You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2021/08/06 03:08:57 UTC
[iotdb] 01/01: [IOTDB-1486] Add a createTemplate Session example
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch TemplateExample
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d0220c498fe8b3a69f70d2ca51d2ab3cecb1d470
Author: Haonan <hh...@outlook.com>
AuthorDate: Mon Jul 12 17:01:41 2021 +0800
[IOTDB-1486] Add a createTemplate Session example
---
.../main/java/org/apache/iotdb/SessionExample.java | 33 ++++++++++++++++++++++
1 file changed, 33 insertions(+)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 0f1ad8b..89e1a5d 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -33,6 +33,7 @@ import org.apache.iotdb.tsfile.write.schema.IMeasurementSchema;
import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
import java.util.ArrayList;
+import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -68,6 +69,7 @@ public class SessionExample {
}
}
+ // createTemplate();
createTimeseries();
createMultiTimeseries();
insertRecord();
@@ -213,6 +215,37 @@ public class SessionExample {
}
}
+ private static void createTemplate()
+ throws IoTDBConnectionException, StatementExecutionException {
+ List<List<String>> measurementList = new ArrayList<>();
+ measurementList.add(Collections.singletonList("s1"));
+ measurementList.add(Collections.singletonList("s2"));
+ measurementList.add(Collections.singletonList("s3"));
+
+ List<List<TSDataType>> dataTypeList = new ArrayList<>();
+ dataTypeList.add(Collections.singletonList(TSDataType.INT64));
+ dataTypeList.add(Collections.singletonList(TSDataType.INT64));
+ dataTypeList.add(Collections.singletonList(TSDataType.INT64));
+
+ List<List<TSEncoding>> encodingList = new ArrayList<>();
+ encodingList.add(Collections.singletonList(TSEncoding.RLE));
+ encodingList.add(Collections.singletonList(TSEncoding.RLE));
+ encodingList.add(Collections.singletonList(TSEncoding.RLE));
+
+ List<CompressionType> compressionTypes = new ArrayList<>();
+ for (int i = 0; i < 3; i++) {
+ compressionTypes.add(CompressionType.SNAPPY);
+ }
+ List<String> schemaNames = new ArrayList<>();
+ schemaNames.add("s1");
+ schemaNames.add("s2");
+ schemaNames.add("s3");
+
+ session.createSchemaTemplate(
+ "template1", schemaNames, measurementList, dataTypeList, encodingList, compressionTypes);
+ session.setSchemaTemplate("template1", "root.sg1");
+ }
+
private static void insertRecord() throws IoTDBConnectionException, StatementExecutionException {
String deviceId = ROOT_SG1_D1;
List<String> measurements = new ArrayList<>();