[iotdb] branch jira1486 updated: [To rel/0.12][IOTDB-1486] Add the createTemplate Session example in 0.12

[haonan]

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

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


The following commit(s) were added to refs/heads/jira1486 by this push:
     new 493826b  [To rel/0.12][IOTDB-1486] Add the createTemplate Session 
example in 0.12
493826b is described below

commit 493826bea7c5887a79c0819872cdd56faf6e515b
Author: HTHou <hhao...@outlook.com>
AuthorDate: Mon Jul 12 15:48:28 2021 +0800

    [To rel/0.12][IOTDB-1486] Add the createTemplate Session example in 0.12
---
 .../main/java/org/apache/iotdb/SessionExample.java | 40 ++++++++++++++++++++++
 1 file changed, 40 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 1e5096c..45b6b4f 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -31,6 +31,7 @@ import org.apache.iotdb.tsfile.write.record.Tablet;
 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;
@@ -65,6 +66,7 @@ public class SessionExample {
       }
     }
 
+    // createTemplate();
     createTimeseries();
     createMultiTimeseries();
     insertRecord();
@@ -187,6 +189,44 @@ 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"));
+    measurementList.add(Collections.singletonList("s4"));
+    measurementList.add(Collections.singletonList("s5"));
+
+    List<List<TSDataType>> dataTypeList = new ArrayList<>();
+    dataTypeList.add(Collections.singletonList(TSDataType.INT64));
+    dataTypeList.add(Collections.singletonList(TSDataType.INT64));
+    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));
+    encodingList.add(Collections.singletonList(TSEncoding.RLE));
+    encodingList.add(Collections.singletonList(TSEncoding.RLE));
+
+    List<CompressionType> compressionTypes = new ArrayList<>();
+    for (int i = 0; i < 5; i++) {
+      compressionTypes.add(CompressionType.SNAPPY);
+    }
+    List<String> schemaNames = new ArrayList<>();
+    schemaNames.add("s1");
+    schemaNames.add("s2");
+    schemaNames.add("s3");
+    schemaNames.add("s4");
+    schemaNames.add("s5");
+
+    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<>();