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