(iotdb) branch beyyes/joinOperator updated: fix criteria in PushPredicateIntoTableScan

[caogaofei]

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

caogaofei pushed a commit to branch beyyes/joinOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/beyyes/joinOperator by this 
push:
     new da3f41d3b9b fix criteria in PushPredicateIntoTableScan
da3f41d3b9b is described below

commit da3f41d3b9b6d1a995c86d932789d78ae82be744
Author: Beyyes <cgf1...@foxmail.com>
AuthorDate: Wed Sep 11 15:29:59 2024 +0800

    fix criteria in PushPredicateIntoTableScan
---
 .../org/apache/iotdb/db/queryengine/common/header/DatasetHeader.java  | 4 ----
 .../relational/planner/optimizations/PushPredicateIntoTableScan.java  | 2 +-
 2 files changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeader.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeader.java
index 8d8d57c3e5b..8eb177dea8d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeader.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/header/DatasetHeader.java
@@ -148,10 +148,6 @@ public class DatasetHeader {
     return respAliasColumns;
   }
 
-  public List<String> getColumnToTsBlockIndexList() {
-    return this.columnToTsBlockIndexList;
-  }
-
   public Map<String, Integer> getColumnNameIndexMap() {
     if (columnToTsBlockIndexMap == null || columnToTsBlockIndexMap.isEmpty()) {
       return columnToTsBlockIndexMap;
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java
index 271f9e9d584..9e3939e81c3 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java
@@ -674,7 +674,7 @@ public class PushPredicateIntoTableScan implements 
PlanOptimizer {
                 node.isSpillable());
       }
 
-      JoinNode.EquiJoinClause joinCriteria = node.getCriteria().get(0);
+      JoinNode.EquiJoinClause joinCriteria = ((JoinNode) 
output).getCriteria().get(0);
       OrderingScheme leftOrderingScheme =
           new OrderingScheme(
               Collections.singletonList(joinCriteria.getLeft()),