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

xuzifu666 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/calcite.git

The following commit(s) were added to refs/heads/main by this push:
     new 4e959ef261 Included the `some` iq files in CoreQuidemTest2
4e959ef261 is described below

commit 4e959ef261353fcc40cb02191b0018e59c976ed2
Author: Zhen Chen <[email protected]>
AuthorDate: Fri Jan 30 06:48:32 2026 +0800

    Included the `some` iq files in CoreQuidemTest2
---
 .../test/java/org/apache/calcite/test/CoreQuidemTest2.java   |  3 +--
 core/src/test/resources/sql/some.iq                          | 12 ++++++++++++
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/core/src/test/java/org/apache/calcite/test/CoreQuidemTest2.java 
b/core/src/test/java/org/apache/calcite/test/CoreQuidemTest2.java
index 865aec400a..0164eeea6e 100644
--- a/core/src/test/java/org/apache/calcite/test/CoreQuidemTest2.java
+++ b/core/src/test/java/org/apache/calcite/test/CoreQuidemTest2.java
@@ -44,9 +44,8 @@ public static void main(String[] args) throws Exception {
     // These remove operations are temporary and will be deleted
     // once the new decorrelator can adapt to all scenarios.
 
-    // TODO: The following files involves UNNEST and LEFT_MARK JOIN
+    // TODO: Support measure
     paths.remove("sql/measure.iq");
-    paths.remove("sql/some.iq");
     paths.remove("sql/sub-query.iq");
     paths.remove("sql/measure-paper.iq");
     return paths;
diff --git a/core/src/test/resources/sql/some.iq 
b/core/src/test/resources/sql/some.iq
index 02e771241f..97414f8450 100644
--- a/core/src/test/resources/sql/some.iq
+++ b/core/src/test/resources/sql/some.iq
@@ -128,12 +128,24 @@ from "scott".emp;
 (14 rows)
 
 !ok
+
+!if (use_old_decorr) {
 EnumerableCalc(expr#0..10=[{inputs}], expr#11=[0], expr#12=[=($t9, $t11)], 
expr#13=[>($t9, $t10)], expr#14=[null:BOOLEAN], expr#15=[<=($t5, $t8)], 
expr#16=[IS NOT TRUE($t15)], expr#17=[AND($t13, $t14, $t16)], expr#18=[>($t5, 
$t8)], expr#19=[<=($t9, $t10)], expr#20=[AND($t18, $t16, $t19)], 
expr#21=[OR($t12, $t17, $t20)], proj#0..7=[{exprs}], X=[$t21])
   EnumerableNestedLoopJoin(condition=[true], joinType=[inner])
     EnumerableTableScan(table=[[scott, EMP]])
     EnumerableAggregate(group=[{}], m=[MAX($6)], c=[COUNT()], d=[COUNT($6)])
       EnumerableTableScan(table=[[scott, EMP]])
 !plan
+!}
+
+!if (use_new_decorr) {
+EnumerableCalc(expr#0..8=[{inputs}], expr#9=[NOT($t8)], proj#0..7=[{exprs}], 
X=[$t9])
+  EnumerableNestedLoopJoin(condition=[<=($5, $8)], joinType=[left_mark])
+    EnumerableTableScan(table=[[scott, EMP]])
+    EnumerableCalc(expr#0..7=[{inputs}], COMM=[$t6])
+      EnumerableTableScan(table=[[scott, EMP]])
+!plan
+!}
 
 # NOT SOME; left side NOT NULL, right side nullable; converse of previous 
query.
 select * from "scott".emp

Reply via email to