This is an automated email from the ASF dual-hosted git repository.
jiangtian 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 950ecff3418 modify table session example (#14357)
950ecff3418 is described below
commit 950ecff3418d781f52347423f410045068c05830
Author: shuwenwei <[email protected]>
AuthorDate: Mon Dec 9 10:01:08 2024 +0800
modify table session example (#14357)
---
.../org/apache/iotdb/TableModelSessionExample.java | 29 ++++++++--------------
.../apache/iotdb/TableModelSessionPoolExample.java | 29 ++++++++--------------
2 files changed, 22 insertions(+), 36 deletions(-)
diff --git
a/example/session/src/main/java/org/apache/iotdb/TableModelSessionExample.java
b/example/session/src/main/java/org/apache/iotdb/TableModelSessionExample.java
index 91923566118..e93e1d1d04b 100644
---
a/example/session/src/main/java/org/apache/iotdb/TableModelSessionExample.java
+++
b/example/session/src/main/java/org/apache/iotdb/TableModelSessionExample.java
@@ -27,8 +27,6 @@ import org.apache.iotdb.session.TableSessionBuilder;
import org.apache.tsfile.enums.TSDataType;
import org.apache.tsfile.write.record.Tablet;
-import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import java.util.ArrayList;
import java.util.Arrays;
@@ -79,15 +77,16 @@ public class TableModelSessionExample {
}
// insert table data by tablet
- List<IMeasurementSchema> measurementSchemaList =
- new ArrayList<>(
- Arrays.asList(
- new MeasurementSchema("region_id", TSDataType.STRING),
- new MeasurementSchema("plant_id", TSDataType.STRING),
- new MeasurementSchema("device_id", TSDataType.STRING),
- new MeasurementSchema("model", TSDataType.STRING),
- new MeasurementSchema("temperature", TSDataType.FLOAT),
- new MeasurementSchema("humidity", TSDataType.DOUBLE)));
+ List<String> measurementNameList =
+ Arrays.asList("region_id", "plant_id", "device_id", "model",
"temperature", "humidity");
+ List<TSDataType> dataTypeList =
+ Arrays.asList(
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.FLOAT,
+ TSDataType.DOUBLE);
List<Tablet.ColumnCategory> columnTypeList =
new ArrayList<>(
Arrays.asList(
@@ -97,13 +96,7 @@ public class TableModelSessionExample {
Tablet.ColumnCategory.ATTRIBUTE,
Tablet.ColumnCategory.MEASUREMENT,
Tablet.ColumnCategory.MEASUREMENT));
- Tablet tablet =
- new Tablet(
- "test1",
- IMeasurementSchema.getMeasurementNameList(measurementSchemaList),
- IMeasurementSchema.getDataTypeList(measurementSchemaList),
- columnTypeList,
- 100);
+ Tablet tablet = new Tablet("test1", measurementNameList, dataTypeList,
columnTypeList, 100);
for (long timestamp = 0; timestamp < 100; timestamp++) {
int rowIndex = tablet.getRowSize();
tablet.addTimestamp(rowIndex, timestamp);
diff --git
a/example/session/src/main/java/org/apache/iotdb/TableModelSessionPoolExample.java
b/example/session/src/main/java/org/apache/iotdb/TableModelSessionPoolExample.java
index cb161925319..78cefcbc2c5 100644
---
a/example/session/src/main/java/org/apache/iotdb/TableModelSessionPoolExample.java
+++
b/example/session/src/main/java/org/apache/iotdb/TableModelSessionPoolExample.java
@@ -29,8 +29,6 @@ import org.apache.iotdb.session.pool.TableSessionPoolBuilder;
import org.apache.tsfile.enums.TSDataType;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.Tablet.ColumnCategory;
-import org.apache.tsfile.write.schema.IMeasurementSchema;
-import org.apache.tsfile.write.schema.MeasurementSchema;
import java.util.ArrayList;
import java.util.Arrays;
@@ -97,15 +95,16 @@ public class TableModelSessionPoolExample {
}
// insert table data by tablet
- List<IMeasurementSchema> measurementSchemaList =
- new ArrayList<>(
- Arrays.asList(
- new MeasurementSchema("region_id", TSDataType.STRING),
- new MeasurementSchema("plant_id", TSDataType.STRING),
- new MeasurementSchema("device_id", TSDataType.STRING),
- new MeasurementSchema("model", TSDataType.STRING),
- new MeasurementSchema("temperature", TSDataType.FLOAT),
- new MeasurementSchema("humidity", TSDataType.DOUBLE)));
+ List<String> measurementNameList =
+ Arrays.asList("region_id", "plant_id", "device_id", "model",
"temperature", "humidity");
+ List<TSDataType> dataTypeList =
+ Arrays.asList(
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.STRING,
+ TSDataType.FLOAT,
+ TSDataType.DOUBLE);
List<ColumnCategory> columnTypeList =
new ArrayList<>(
Arrays.asList(
@@ -115,13 +114,7 @@ public class TableModelSessionPoolExample {
ColumnCategory.ATTRIBUTE,
ColumnCategory.MEASUREMENT,
ColumnCategory.MEASUREMENT));
- Tablet tablet =
- new Tablet(
- "test1",
- IMeasurementSchema.getMeasurementNameList(measurementSchemaList),
- IMeasurementSchema.getDataTypeList(measurementSchemaList),
- columnTypeList,
- 100);
+ Tablet tablet = new Tablet("test1", measurementNameList, dataTypeList,
columnTypeList, 100);
for (long timestamp = 0; timestamp < 100; timestamp++) {
int rowIndex = tablet.getRowSize();
tablet.addTimestamp(rowIndex, timestamp);
