This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch opt_aligned_tvlist
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/opt_aligned_tvlist by this
push:
new 583edfe356b recover example
583edfe356b is described below
commit 583edfe356bc6dbaf88abec5a75a5c366b3cf05b
Author: HTHou <[email protected]>
AuthorDate: Fri Nov 28 11:23:52 2025 +0800
recover example
---
.../iotdb/AlignedTimeseriesSessionExample.java | 87 ++++++++--------------
1 file changed, 33 insertions(+), 54 deletions(-)
diff --git
a/example/session/src/main/java/org/apache/iotdb/AlignedTimeseriesSessionExample.java
b/example/session/src/main/java/org/apache/iotdb/AlignedTimeseriesSessionExample.java
index 84e570bef23..288bd65ddcb 100644
---
a/example/session/src/main/java/org/apache/iotdb/AlignedTimeseriesSessionExample.java
+++
b/example/session/src/main/java/org/apache/iotdb/AlignedTimeseriesSessionExample.java
@@ -63,45 +63,45 @@ public class AlignedTimeseriesSessionExample {
// set session fetchSize
session.setFetchSize(10000);
- // // createTemplate();
- // createAlignedTimeseries();
- // createAlignedTimeseriesWithNullPartical();
- //
- // insertAlignedRecord();
+ // createTemplate();
+ createAlignedTimeseries();
+ createAlignedTimeseriesWithNullPartical();
+
+ insertAlignedRecord();
// insertAlignedRecords();
// insertAlignedRecordsOfOneDevice();
// insertAlignedStringRecord();
// insertAlignedStringRecords();
- insertTabletWithAlignedTimeseriesMethod1();
+ // insertTabletWithAlignedTimeseriesMethod1();
// insertTabletWithAlignedTimeseriesMethod2();
// insertNullableTabletWithAlignedTimeseries();
// insertTabletsWithAlignedTimeseries();
- // session.executeNonQueryStatement(FLUSH);
- // selectTest();
- // selectWithValueFilterTest();
- // selectWithLastTest();
- // selectWithLastTestWithoutValueFilter();
- // session.executeNonQueryStatement("delete from root.sg_1.d1.s1 where
time <= 5");
- // System.out.println("execute sql delete from root.sg_1.d1.s1 where
time <= 5");
- // selectTest();
- // selectWithValueFilterTest();
- // selectWithLastTest();
- // selectWithLastTestWithoutValueFilter();
- // session.executeNonQueryStatement("delete from root.sg_1.d1.s2 where
time <= 3");
- // System.out.println("execute sql delete from root.sg_1.d1.s2 where
time <= 3");
- //
- // selectTest();
- // selectWithValueFilterTest();
- // selectWithLastTest();
- // selectWithLastTestWithoutValueFilter();
- // session.executeNonQueryStatement("delete from root.sg_1.d1.s1 where
time <= 10");
- // System.out.println("execute sql delete from root.sg_1.d1.s1 where
time <= 10");
- // selectTest();
- // selectWithValueFilterTest();
- // selectWithLastTest();
- // selectWithLastTestWithoutValueFilter();
+ session.executeNonQueryStatement(FLUSH);
+ selectTest();
+ selectWithValueFilterTest();
+ selectWithLastTest();
+ selectWithLastTestWithoutValueFilter();
+ session.executeNonQueryStatement("delete from root.sg_1.d1.s1 where time
<= 5");
+ System.out.println("execute sql delete from root.sg_1.d1.s1 where time <=
5");
+ selectTest();
+ selectWithValueFilterTest();
+ selectWithLastTest();
+ selectWithLastTestWithoutValueFilter();
+ session.executeNonQueryStatement("delete from root.sg_1.d1.s2 where time
<= 3");
+ System.out.println("execute sql delete from root.sg_1.d1.s2 where time <=
3");
+
+ selectTest();
+ selectWithValueFilterTest();
+ selectWithLastTest();
+ selectWithLastTestWithoutValueFilter();
+ session.executeNonQueryStatement("delete from root.sg_1.d1.s1 where time
<= 10");
+ System.out.println("execute sql delete from root.sg_1.d1.s1 where time <=
10");
+ selectTest();
+ selectWithValueFilterTest();
+ selectWithLastTest();
+ selectWithLastTestWithoutValueFilter();
// selectWithValueFilterTest();
// selectWithGroupByTest();
@@ -347,6 +347,7 @@ public class AlignedTimeseriesSessionExample {
// only measurementId and data type in MeasurementSchema take effects in
Tablet
List<IMeasurementSchema> schemaList = new ArrayList<>();
schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
+ schemaList.add(new MeasurementSchema("s2", TSDataType.INT32));
Tablet tablet = new Tablet(ROOT_SG1_D1, schemaList);
long timestamp = 1;
@@ -356,30 +357,8 @@ public class AlignedTimeseriesSessionExample {
tablet.addTimestamp(rowIndex, timestamp);
tablet.addValue(
schemaList.get(0).getMeasurementName(), rowIndex, new
SecureRandom().nextLong());
-
- if (tablet.getRowSize() == tablet.getMaxRowNumber()) {
- session.insertAlignedTablet(tablet, true);
- tablet.reset();
- }
- timestamp++;
- }
-
- if (tablet.getRowSize() != 0) {
- session.insertAlignedTablet(tablet);
- tablet.reset();
- }
-
- schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema("s2", TSDataType.INT32));
-
- tablet = new Tablet(ROOT_SG1_D1, schemaList);
- timestamp = 1;
-
- for (long row = 1; row < 100; row++) {
- int rowIndex = tablet.getRowSize();
- tablet.addTimestamp(rowIndex, timestamp);
tablet.addValue(
- schemaList.get(0).getMeasurementName(), rowIndex, new
SecureRandom().nextInt());
+ schemaList.get(1).getMeasurementName(), rowIndex, new
SecureRandom().nextInt());
if (tablet.getRowSize() == tablet.getMaxRowNumber()) {
session.insertAlignedTablet(tablet, true);
@@ -393,7 +372,7 @@ public class AlignedTimeseriesSessionExample {
tablet.reset();
}
- // session.executeNonQueryStatement(FLUSH);
+ session.executeNonQueryStatement(FLUSH);
}
/** Method 2 for insert tablet with aligned timeseries */
