You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/12 08:00:25 UTC
[iotdb] 02/02: spotless
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 <xi...@gmail.com>
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;