Skip to content
Closed
Show file tree
Hide file tree
Changes from 59 commits
Commits
Show all changes
68 commits
Select commit Hold shift + click to select a range
612396c
Initial commit
andylam-db Nov 29, 2023
83e6a51
Add CrossDbmsQueryTestSuite
andylam-db Nov 29, 2023
c691f83
Small changes for niceness
andylam-db Nov 29, 2023
24a02f0
Save point
andylam-db Nov 29, 2023
315847a
Add sqllogictest-select1.sql in postgres-crosstest input file
andylam-db Nov 29, 2023
5e087e1
Add header for class suite
andylam-db Nov 29, 2023
33b52b2
Small changes
andylam-db Nov 29, 2023
81202c4
Trying to get the input files set up..
andylam-db Nov 29, 2023
c9fba5b
Passing test!!
andylam-db Nov 29, 2023
8b5ed22
Ignore all earlier tests first
andylam-db Nov 29, 2023
fea3975
Small comment changes
andylam-db Nov 30, 2023
678a0ef
More comments
andylam-db Nov 30, 2023
309a7e2
Address simple comments
andylam-db Nov 30, 2023
5c52b9c
A little more small changes..
andylam-db Nov 30, 2023
ad867df
More small changes and removal of redundant code
andylam-db Nov 30, 2023
bef8011
Generate golden files for SQLQueryTestSuite
andylam-db Nov 30, 2023
a6e7e2a
Revert "Generate golden files for SQLQueryTestSuite"
andylam-db Nov 30, 2023
1409d63
Ignore "postgres-crosstest" in SQLQueryTestSuite
andylam-db Nov 30, 2023
a552d86
Add comment to clarify why it is ignored
andylam-db Nov 30, 2023
7a9cb80
Fix compilation failures
andylam-db Nov 30, 2023
66f41a5
Regenerate golden files for sqllogictest-select1.sql.out
andylam-db Nov 30, 2023
69614d3
Tiny changes..
andylam-db Nov 30, 2023
2bf43df
Add postgresql back to ignorelist
andylam-db Nov 30, 2023
aba83b8
Add exception handling in CrossDbmsQueryTestSuite
andylam-db Nov 30, 2023
bf4036d
Do refactoring so that we can add an additional input argument for Cr…
andylam-db Dec 1, 2023
08e2cfb
Generate with postgres
andylam-db Dec 1, 2023
2ec381c
Fix compilation error with ThriftServerQueryTestSuite
andylam-db Dec 1, 2023
9c2d283
Generate golden files with SQLQueryTestSuite
andylam-db Dec 1, 2023
ab4ab12
Fixed a bug where tests weren't running against the golden file
andylam-db Dec 4, 2023
0166aed
Use local spark session
andylam-db Dec 4, 2023
2e45a67
Small comment change
andylam-db Dec 4, 2023
496cd82
Merge master
andylam-db Dec 4, 2023
dd4597e
Revert change in ThriftServerQueryTestSuite
andylam-db Dec 4, 2023
cb71979
Remove DialectConverter..
andylam-db Dec 4, 2023
6cd52f1
Don't run the tests if the cross dbms is not specified
andylam-db Dec 5, 2023
7f39707
Remove sqllogictest
andylam-db Dec 18, 2023
615f4d9
Small niceness changes
andylam-db Dec 18, 2023
cf345bd
Do null -> NULL replacement, and put 2 tests in
andylam-db Dec 18, 2023
cdef387
Add docker compose and bash scripts for easy postgres instance
andylam-db Dec 18, 2023
36be209
Trivial changes
andylam-db Dec 18, 2023
d037331
Trivial changes
andylam-db Dec 18, 2023
750a1de
Fix typo
andylam-db Dec 19, 2023
089c292
Add header comments, and make CrossDbmsQuerySuite an abstract class
andylam-db Dec 19, 2023
62d1760
Trivial changes
andylam-db Dec 19, 2023
def270b
Use prepared statements
andylam-db Dec 19, 2023
fdb90a4
Remove sql file changes for now
andylam-db Dec 19, 2023
8c21ceb
Header comment improvements
andylam-db Dec 19, 2023
50c2dfb
Trivial changes
andylam-db Dec 19, 2023
939b8f2
Add custom postgres command
andylam-db Dec 19, 2023
db01061
Modify exists-having to be compatible with psql
andylam-db Dec 19, 2023
d8c7bc9
Merge branch 'master' into crossdbms
andylam-db Dec 19, 2023
7200f7d
Modify query slightly
andylam-db Dec 19, 2023
1d79345
Add readme and add ONLY_IF for most sql files in subquery dir
andylam-db Dec 20, 2023
83cd8d4
Rewrite exists-having
andylam-db Dec 20, 2023
f491d1f
Update comment
andylam-db Dec 20, 2023
cc039ae
Merge master
andylam-db Dec 21, 2023
ce0e106
Ignore subquery-offset.sql
andylam-db Dec 21, 2023
1d7c620
Create new file PostgreSQLQueryTestSuite.scala and fix indent
andylam-db Dec 22, 2023
0e542cf
Move from postgres-results -> crossdbms-results
andylam-db Jan 2, 2024
5d4c577
Fix silly paste
andylam-db Jan 3, 2024
68ea6f2
Fix unintended removal of results file
andylam-db Jan 3, 2024
1e1a283
In middle of refactoring..
andylam-db Jan 3, 2024
5756c8e
Major refactoring in progress..
andylam-db Jan 3, 2024
81a61f7
Passing tests
andylam-db Jan 3, 2024
cf7b044
Add documnetation and delete previous files
andylam-db Jan 3, 2024
a32a693
Move functions from PostgreSQLQueryTestSuite -> CrossDbmsQueryTestSuite
andylam-db Jan 3, 2024
e08f7a4
Merge master..
andylam-db Jan 3, 2024
18f821f
Merge branch 'master' into crossdbms
andylam-db Jan 4, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
@@ -1,50 +1,41 @@
-- Automatically generated by SQLQueryTestSuite
-- Automatically generated by PostgreSQLQueryTestSuite with postgres
-- !query
CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(200, "emp 2", date "2003-01-01", 200.00D, 10),
(300, "emp 3", date "2002-01-01", 300.00D, 20),
(400, "emp 4", date "2005-01-01", 400.00D, 30),
(500, "emp 5", date "2001-01-01", 400.00D, NULL),
(600, "emp 6 - no dept", date "2001-01-01", 400.00D, 100),
(700, "emp 7", date "2010-01-01", 400.00D, 100),
(800, "emp 8", date "2016-01-01", 150.00D, 70)
AS EMP(id, emp_name, hiredate, salary, dept_id)
-- !query schema
struct<>
CREATE TEMPORARY VIEW EMP(id, emp_name, hiredate, salary, dept_id) AS VALUES
(100, 'emp 1', date '2005-01-01', double(100.00), 10),
(100, 'emp 1', date '2005-01-01', double(100.00), 10),
(200, 'emp 2', date '2003-01-01', double(200.00), 10),
(300, 'emp 3', date '2002-01-01', double(300.00), 20),
(400, 'emp 4', date '2005-01-01', double(400.00), 30),
(500, 'emp 5', date '2001-01-01', double(400.00), NULL),
(600, 'emp 6 - no dept', date '2001-01-01', double(400.00), 100),
(700, 'emp 7', date '2010-01-01', double(400.00), 100),
(800, 'emp 8', date '2016-01-01', double(150.00), 70)
-- !query output



