[incubator-iotdb] branch IOTDB-615-Use-binary-rather-than-string-in-insert-plan updated: fix example

[xuekaifeng]

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

xuekaifeng pushed a commit to branch 
IOTDB-615-Use-binary-rather-than-string-in-insert-plan
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to 
refs/heads/IOTDB-615-Use-binary-rather-than-string-in-insert-plan by this push:
     new ca082e7  fix example
ca082e7 is described below

commit ca082e7bd5e2b3a072119f89307ea681f84310d6
Author: 151250176 <151250...@smail.nju.edu.cn>
AuthorDate: Wed May 20 00:48:53 2020 +0800

    fix example
---
 .../apache/iotdb/rocketmq/RocketMQConsumer.java    | 34 ++++++++++++++++++++--
 1 file changed, 32 insertions(+), 2 deletions(-)

diff --git 
a/example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
 
b/example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
index 696b2b9..9421aaf 100644
--- 
a/example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
+++ 
b/example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
@@ -18,6 +18,7 @@
  */
 package org.apache.iotdb.rocketmq;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import org.apache.iotdb.rpc.IoTDBConnectionException;
@@ -89,8 +90,37 @@ public class RocketMQConsumer {
     String device = dataArray[0];
     long time = Long.parseLong(dataArray[1]);
     List<String> measurements = Arrays.asList(dataArray[2].split(":"));
-    List<String> values = Arrays.asList(dataArray[3].split(":"));
-    session.insertRecord(device, time, measurements, values);
+    List<TSDataType> types = new ArrayList<>();
+    for(String type : dataArray[3].split(":")){
+      types.add(TSDataType.valueOf(type));
+    }
+
+    List<Object> values = new ArrayList<>();
+    String[] valuesStr = dataArray[4].split(":");
+    for(int i = 0; i < valuesStr.length; i++){
+      switch (types.get(i)){
+        case INT64:
+          values.add(Long.parseLong(valuesStr[i]));
+          break;
+        case DOUBLE:
+          values.add(Double.parseDouble(valuesStr[i]));
+          break;
+        case INT32:
+          values.add(Integer.parseInt(valuesStr[i]));
+          break;
+        case TEXT:
+          values.add(valuesStr[i]);
+          break;
+        case FLOAT:
+          values.add(Float.parseFloat(valuesStr[i]));
+          break;
+        case BOOLEAN:
+          values.add(Boolean.parseBoolean(valuesStr[i]));
+          break;
+      }
+    }
+
+    session.insertRecord(device, time, measurements, types, values);
   }
 
   public void start() throws MQClientException {