This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch xingtanzjr/graph_visitor in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6badf76ed4806f5bf6f0ebbb9a8d8e662b71c4e0 Author: Jinrui.Zhang <[email protected]> AuthorDate: Tue Apr 12 16:00:14 2022 +0800 spotless --- .../db/mpp/sql/planner/plan/node/PlanGraphPrinter.java | 18 ++++++++---------- .../iotdb/db/mpp/sql/planner/plan/node/PlanNode.java | 3 +-- .../iotdb/db/mpp/sql/plan/DistributionPlannerTest.java | 2 -- 3 files changed, 9 insertions(+), 14 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java index 660f51d1e9..b8136419f7 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java @@ -19,13 +19,14 @@ package org.apache.iotdb.db.mpp.sql.planner.plan.node; -import org.apache.commons.lang3.Validate; import org.apache.iotdb.db.mpp.sql.planner.plan.node.process.ExchangeNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.process.LimitNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.process.TimeJoinNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.sink.FragmentSinkNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.source.SeriesScanNode; +import org.apache.commons.lang3.Validate; + import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -96,7 +97,7 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter private List<String> render(PlanNode node, List<String> nodeBoxString, GraphContext context) { Box box = new Box(nodeBoxString); List<List<String>> children = new ArrayList<>(); - for(PlanNode child : node.getChildren()) { + for (PlanNode child : node.getChildren()) { children.add(child.accept(this, context)); } box.calculateBoxParams(children); @@ -156,7 +157,8 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter } StringBuilder line1 = new StringBuilder(); for (int i = 0; i < box.lineWidth; i++) { - if (i < getChildMidPosition(children, 0) || i > getChildMidPosition(children, children.size() - 1)) { + if (i < getChildMidPosition(children, 0) + || i > getChildMidPosition(children, children.size() - 1)) { line1.append(INDENT); continue; } @@ -281,7 +283,7 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter int childrenWidth = 0; for (List<String> childBoxString : childBoxStrings) { Validate.isTrue(childBoxString.size() > 0, "Lines of box string should be greater than 0"); - childrenWidth +=childBoxString.get(0).length(); + childrenWidth += childBoxString.get(0).length(); } childrenWidth += childBoxStrings.size() > 1 ? (childBoxStrings.size() - 1) * BOX_MARGIN : 0; this.lineWidth = Math.max(this.boxWidth, childrenWidth); @@ -291,9 +293,7 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter } } - public static class GraphContext { - - } + public static class GraphContext {} public static List<String> getGraph(PlanNode node) { return node.accept(new PlanGraphPrinter(), new PlanGraphPrinter.GraphContext()); @@ -301,10 +301,8 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter public static void print(PlanNode node) { List<String> lines = getGraph(node); - for(String line : lines) { + for (String line : lines) { System.out.println(line); } } } - - diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java index 6636a5b41d..8f9734123c 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java @@ -18,10 +18,9 @@ */ package org.apache.iotdb.db.mpp.sql.planner.plan.node; -import com.google.common.collect.ImmutableList; -import com.google.common.collect.Lists; import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils; +import com.google.common.collect.ImmutableList; import org.apache.commons.lang.Validate; import java.nio.ByteBuffer; diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java index f68f1f8c36..68b12abb0e 100644 --- a/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java +++ b/server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java @@ -34,10 +34,8 @@ import org.apache.iotdb.db.mpp.sql.analyze.Analysis; import org.apache.iotdb.db.mpp.sql.analyze.QueryType; import org.apache.iotdb.db.mpp.sql.planner.DistributionPlanner; import org.apache.iotdb.db.mpp.sql.planner.plan.DistributedQueryPlan; -import org.apache.iotdb.db.mpp.sql.planner.plan.FragmentInstance; import org.apache.iotdb.db.mpp.sql.planner.plan.LogicalQueryPlan; import org.apache.iotdb.db.mpp.sql.planner.plan.SubPlan; -import org.apache.iotdb.db.mpp.sql.planner.plan.node.PlanGraphPrinter; import org.apache.iotdb.db.mpp.sql.planner.plan.node.PlanNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.process.LimitNode; import org.apache.iotdb.db.mpp.sql.planner.plan.node.process.TimeJoinNode;
