You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/11/01 01:44:57 UTC
[iotdb] 02/02: fix format
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 <TX...@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;
}