This is an automated email from the ASF dual-hosted git repository. qiaojialin pushed a commit to branch fix_tsfile_example in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 5e636a076c9d61975eeaacd03f93a2f27f46d282 Author: qiaojialin <[email protected]> AuthorDate: Fri Jul 24 16:36:30 2020 +0800 fix TsFileWriteWithTablet --- .../main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 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..1a5dd74 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; @@ -61,7 +62,9 @@ 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( + MeasurementSchema measurementSchema = new MeasurementSchema("sensor_" + (i + 1), TSDataType.INT64, TSEncoding.TS_2DIFF); + measurementSchemas.add(measurementSchema); + schema.registerTimeseries(new Path("root.sg.device_1", "sensor_" + (i + 1)), new MeasurementSchema("sensor_" + (i + 1), TSDataType.INT64, TSEncoding.TS_2DIFF)); } @@ -69,7 +72,7 @@ public class TsFileWriteWithTablet { try (TsFileWriter tsFileWriter = new TsFileWriter(f, schema)) { // construct the tablet - Tablet tablet = new Tablet("device_1", measurementSchemas); + Tablet tablet = new Tablet("root.sg.device_1", measurementSchemas); long[] timestamps = tablet.timestamps; Object[] values = tablet.values;
