You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2020/11/02 07:54:09 UTC
[iotdb] 03/04: insert
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a commit to branch change_jdbc_to_session_in_csv
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d81c2131ed84b999ac3e63c83f4f784bbd848891
Author: Boris <96...@qq.com>
AuthorDate: Mon Nov 2 14:22:56 2020 +0800
insert
---
cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java b/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
index 21f9016..266add5 100644
--- a/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
+++ b/cli/src/main/java/org/apache/iotdb/tool/ImportCsv.java
@@ -135,6 +135,14 @@ public class ImportCsv extends AbstractCsvTool {
for(String device: deviceToMeasurementsAndPositions.keySet()) {
devices.add(device);
Map<String, Integer> measurementsAndPositions = deviceToMeasurementsAndPositions.get(device);
+ List<String> measurements = new ArrayList<>();
+ List<String> values = new ArrayList<>();
+ for(String measurement : measurementsAndPositions.keySet()) {
+ measurements.add(measurement);
+ values.add(cols[measurementsAndPositions.get(measurement)]);
+ }
+ measurementsList.add(measurements);
+ valuesList.add(values);
}
}