[incubator-iotdb] branch master updated: add the print of information about chunkgroups for debug (#175)

[qiaojialin]

This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new f8754f9  add the print of information about chunkgroups for debug 
(#175)
f8754f9 is described below

commit f8754f929a811464bbd5c1bb75367219fab1b0d0
Author: RUI, LEI <33376433+lei...@users.noreply.github.com>
AuthorDate: Mon May 13 14:06:55 2019 +0800

    add the print of information about chunkgroups for debug (#175)
    
    * print debug information about the start and end position of 
chunkgroupMetadata
---
 .../iotdb/tsfile/read/ReadInPartitionTest.java     | 33 ++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git 
a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadInPartitionTest.java 
b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadInPartitionTest.java
index 96bf3c1..a7cc8d9 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadInPartitionTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadInPartitionTest.java
@@ -18,11 +18,18 @@
  */
 package org.apache.iotdb.tsfile.read;
 
+import java.io.File;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
+import java.util.stream.Collectors;
 import org.apache.iotdb.tsfile.common.constant.QueryConstant;
 import org.apache.iotdb.tsfile.exception.write.WriteProcessException;
+import org.apache.iotdb.tsfile.file.metadata.ChunkGroupMetaData;
+import org.apache.iotdb.tsfile.file.metadata.TsDeviceMetadata;
+import org.apache.iotdb.tsfile.file.metadata.TsDeviceMetadataIndex;
+import org.apache.iotdb.tsfile.file.metadata.TsFileMetaData;
 import org.apache.iotdb.tsfile.read.common.Path;
 import org.apache.iotdb.tsfile.read.common.RowRecord;
 import org.apache.iotdb.tsfile.read.expression.QueryExpression;
@@ -43,6 +50,32 @@ public class ReadInPartitionTest {
   public void before() throws InterruptedException, WriteProcessException, 
IOException {
     TsFileGeneratorForTest.generateFile(1000000, 1024 * 1024, 10000);
     reader = new TsFileSequenceReader(FILE_PATH);
+
+    System.out.println("file length: " + new File(FILE_PATH).length());
+    System.out.println("file magic head: " + reader.readHeadMagic());
+    System.out.println("file magic tail: " + reader.readTailMagic());
+    System.out.println("Level 1 metadata position: " + 
reader.getFileMetadataPos());
+    System.out.println("Level 1 metadata size: " + 
reader.getFileMetadataPos());
+    TsFileMetaData metaData = reader.readFileMetadata();
+    System.out.println("[Metadata]");
+    List<TsDeviceMetadataIndex> deviceMetadataIndexList = 
metaData.getDeviceMap().values().stream()
+        .sorted((x, y) -> (int) (x.getOffset() - 
y.getOffset())).collect(Collectors.toList());
+    for (TsDeviceMetadataIndex index : deviceMetadataIndexList) {
+      TsDeviceMetadata deviceMetadata = reader.readTsDeviceMetaData(index);
+      List<ChunkGroupMetaData> chunkGroupMetaDataList = 
deviceMetadata.getChunkGroupMetaDataList();
+      for (ChunkGroupMetaData chunkGroupMetaData : chunkGroupMetaDataList) {
+        System.out.println(String
+            .format("\t[Device]Device %s", chunkGroupMetaData.getDeviceID()));
+        System.out.println("chunkGroupMetaData.start: 
"+chunkGroupMetaData.getStartOffsetOfChunkGroup()+" ,end: "+
+            chunkGroupMetaData.getEndOffsetOfChunkGroup());
+
+//        for (ChunkMetaData chunkMetadata : 
chunkGroupMetaData.getChunkMetaDataList()) {
+//          System.out.println("\t\tMeasurement:" + 
chunkMetadata.getMeasurementUid());
+//          System.out.println("\t\tFile offset:" + 
chunkMetadata.getOffsetOfChunkHeader());
+//        }
+
+      }
+    }
   }
 
   @After