You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/04/10 10:12:22 UTC
[incubator-iotdb] 01/01: fix session example
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_SessionExample
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 93ba23136e6bae3e1dcfe3e499f3e0a68d24a218
Author: qiaojialin <64...@qq.com>
AuthorDate: Fri Apr 10 18:12:01 2020 +0800
fix session example
---
.../src/main/java/org/apache/iotdb/SessionExample.java | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
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 08596b2..8658d91 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -44,16 +44,21 @@ public class SessionExample {
session = new Session("127.0.0.1", 6667, "root", "root");
session.open(false);
- session.setStorageGroup("root.sg1");
- if (session.checkTimeseriesExists("root.sg1.d1.s1")) {
+ try {
+ session.setStorageGroup("root.sg1");
+ } catch (Exception e) {
+ // ignore duplicated set
+ }
+
+ if (!session.checkTimeseriesExists("root.sg1.d1.s1")) {
session.createTimeseries("root.sg1.d1.s1", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}
- if (session.checkTimeseriesExists("root.sg1.d1.s2")) {
+ if (!session.checkTimeseriesExists("root.sg1.d1.s2")) {
session.createTimeseries("root.sg1.d1.s2", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}
- if (session.checkTimeseriesExists("root.sg1.d1.s3")) {
+ if (!session.checkTimeseriesExists("root.sg1.d1.s3")) {
session.createTimeseries("root.sg1.d1.s3", TSDataType.INT64, TSEncoding.RLE,
CompressionType.SNAPPY);
}