-- !query
CREATE TEMPORARY VIEW DEPT AS SELECT * FROM VALUES
(10, "dept 1", "CA"),
(20, "dept 2", "NY"),
(30, "dept 3", "TX"),
(40, "dept 4 - unassigned", "OR"),
(50, "dept 5 - unassigned", "NJ"),
(70, "dept 7", "FL")
AS DEPT(dept_id, dept_name, state)
-- !query schema
struct<>
CREATE TEMPORARY VIEW DEPT(dept_id, dept_name, state) AS VALUES
(10, 'dept 1', 'CA'),
(20, 'dept 2', 'NY'),
(30, 'dept 3', 'TX'),
(40, 'dept 4 - unassigned', 'OR'),
(50, 'dept 5 - unassigned', 'NJ'),
(70, 'dept 7', 'FL')
-- !query output



-- !query
CREATE TEMPORARY VIEW BONUS AS SELECT * FROM VALUES
("emp 1", 10.00D),
("emp 1", 20.00D),
("emp 2", 300.00D),
("emp 2", 100.00D),
("emp 3", 300.00D),
("emp 4", 100.00D),
("emp 5", 1000.00D),
("emp 6 - no dept", 500.00D)
AS BONUS(emp_name, bonus_amt)
-- !query schema
struct<>
CREATE TEMPORARY VIEW BONUS(emp_name, bonus_amt) AS VALUES
('emp 1', double(10.00)),
('emp 1', double(20.00)),
('emp 2', double(300.00)),
('emp 2', double(100.00)),
('emp 3', double(300.00)),
('emp 4', double(100.00)),
('emp 5', double(1000.00)),
('emp 6 - no dept', double(500.00))
-- !query output


