recover example
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 84e570b..288bd65 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 @@
// 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 @@
// 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 @@
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 @@
tablet.reset();
}
- // session.executeNonQueryStatement(FLUSH);
+ session.executeNonQueryStatement(FLUSH);
}
/** Method 2 for insert tablet with aligned timeseries */
