(iotdb) branch ty/InnerTimeJoin updated: add some todo

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch ty/InnerTimeJoin
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/ty/InnerTimeJoin by this push:
     new cf9297bdfe0 add some todo
cf9297bdfe0 is described below

commit cf9297bdfe02da36300a731e667eb3efc2206eec
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Thu Jan 4 17:07:40 2024 +0800

    add some todo
---
 .../iotdb/db/queryengine/plan/planner/distribution/SourceRewriter.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SourceRewriter.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SourceRewriter.java
index e8e3563acc4..460e4938480 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SourceRewriter.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SourceRewriter.java
@@ -805,6 +805,7 @@ public class SourceRewriter extends 
SimplePlanNodeRewriter<DistributionPlanConte
     List<PlanNode> subInnerJoinNode = new 
ArrayList<>(continuousTimeRange.size());
     for (List<TTimePartitionSlot> oneRegion : continuousTimeRange) {
       if (!oneRegion.isEmpty()) {
+        // TODO InnerTimeJoinNode's header
         InnerTimeJoinNode innerTimeJoinNode = (InnerTimeJoinNode) node.clone();
         
innerTimeJoinNode.setPlanNodeId(context.queryContext.getQueryId().genPlanNodeId());