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 2023/02/11 12:00:53 UTC
[iotdb] 03/13: implement createSubNode in HorizontallyConcatNode
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 <wx...@gmail.com>
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