Expand All @@ -56,8 +47,6 @@ GROUP BY dept_id
HAVING EXISTS (SELECT 1
FROM bonus
WHERE bonus_amt < min(emp.salary))
-- !query schema
struct<dept_id:int,count(1):bigint>
-- !query output
10 3
100 2
Expand All @@ -77,8 +66,6 @@ WHERE EXISTS (SELECT dept_id,
HAVING EXISTS (SELECT 1
FROM bonus
WHERE bonus_amt < Min(emp.salary)))
-- !query schema
struct<dept_id:int,dept_name:string,state:string>
-- !query output
10 dept 1 CA
20 dept 2 NY
Expand All @@ -100,8 +87,6 @@ WHERE EXISTS (SELECT dept_id,
FROM bonus
WHERE bonus_amt < Min(p.salary)))
GROUP BY gp.dept_id
-- !query schema
struct<dept_id:int,max(salary):double>
-- !query output
10 200.0
100 400.0
Expand All @@ -121,8 +106,6 @@ WHERE EXISTS (SELECT dept_id,
HAVING EXISTS (SELECT 1
FROM bonus
WHERE bonus_amt > Min(emp.salary)))
-- !query schema
struct<dept_id:int,dept_name:string,state:string>
-- !query output
10 dept 1 CA
20 dept 2 NY
Expand All @@ -144,7 +127,5 @@ WHERE EXISTS (SELECT dept_id,
FROM bonus
WHERE ( bonus_amt > min(emp.salary)
AND count(emp.dept_id) > 1 )))
-- !query schema
struct<dept_id:int,dept_name:string,state:string>
-- !query output
10 dept 1 CA
10 changes: 10 additions & 0 deletions sql/core/src/test/resources/sql-tests/inputs/subquery/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@

## Note on PostgreSQLQueryTestSuite

The SQL files in this directory are automatically opted into `PostgreSQLQueryTestSuite`, which
generates golden files with Postgres and runs Spark against these golden files. If you added a new
SQL test file, please generate the golden files with `PostgreSQLQueryTestSuite`. It is likely to
fail because of incompatibility between the SQL dialects of Spark and Postgres. To have queries that
are compatible for both systems, keep your SQL queries simple by using basic types like INTs and
strings only, if possible, and using functions that are present in both Spark and Postgres. Refer
to the header comment for `PostgreSQLQueryTestSuite` for more information.
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
--CONFIG_DIM1 spark.sql.codegen.wholeStage=true
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=CODEGEN_ONLY
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=NO_CODEGEN
--ONLY_IF spark

CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- Tests EXISTS subquery support. Tests basic form
-- of EXISTS subquery (both EXISTS and NOT EXISTS)
--ONLY_IF spark

CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
--ONLY_IF spark
create temporary view t1(c1, c2) as values (0, 1), (1, 2);
create temporary view t2(c1, c2) as values (0, 2), (0, 3);
create temporary view t3(c1, c2) as values (0, 3), (1, 4), (2, 5);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- Tests EXISTS subquery used along with
-- Common Table Expressions(CTE)
--ONLY_IF spark

CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,36 +1,33 @@
-- Tests HAVING clause in subquery.

CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(200, "emp 2", date "2003-01-01", 200.00D, 10),
(300, "emp 3", date "2002-01-01", 300.00D, 20),
(400, "emp 4", date "2005-01-01", 400.00D, 30),
(500, "emp 5", date "2001-01-01", 400.00D, NULL),
(600, "emp 6 - no dept", date "2001-01-01", 400.00D, 100),
(700, "emp 7", date "2010-01-01", 400.00D, 100),
(800, "emp 8", date "2016-01-01", 150.00D, 70)
AS EMP(id, emp_name, hiredate, salary, dept_id);
CREATE TEMPORARY VIEW EMP(id, emp_name, hiredate, salary, dept_id) AS VALUES
(100, 'emp 1', date '2005-01-01', double(100.00), 10),
(100, 'emp 1', date '2005-01-01', double(100.00), 10),
(200, 'emp 2', date '2003-01-01', double(200.00), 10),
(300, 'emp 3', date '2002-01-01', double(300.00), 20),
(400, 'emp 4', date '2005-01-01', double(400.00), 30),
(500, 'emp 5', date '2001-01-01', double(400.00), NULL),
(600, 'emp 6 - no dept', date '2001-01-01', double(400.00), 100),
(700, 'emp 7', date '2010-01-01', double(400.00), 100),
(800, 'emp 8', date '2016-01-01', double(150.00), 70);

CREATE TEMPORARY VIEW DEPT AS SELECT * FROM VALUES
(10, "dept 1", "CA"),
(20, "dept 2", "NY"),
(30, "dept 3", "TX"),
(40, "dept 4 - unassigned", "OR"),
(50, "dept 5 - unassigned", "NJ"),
(70, "dept 7", "FL")
AS DEPT(dept_id, dept_name, state);
CREATE TEMPORARY VIEW DEPT(dept_id, dept_name, state) AS VALUES
(10, 'dept 1', 'CA'),
(20, 'dept 2', 'NY'),
(30, 'dept 3', 'TX'),
(40, 'dept 4 - unassigned', 'OR'),
(50, 'dept 5 - unassigned', 'NJ'),
(70, 'dept 7', 'FL');

CREATE TEMPORARY VIEW BONUS AS SELECT * FROM VALUES
("emp 1", 10.00D),
("emp 1", 20.00D),
("emp 2", 300.00D),
("emp 2", 100.00D),
("emp 3", 300.00D),
("emp 4", 100.00D),
("emp 5", 1000.00D),
("emp 6 - no dept", 500.00D)
AS BONUS(emp_name, bonus_amt);
CREATE TEMPORARY VIEW BONUS(emp_name, bonus_amt) AS VALUES
('emp 1', double(10.00)),
('emp 1', double(20.00)),
('emp 2', double(300.00)),
('emp 2', double(100.00)),
('emp 3', double(300.00)),
('emp 4', double(100.00)),
('emp 5', double(1000.00)),
('emp 6 - no dept', double(500.00));

-- simple having in subquery.
-- TC.01.01
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
-- 3. Join type: inner / left outer / right outer / full outer / left semi / left anti
-- 4. AND or OR for the join condition

--ONLY_IF spark
CREATE TEMP VIEW x(x1, x2) AS VALUES
(2, 1),
(1, 1),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
--CONFIG_DIM2 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=CODEGEN_ONLY
--CONFIG_DIM2 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=NO_CODEGEN

--ONLY_IF spark
CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=CODEGEN_ONLY
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=NO_CODEGEN

--ONLY_IF spark
CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- Tests EXISTS subquery support where the subquery is used outside the WHERE clause.

--ONLY_IF spark

CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
-- Tests EXISTS subquery support. Tests EXISTS
-- subquery within a AND or OR expression.

--ONLY_IF spark
CREATE TEMPORARY VIEW EMP AS SELECT * FROM VALUES
(100, "emp 1", date "2005-01-01", 100.00D, 10),
(100, "emp 1", date "2005-01-01", 100.00D, 10),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
--ONLY_IF spark

