Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add window query test files from Drill (#14561)

This commit is contained in:
imply-cheddar 2023-07-13 12:14:39 +09:00 committed by GitHub
parent 0dcb19f7e3
commit 7650a71d37
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2605 changed files with 1362642 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_10.e Normal file
View File

@ -0,0 +1 @@
19

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_10.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(firstVal_c1) FROM (SELECT FIRST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) firstVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_11.e Normal file
View File

@ -0,0 +1 @@
-1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_11.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(firstVal_c1) FROM (SELECT FIRST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) firstVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_12.e Normal file
View File

@ -0,0 +1 @@
6

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_12.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct firstVal_c1) FROM (SELECT FIRST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) firstVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_13.e Normal file
View File

@ -0,0 +1 @@
2147483647

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_13.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lastVal_c1) FROM (SELECT LAST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) lastVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_14.e Normal file
View File

@ -0,0 +1 @@
-1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_14.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(lastVal_c1) FROM (SELECT LAST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) lastVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_15.e Normal file
View File

@ -0,0 +1 @@
21

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_15.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct lastVal_c1) FROM (SELECT LAST_VALUE(c1) OVER(PARTITION BY c2 ORDER BY c1) lastVal_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_16.e Normal file
View File

@ -0,0 +1 @@
2147483647

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_16.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(LEAD_c1) FROM (SELECT LEAD(c1) OVER(PARTITION BY c2 ORDER BY c1) LEAD_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_17.e Normal file
View File

@ -0,0 +1 @@
1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_17.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(LEAD_c1) FROM (SELECT LEAD(c1) OVER(PARTITION BY c2 ORDER BY c1) LEAD_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_18.e Normal file
View File

@ -0,0 +1 @@
214802204.95000000

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_18.q Normal file
View File

@ -0,0 +1 @@
SELECT AVG(LEAD_c1) FROM (SELECT LEAD(c1) OVER(PARTITION BY c2 ORDER BY c1) LEAD_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_19.e Normal file
View File

@ -0,0 +1 @@
20

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_19.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(LEAD_c1) FROM (SELECT LEAD(c1) OVER(PARTITION BY c2 ORDER BY c1) LEAD_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_20.e Normal file
View File

@ -0,0 +1 @@
2147483647

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_20.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lag_c1) FROM (SELECT LAG(c1) OVER(PARTITION BY c2 ORDER BY c1) lag_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_21.e Normal file
View File

@ -0,0 +1 @@
-1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_21.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(lag_c1) FROM (SELECT LAG(c1) OVER(PARTITION BY c2 ORDER BY c1) lag_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_22.e Normal file
View File

@ -0,0 +1 @@
186784043.04347826

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_22.q Normal file
View File

@ -0,0 +1 @@
SELECT AVG(lag_c1) FROM (SELECT LAG(c1) OVER(PARTITION BY c2 ORDER BY c1) lag_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_23.e Normal file
View File

@ -0,0 +1 @@
23

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_23.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(lag_c1) FROM (SELECT LAG(c1) OVER(PARTITION BY c2 ORDER BY c1) lag_c1 , c2 FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_3.e Normal file
View File

@ -0,0 +1 @@
-1 e e 1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_3.q Normal file
View File

@ -0,0 +1 @@
SELECT * FROM (SELECT c1, c2, LEAD(c2) OVER ( PARTITION BY c2 ORDER BY c1) LEAD_c2, NTILE(3) OVER ( PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query WHERE LEAD_c2 ="e" ORDER BY tile, c1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_30.e Normal file
View File

@ -0,0 +1 @@
22

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_30.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY col7 ORDER BY col1) tile FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_31.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_31.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY col7 ORDER BY col1) tile FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_32.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_32.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct tile) FROM (SELECT NTILE(3) OVER(PARTITION BY col7 ORDER BY col1) tile FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_33.e Normal file
View File

@ -0,0 +1 @@
1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_33.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY col7 ORDER BY col1) tile FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_34.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_34.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY col7 ORDER BY col1) tile FROM "allTypsUniq.parquet") sub_query HAVING MAX(tile) > 2

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_35.e Normal file
View File

@ -0,0 +1 @@
-1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_35.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(firstVal_col1) FROM (SELECT FIRST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) firstVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_36.e Normal file
View File

@ -0,0 +1 @@
-65535

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_36.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(firstVal_col1) FROM (SELECT FIRST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) firstVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_37.e Normal file
View File

@ -0,0 +1 @@
2

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_37.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct firstVal_col1) FROM (SELECT FIRST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) firstVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_38.e Normal file
View File

@ -0,0 +1 @@
9223372036854775807

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_38.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lastVal_col1) FROM (SELECT LAST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) lastVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_39.e Normal file
View File

@ -0,0 +1 @@
-65535

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_39.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(lastVal_col1) FROM (SELECT LAST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) lastVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_4.e Normal file
View File

@ -0,0 +1 @@
15 e e 2

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_4.q Normal file
View File

@ -0,0 +1 @@
SELECT * FROM (SELECT c1, c2, lag(c2) OVER ( PARTITION BY c2 ORDER BY c1) lag_c2, NTILE(3) OVER ( PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query WHERE lag_c2 = "e" ORDER BY tile, c1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_40.e Normal file
View File

@ -0,0 +1 @@
22

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_40.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct lastVal_col1) FROM (SELECT LAST_VALUE(col1) OVER(PARTITION BY col7 ORDER BY col1) lastVal_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_41.e Normal file
View File

@ -0,0 +1 @@
9223372036854775807

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_41.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lead_col1) FROM (SELECT LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_42.e Normal file
View File

@ -0,0 +1 @@
9223372036854775806

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_42.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lead_col1) FROM (SELECT col1, LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query WHERE col1 NOT IN (-1,0,1,-65535,10000000) AND col7 NOT IN (false)

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_43.e Normal file
View File

@ -0,0 +1 @@
9223372036854775806

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_43.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lead_col1) FROM (SELECT col1, LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query WHERE col7 NOT IN (false)

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_44.e Normal file
View File

@ -0,0 +1 @@
9223372036854775807

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_44.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lead_col1) FROM (SELECT col1, LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query WHERE col7 NOT IN (true)

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_45.e Normal file
View File

@ -0,0 +1 @@
0

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_45.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(lead_col1) FROM (SELECT LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_46.e Normal file
View File

@ -0,0 +1 @@
161564562.65000000

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_46.q Normal file
View File

@ -0,0 +1 @@
SELECT AVG(lead_col0) FROM (SELECT LEAD(col0) OVER(PARTITION BY col7 ORDER BY col0) lead_col0 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_47.e Normal file
View File

@ -0,0 +1 @@
20

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_47.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(lead_col1) FROM (SELECT LEAD(col1) OVER(PARTITION BY col7 ORDER BY col1) lead_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_48.e Normal file
View File

@ -0,0 +1 @@
4611686018427387903

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_48.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(lag_col1) FROM (SELECT LAG(col1) OVER(PARTITION BY col7 ORDER BY col1) lag_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_49.e Normal file
View File

@ -0,0 +1 @@
-65535

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_49.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(lag_col1) FROM (SELECT LAG(col1) OVER(PARTITION BY col7 ORDER BY col1) lag_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_5.e Normal file
View File

@ -0,0 +1 @@
30

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_5.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_50.e Normal file
View File

@ -0,0 +1 @@
235195986941643711

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_50.q Normal file
View File

@ -0,0 +1 @@
SELECT AVG(lag_col1) FROM (SELECT LAG(col1) OVER(PARTITION BY col7 ORDER BY col1) lag_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_51.e Normal file
View File

@ -0,0 +1 @@
20

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_51.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(lag_col1) FROM (SELECT LAG(col1) OVER(PARTITION BY col7 ORDER BY col1) lag_col1 , col7 FROM "allTypsUniq.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_6.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_6.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_7.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_7.q Normal file
View File

@ -0,0 +1 @@
SELECT COUNT(distinct tile) FROM (SELECT NTILE(3) OVER(PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_8.e Normal file
View File

@ -0,0 +1 @@
1

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_8.q Normal file
View File

@ -0,0 +1 @@
SELECT MIN(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_9.e Normal file
View File

@ -0,0 +1 @@
3

1
sql/src/test/resources/drill/window/queries/aggregates/aggOWnFn_9.q Normal file
View File

@ -0,0 +1 @@
SELECT MAX(tile) FROM (SELECT NTILE(3) OVER(PARTITION BY c2 ORDER BY c1) tile FROM "tblWnulls.parquet") sub_query HAVING MAX(tile) > 2

56
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_01.e Normal file
View File

@ -0,0 +1,56 @@
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024
407024

1
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_01.q Normal file
View File

@ -0,0 +1 @@
select MAX(col_int) OVER() FROM "smlTbl.parquet"

56
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_02.e Normal file
View File

@ -0,0 +1,56 @@
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048
-199048

1
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_02.q Normal file
View File

@ -0,0 +1 @@
select MIN(col_int) OVER() FROM "smlTbl.parquet"

56
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_03.e Normal file
View File

@ -0,0 +1,56 @@
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349
427349

1
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_03.q Normal file
View File

@ -0,0 +1 @@
select SUM(col_int) OVER() FROM "smlTbl.parquet"

56
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_04.e Normal file
View File

@ -0,0 +1,56 @@
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571
7631.2321428571428571

1
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_04.q Normal file
View File

@ -0,0 +1 @@
select AVG(col_int) OVER() FROM "smlTbl.parquet"

56
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_05.e Normal file
View File

@ -0,0 +1,56 @@
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56
56

1
sql/src/test/resources/drill/window/queries/aggregates/mtyOvrCluse_05.q Normal file
View File

@ -0,0 +1 @@
select COUNT(col_int) OVER() FROM "smlTbl.parquet"

1
sql/src/test/resources/drill/window/queries/aggregates/nulls_first_4802.q.fail Normal file
View File

@ -0,0 +1 @@
select col_int, count(*) OVER (PARTITION BY col_bln ORDER BY col_int,col_bln NULLS first) FROM (select * from `typeall_l` ORDER BY col_int LIMIT 64 OFFSET 64) subqry;

28
sql/src/test/resources/drill/window/queries/aggregates/queries.json Normal file
View File

@ -0,0 +1,28 @@
{
"testId": "wind_fn_aggregates",
"type": "group",
"description": "Functional tests to verify Window Functions",
"submit-type": "jdbc",
"categories": [
"functional"
],
"matrices": [
{
"query-file": ".*.q",
"schema": "dfs.window_functions",
"output-format": "tsv",
"expected-file": ".*.e",
"verification-type": [
"in-memory"
]
}
],
"datasources": [
{
"mode": "cp",
"src": "Datasources/window_functions",
"dest": "window_functions"
}
]
}

4
sql/src/test/resources/drill/window/queries/aggregates/testW_Nulls_1.e Normal file
View File

@ -0,0 +1,4 @@
null c null
null d null
null d null
null null null

3
sql/src/test/resources/drill/window/queries/aggregates/testW_Nulls_1.q Normal file
View File

@ -0,0 +1,3 @@
-- SELECT c1, c2, w_MAX FROM ( SELECT c1, c2, MAX ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC) w_MAX FROM "tblWnulls.parquet" ) sub_query WHERE w_MAX IS null
SELECT c1, c2, MAX ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC) w_MAX FROM "tblWnulls.parquet"

Some files were not shown because too many files have changed in this diff Show More