iotdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [iotdb] 02/02: fix format
Date Sun, 01 Nov 2020 01:44:57 GMT
This is an automated email from the ASF dual-hosted git repository.

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

commit ce4a471cef281a5d83c952cad892b8055578337f
Author: LebronAl <TXYPotato@gmail.com>
AuthorDate: Fri Oct 30 16:42:03 2020 +0800

    fix format
---
 .../apache/iotdb/db/qp/executor/PlanExecutor.java  | 31 +++++++++-------------
 1 file changed, 13 insertions(+), 18 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
index b05283f..db3e52a 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
@@ -1055,31 +1055,26 @@ public class PlanExecutor implements IPlanExecutor {
     return true;
   }
 
-  private boolean createMultiTimeSeries(CreateMultiTimeSeriesPlan createMultiTimeSeriesPlan)
{
-    Map<Integer, Exception> results = new HashMap<>(createMultiTimeSeriesPlan.getPaths().size());
-    for (int i = 0; i < createMultiTimeSeriesPlan.getPaths().size(); i++) {
+  private boolean createMultiTimeSeries(CreateMultiTimeSeriesPlan multiPlan) {
+    Map<Integer, Exception> results = new HashMap<>(multiPlan.getPaths().size());
+    for (int i = 0; i < multiPlan.getPaths().size(); i++) {
       CreateTimeSeriesPlan plan = new CreateTimeSeriesPlan(
-          createMultiTimeSeriesPlan.getPaths().get(i),
-          createMultiTimeSeriesPlan.getDataTypes().get(i),
-          createMultiTimeSeriesPlan.getEncodings().get(i),
-          createMultiTimeSeriesPlan.getCompressors().get(i),
-          createMultiTimeSeriesPlan.getProps() == null ? null
-              : createMultiTimeSeriesPlan.getProps().get(i),
-          createMultiTimeSeriesPlan.getTags() == null ? null
-              : createMultiTimeSeriesPlan.getTags().get(i),
-          createMultiTimeSeriesPlan.getAttributes() == null ? null
-              : createMultiTimeSeriesPlan.getAttributes().get(i),
-          createMultiTimeSeriesPlan.getAlias() == null ? null
-              : createMultiTimeSeriesPlan.getAlias().get(i));
-
+          multiPlan.getPaths().get(i),
+          multiPlan.getDataTypes().get(i),
+          multiPlan.getEncodings().get(i),
+          multiPlan.getCompressors().get(i),
+          multiPlan.getProps() == null ? null : multiPlan.getProps().get(i),
+          multiPlan.getTags() == null ? null : multiPlan.getTags().get(i),
+          multiPlan.getAttributes() == null ? null : multiPlan.getAttributes().get(i),
+          multiPlan.getAlias() == null ? null : multiPlan.getAlias().get(i));
       try {
         createTimeSeries(plan);
       } catch (QueryProcessException e) {
-        results.put(createMultiTimeSeriesPlan.getIndexes().get(i), e);
+        results.put(multiPlan.getIndexes().get(i), e);
         logger.debug("meet error while processing create timeseries. ", e);
       }
     }
-    createMultiTimeSeriesPlan.setResults(results);
+    multiPlan.setResults(results);
     return true;
   }
 


Mime
View raw message