[incubator-iotdb] branch dev_merge updated: change session example generate

[ejttianyu]

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

ejttianyu pushed a commit to branch dev_merge
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/dev_merge by this push:
     new 00c61e8  change session example generate
00c61e8 is described below

commit 00c61e8dccd0df9d3852540e8e281f90a0495f32
Author: EJTTianyu <1653503...@qq.com>
AuthorDate: Thu May 14 11:06:31 2020 +0800

    change session example generate
---
 cli/src/main/java/org/apache/iotdb/cli/SessionTest.java | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java 
b/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
index 0de62dd..677caeb 100644
--- a/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
+++ b/cli/src/main/java/org/apache/iotdb/cli/SessionTest.java
@@ -20,6 +20,7 @@ package org.apache.iotdb.cli;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Random;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
 import org.apache.iotdb.rpc.StatementExecutionException;
 import org.apache.iotdb.session.pool.SessionDataSetWrapper;
@@ -58,6 +59,8 @@ public class SessionTest {
 
     private int device;
 
+    Random random = new Random();
+
     public Write(int i) {
       this.device = i;
     }
@@ -68,11 +71,11 @@ public class SessionTest {
 
       long time = 0;
       while (true) {
-        try {
-          Thread.sleep(1000);
-        } catch (InterruptedException e) {
-          e.printStackTrace();
-        }
+//        try {
+//          Thread.sleep(1000);
+//        } catch (InterruptedException e) {
+//          e.printStackTrace();
+//        }
         long start = System.currentTimeMillis();
         time += 5000;
         String deviceId = "root.sg.d1";
@@ -83,11 +86,11 @@ public class SessionTest {
 
         List<String> values = new ArrayList<>();
         for (int i = 0; i < 50000; i++) {
-          values.add("1");
+          values.add(random.nextInt(1000) + "");
         }
 
         try {
-          session.insertRecord(deviceId, time, measurements, values);
+          session.insertRecord(deviceId, time - random.nextInt(10000), 
measurements, values);
         } catch (IoTDBConnectionException e) {
           e.printStackTrace();
         } catch (StatementExecutionException e) {