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 <[email protected]> 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; }
