This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/join in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 98b071c5beeb63d1de9999cf4c844b7f48a6a470 Author: Beyyes <[email protected]> AuthorDate: Thu Aug 15 16:11:36 2024 +0800 add join plan graph --- .../queryengine/plan/planner/plan/node/PlanGraphPrinter.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java index 4b99bfe80f3..8d612709af1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java @@ -728,6 +728,17 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter return render(node, boxValue, context); } + @Override + public List<String> visitJoin( + org.apache.iotdb.db.queryengine.plan.relational.planner.node.JoinNode node, + GraphContext context) { + List<String> boxValue = new ArrayList<>(); + boxValue.add(String.format("Join-%s", node.getPlanNodeId().getId())); + boxValue.add(String.format("JoinType: %s", node.getJoinType())); + boxValue.add(String.format("JoinCriteria: %s", node.getCriteria())); + return render(node, boxValue, context); + } + private String printRegion(TRegionReplicaSet regionReplicaSet) { return String.format( "Partition: %s",
