This is an automated email from the ASF dual-hosted git repository. xiangweiwei pushed a commit to branch advancePipeline in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d503d4fb0862417536c786ca370971964614ff2e Author: Alima777 <[email protected]> AuthorDate: Wed Feb 8 11:31:57 2023 +0800 implement createSubNode in HorizontallyConcatNode --- .../plan/planner/plan/node/process/HorizontallyConcatNode.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/HorizontallyConcatNode.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/HorizontallyConcatNode.java index f75bd68371..28ec4896f8 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/HorizontallyConcatNode.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/HorizontallyConcatNode.java @@ -42,6 +42,10 @@ public class HorizontallyConcatNode extends MultiChildProcessNode { super(id, new ArrayList<>()); } + public HorizontallyConcatNode(PlanNodeId id, List<PlanNode> children) { + super(id, children); + } + @Override public PlanNode clone() { return new HorizontallyConcatNode(getPlanNodeId()); @@ -49,8 +53,9 @@ public class HorizontallyConcatNode extends MultiChildProcessNode { @Override public PlanNode createSubNode(int subNodeId, int startIndex, int endIndex) { - return new VerticallyConcatNode( - new PlanNodeId(String.format("%s-%s", getPlanNodeId(), subNodeId))); + return new HorizontallyConcatNode( + new PlanNodeId(String.format("%s-%s", getPlanNodeId(), subNodeId)), + children.subList(startIndex, endIndex)); } @Override
