You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/07/24 08:36:51 UTC
[incubator-iotdb] 01/01: fix TsFileWriteWithTablet
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 <64...@qq.com>
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;