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

Window Drill tests coverage improvement (#16722) 

Window Drill tests coverage improvement
This commit is contained in:
Sree Charan Manamala 2024-07-11 19:11:36 +05:30 committed by GitHub
parent d6c07270a5
commit 760d70312f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sql/src/test/java/org/apache/druid/sql/calcite/DrillWindowQueryTest.java
View File

@ -4236,7 +4236,7 @@ public class DrillWindowQueryTest extends BaseCalciteQueryTest
windowQueryTest();
}
@NotYetSupported(Modes.COLUMN_NOT_FOUND)
@NotYetSupported(Modes.AGGREGATION_NOT_SUPPORT_TYPE)
@DrillTest("frameclause/subQueries/frmInSubQry_25")
@Test
public void test_frameclause_subQueries_frmInSubQry_25()
@ -4244,7 +4244,7 @@ public class DrillWindowQueryTest extends BaseCalciteQueryTest
windowQueryTest();
}
@NotYetSupported(Modes.INCORRECT_SYNTAX)
@NotYetSupported(Modes.VIEWS_NOT_SUPPORTED)
@DrillTest("nestedAggs/nstdWinView01")
@Test
public void test_nestedAggs_nstdWinView01()
@ -5083,7 +5083,6 @@ public class DrillWindowQueryTest extends BaseCalciteQueryTest
windowQueryTest();
}
@NotYetSupported(Modes.COLUMN_NOT_FOUND)
@DrillTest("aggregates/testW_Nulls_5")
@Test
public void test_aggregates_testW_Nulls_5()
@ -5091,7 +5090,6 @@ public class DrillWindowQueryTest extends BaseCalciteQueryTest
windowQueryTest();
}
@NotYetSupported(Modes.COLUMN_NOT_FOUND)
@DrillTest("aggregates/testW_Nulls_6")
@Test
public void test_aggregates_testW_Nulls_6()

3
sql/src/test/java/org/apache/druid/sql/calcite/NotYetSupported.java
View File

@ -80,13 +80,12 @@ public @interface NotYetSupported
NOT_ENOUGH_RULES(DruidException.class, "not enough rules"),
ERROR_HANDLING(AssertionError.class, "targetPersona: is <[A-Z]+> and category: is <[A-Z_]+> and errorCode: is"),
EXPRESSION_NOT_GROUPED(DruidException.class, "Expression '[a-z]+' is not being grouped"),
COLUMN_NOT_FOUND(DruidException.class, "CalciteContextException.*Column.*not found in any table"),
NULLS_FIRST_LAST(DruidException.class, "NULLS (FIRST|LAST)"),
BIGINT_TO_DATE(DruidException.class, "BIGINT to type (DATE|TIME)"),
AGGREGATION_NOT_SUPPORT_TYPE(DruidException.class, "Aggregation \\[(MIN|MAX)\\] does not support type \\[STRING\\]"),
ALLDATA_CSV(DruidException.class, "allData.csv"),
BIGINT_TIME_COMPARE(DruidException.class, "Cannot apply '.' to arguments of type"),
INCORRECT_SYNTAX(DruidException.class, "Incorrect syntax near the keyword"),
VIEWS_NOT_SUPPORTED(DruidException.class, "Incorrect syntax near the keyword 'CREATE'"),
RESULT_MISMATCH(AssertionError.class, "(assertResulEquals|AssertionError: column content mismatch)"),
LONG_CASTING(AssertionError.class, "expected: java.lang.Long"),
UNSUPPORTED_NULL_ORDERING(DruidException.class, "(A|DE)SCENDING ordering with NULLS (LAST|FIRST)"),

2
sql/src/test/resources/drill/window/queries/aggregates/testW_Nulls_5.q
View File

@ -1 +1 @@
SELECT c1, c2, w_avg FROM ( SELECT c1, c2, avg ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC nulls first ) w_AVG FROM "tblWnulls.parquet" ) sub_query WHERE w_avg IS null
SELECT c1, c2, w_avg FROM ( SELECT c1, c2, avg ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC nulls first ) w_avg FROM "tblWnulls.parquet" ) sub_query WHERE w_avg IS null

2
sql/src/test/resources/drill/window/queries/aggregates/testW_Nulls_6.q
View File

@ -1 +1 @@
SELECT c1, c2, w_avg FROM ( SELECT c1, c2, avg ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC nulls first ) w_AVG FROM "tblWnulls.parquet" ) sub_query
SELECT c1, c2, w_avg FROM ( SELECT c1, c2, avg ( c1 ) OVER ( PARTITION BY c2 ORDER BY c1 ASC nulls first ) w_avg FROM "tblWnulls.parquet" ) sub_query

2
sql/src/test/resources/drill/window/queries/frameclause/subQueries/frmInSubQry_25.q
View File

@ -2,7 +2,7 @@ SELECT *
FROM
( SELECT MIN(c5) OVER W as w_min,
MIN(c5) OVER W2 as w2_min,
MIN(C5) OVER W3 as w3_min
MIN(c5) OVER W3 as w3_min
FROM "t_alltype.parquet"
WINDOW W AS ( PARTITION BY c8 ORDER BY c1 RANGE BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING ),
W2 AS ( PARTITION BY c8 ORDER BY c1 ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW ),