[incubator-iotdb] branch master updated: fix TsFileWriteWithTablet (#1558)

[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 358640c  fix TsFileWriteWithTablet (#1558)
358640c is described below

commit 358640cb8bb875c3d1b6b7a15c78a286b01915d9
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Sat Jul 25 15:24:52 2020 +0800

    fix TsFileWriteWithTablet (#1558)
    
    * fix TsFileWriteWithTablet
    
    Co-authored-by: HTHou <hhao...@outlook.com>
---
 .../java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java   | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java
 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java
index 7dfe074..a013acc 100644
--- 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java
+++ 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java
@@ -25,6 +25,7 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
 import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
 
 import org.apache.iotdb.tsfile.fileSystem.FSFactoryProducer;
+import org.apache.iotdb.tsfile.read.common.Path;
 import org.apache.iotdb.tsfile.write.TsFileWriter;
 import org.apache.iotdb.tsfile.write.record.Tablet;
 import org.apache.iotdb.tsfile.write.schema.Schema;
@@ -53,6 +54,8 @@ public class TsFileWriteWithTablet {
 
       Schema schema = new Schema();
 
+      String device = "root.sg.device_1";
+      String sensorPrefix = "sensor_";
       // the number of rows to include in the tablet
       int rowNum = 1000000;
       // the number of values to include in the tablet
@@ -61,15 +64,17 @@ public class TsFileWriteWithTablet {
       List<MeasurementSchema> measurementSchemas = new ArrayList<>();
       // add measurements into file schema (all with INT64 data type)
       for (int i = 0; i < sensorNum; i++) {
-        measurementSchemas.add(
-            new MeasurementSchema("sensor_" + (i + 1), TSDataType.INT64, 
TSEncoding.TS_2DIFF));
+        MeasurementSchema measurementSchema = new 
MeasurementSchema(sensorPrefix + (i + 1), TSDataType.INT64, 
TSEncoding.TS_2DIFF);
+        measurementSchemas.add(measurementSchema);
+        schema.registerTimeseries(new Path(device, sensorPrefix + (i + 1)),
+            new MeasurementSchema(sensorPrefix + (i + 1), TSDataType.INT64, 
TSEncoding.TS_2DIFF));
       }
 
       // add measurements into TSFileWriter
       try (TsFileWriter tsFileWriter = new TsFileWriter(f, schema)) {
 
         // construct the tablet
-        Tablet tablet = new Tablet("device_1", measurementSchemas);
+        Tablet tablet = new Tablet(device, measurementSchemas);
 
         long[] timestamps = tablet.timestamps;
         Object[] values = tablet.values;