[iotdb] branch master updated: Feature/simplified tsfile examples (#10906)

[haonan]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new e9fe0b1082d Feature/simplified tsfile examples (#10906)
e9fe0b1082d is described below

commit e9fe0b1082dff04815e75a84b7778126af55d2eb
Author: Christofer Dutz <cd...@apache.org>
AuthorDate: Thu Aug 24 08:37:28 2023 +0200

    Feature/simplified tsfile examples (#10906)
---
 .../org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java   | 8 ++------
 .../org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java     | 6 +-----
 .../java/org/apache/iotdb/tsfile/TsFileWriteWithTSRecord.java     | 8 ++------
 .../main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java  | 6 +-----
 4 files changed, 6 insertions(+), 22 deletions(-)

diff --git 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java
 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java
index 252df3ac19e..0a38aa8b882 100644
--- 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java
+++ 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java
@@ -68,12 +68,8 @@ public class TsFileWriteAlignedWithTSRecord {
       // register timeseries
       tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), 
measurementSchemas);
 
-      List<IMeasurementSchema> writeMeasurementScheams = new ArrayList<>();
       // example1
-      writeMeasurementScheams.add(measurementSchemas.get(0));
-      writeMeasurementScheams.add(measurementSchemas.get(1));
-      writeMeasurementScheams.add(measurementSchemas.get(2));
-      writeAligned(tsFileWriter, DEVICE_1, writeMeasurementScheams, 1000000, 
0, 0);
+      writeAligned(tsFileWriter, DEVICE_1, measurementSchemas, 1000000, 0, 0);
     } catch (WriteProcessException e) {
       logger.error("write TSRecord failed", e);
     }
@@ -82,7 +78,7 @@ public class TsFileWriteAlignedWithTSRecord {
   private static void writeAligned(
       TsFileWriter tsFileWriter,
       String deviceId,
-      List<IMeasurementSchema> schemas,
+      List<MeasurementSchema> schemas,
       long rowSize,
       long startTime,
       long startValue)
diff --git 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java
 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java
index 0aee3c01686..e33f96d5c03 100644
--- 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java
+++ 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java
@@ -66,12 +66,8 @@ public class TsFileWriteAlignedWithTablet {
       // register align timeseries
       tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), 
measurementSchemas);
 
-      List<MeasurementSchema> writeMeasurementScheams = new ArrayList<>();
       // example 1
-      writeMeasurementScheams.add(measurementSchemas.get(0));
-      writeMeasurementScheams.add(measurementSchemas.get(1));
-      writeMeasurementScheams.add(measurementSchemas.get(2));
-      writeAlignedWithTablet(tsFileWriter, DEVICE_1, writeMeasurementScheams, 
200000, 0, 0);
+      writeAlignedWithTablet(tsFileWriter, DEVICE_1, measurementSchemas, 
200000, 0, 0);
 
       writeNonAlignedWithTablet(tsFileWriter); // write nonAligned timeseries
     } catch (WriteProcessException e) {
diff --git 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTSRecord.java
 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTSRecord.java
index 3d42e9e0f03..b8f2156c0c9 100644
--- 
a/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTSRecord.java
+++ 
b/example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTSRecord.java
@@ -69,12 +69,8 @@ public class TsFileWriteWithTSRecord {
         // register timeseries
         tsFileWriter.registerTimeseries(new Path(DEVICE_1), schemas);
 
-        List<IMeasurementSchema> writeMeasurementScheams = new ArrayList<>();
         // example1
-        writeMeasurementScheams.add(schemas.get(0));
-        writeMeasurementScheams.add(schemas.get(1));
-        writeMeasurementScheams.add(schemas.get(2));
-        write(tsFileWriter, DEVICE_1, writeMeasurementScheams, 10000, 0, 0);
+        write(tsFileWriter, DEVICE_1, schemas, 10000, 0, 0);
       }
     } catch (Exception e) {
       logger.error("TsFileWriteWithTSRecord meet error", e);
@@ -84,7 +80,7 @@ public class TsFileWriteWithTSRecord {
   private static void write(
       TsFileWriter tsFileWriter,
       String deviceId,
-      List<IMeasurementSchema> schemas,
+      List<MeasurementSchema> schemas,
       long rowSize,
       long startTime,
       long startValue)
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 c3f37bfe9d5..c79e3a32c4e 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
@@ -65,12 +65,8 @@ public class TsFileWriteWithTablet {
         // register nonAligned timeseries
         tsFileWriter.registerTimeseries(new Path(DEVICE_1), 
measurementSchemas);
 
-        List<MeasurementSchema> writeMeasurementScheams = new ArrayList<>();
         // example 1
-        writeMeasurementScheams.add(measurementSchemas.get(0));
-        writeMeasurementScheams.add(measurementSchemas.get(1));
-        writeMeasurementScheams.add(measurementSchemas.get(2));
-        writeWithTablet(tsFileWriter, DEVICE_1, writeMeasurementScheams, 
10000, 0, 0);
+        writeWithTablet(tsFileWriter, DEVICE_1, measurementSchemas, 10000, 0, 
0);
       }
     } catch (Exception e) {
       logger.error("meet error in TsFileWrite with tablet", e);