create temporary view tab_a as select * from values (1, 1) as tab_a(a1, b1);
create temporary view tab_b as select * from values (1, 1) as tab_b(a2, b2);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
--ONLY_IF spark
create temporary view t1(c1, c2) as values (0, 1), (1, 2);
create temporary view t2(c1, c2) as values (0, 2), (0, 3);
create temporary view t3(c1, c2) as values (0, 3), (1, 4), (2, 5);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=CODEGEN_ONLY
--CONFIG_DIM1 spark.sql.codegen.wholeStage=false,spark.sql.codegen.factoryMode=NO_CODEGEN

--ONLY_IF spark
create temporary view t1 as select * from values
("t1a", 6S, 8, 10L, float(15.0), 20D, 20E2BD, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
("t1b", 8S, 16, 19L, float(17.0), 25D, 26E2BD, timestamp '2014-05-04 01:01:00.000', date '2014-05-04'),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false

--ONLY_IF spark
create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
("val1b", 8S, 16, 19L, float(17.0), 25D, 26E2, timestamp '2014-05-04 01:01:00.000', date '2014-05-04'),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@
--CONFIG_DIM3 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM3 spark.sql.optimizeNullAwareAntiJoin=false

--ONLY_IF spark
create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
("val1b", 8S, 16, 19L, float(17.0), 25D, 26E2, timestamp '2014-05-04 01:01:00.000', date '2014-05-04'),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false

--ONLY_IF spark
create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2BD, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
("val1b", 8S, 16, 19L, float(17.0), 25D, 26E2BD, timestamp '2014-05-04 01:01:00.000', date '2014-05-04'),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false

--ONLY_IF spark
create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
("val1b", 8S, 16, 19L, float(17.0), 25D, 26E2, timestamp '2014-05-04 01:01:00.000', date '2014-05-04'),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
--ONLY_IF spark
create temp view v (c) as values (1), (null);
create temp view v_empty (e) as select 1 where false;

Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
-- SPARK-43413: Tests for IN subquery nullability
--ONLY_IF spark

create temp view t0 as select 1 as a_nonnullable;
create temp view t1 as select cast(null as int) as b_nullable;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@

--CONFIG_DIM2 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM2 spark.sql.optimizeNullAwareAntiJoin=false
--ONLY_IF spark

create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2BD, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- A test suite for set-operations in parent side, subquery, and both predicate subquery
-- It includes correlated cases.
--ONLY_IF spark

create temporary view t1 as select * from values
("val1a", 6S, 8, 10L, float(15.0), 20D, 20E2BD, timestamp '2014-04-04 01:00:00.000', date '2014-04-04'),
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
-- Test that correlated EXISTS subqueries in join conditions are supported.
--ONLY_IF spark

-- Permutations of the test:
-- 1. In / Not In
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- A test suite for in with cte in parent side, subquery, and both predicate subquery
-- It includes correlated cases.
--ONLY_IF spark

--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
-- Tests NOT-IN subqueries nested inside OR expression(s).
--ONLY_IF spark

--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- A test suite for NOT IN GROUP BY in parent side, subquery, and both predicate subquery
-- It includes correlated cases.
--ONLY_IF spark

-- Test aggregate operator with codegen on and off.
--CONFIG_DIM1 spark.sql.codegen.wholeStage=true
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
-- A test suite for not-in-joins in parent side, subquery, and both predicate subquery
-- It includes correlated cases.
--ONLY_IF spark

--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
--ONLY_IF spark

CREATE TEMPORARY VIEW m AS SELECT * FROM VALUES
(null, null),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
-- This can be generalized to include more tests for more columns, but it covers the main cases
-- when there is more than one column.

--ONLY_IF spark
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=true
--CONFIG_DIM1 spark.sql.optimizeNullAwareAntiJoin=false
--ONLY_IF spark

CREATE TEMPORARY VIEW m AS SELECT * FROM VALUES
(null, 1.0),
Expand Down
Loading