Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 15:35:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Enable WINDOW_LEAF_OPERATOR for native engine to support queries without group by (#16753)

Browse Source
This commit is contained in:
Sree Charan Manamala 2024-07-22 16:01:55 +05:30 committed by GitHub
parent 7f7e6ca1e5
commit c9aae9d8e6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sql/src/main/java/org/apache/druid/sql/calcite/run/NativeSqlEngine.java
View File

@ -109,6 +109,7 @@ public class NativeSqlEngine implements SqlEngine
case ALLOW_TOP_LEVEL_UNION_ALL: case ALLOW_TOP_LEVEL_UNION_ALL:
case TIME_BOUNDARY_QUERY: case TIME_BOUNDARY_QUERY:
case GROUPBY_IMPLICITLY_SORTS: case GROUPBY_IMPLICITLY_SORTS:
case WINDOW_LEAF_OPERATOR:
return true; return true;
case CAN_INSERT: case CAN_INSERT:
case CAN_REPLACE: case CAN_REPLACE:
@ -116,7 +117,6 @@ public class NativeSqlEngine implements SqlEngine
case WRITE_EXTERNAL_DATA: case WRITE_EXTERNAL_DATA:
case SCAN_ORDER_BY_NON_TIME: case SCAN_ORDER_BY_NON_TIME:
case SCAN_NEEDS_SIGNATURE: case SCAN_NEEDS_SIGNATURE:
case WINDOW_LEAF_OPERATOR:
return false; return false;
default: default:
throw SqlEngines.generateUnrecognizedFeatureException(NativeSqlEngine.class.getSimpleName(), feature); throw SqlEngines.generateUnrecognizedFeatureException(NativeSqlEngine.class.getSimpleName(), feature);

2
sql/src/test/java/org/apache/druid/sql/calcite/CalciteQueryTest.java
View File

@ -15922,7 +15922,7 @@ public class CalciteQueryTest extends BaseCalciteQueryTest
.run(); .run();
} }
@NotYetSupported(Modes.WINDOW_OPERATOR_QUERY_ON_UNSUPPORTED_DATASOURCE) @NotYetSupported(Modes.CANNOT_RETRIEVE_ROWS)
@Test @Test
public void testWindowingOverJoin() public void testWindowingOverJoin()
{ {

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

@ -89,7 +89,7 @@ public @interface NotYetSupported
RESULT_MISMATCH(AssertionError.class, "(assertResulEquals|AssertionError: column content mismatch)"), RESULT_MISMATCH(AssertionError.class, "(assertResulEquals|AssertionError: column content mismatch)"),
LONG_CASTING(AssertionError.class, "expected: java.lang.Long"), LONG_CASTING(AssertionError.class, "expected: java.lang.Long"),
UNSUPPORTED_NULL_ORDERING(DruidException.class, "(A|DE)SCENDING ordering with NULLS (LAST|FIRST)"), UNSUPPORTED_NULL_ORDERING(DruidException.class, "(A|DE)SCENDING ordering with NULLS (LAST|FIRST)"),
WINDOW_OPERATOR_QUERY_ON_UNSUPPORTED_DATASOURCE(DruidException.class, "WindowOperatorQuery must run on top of a query or inline data source"), CANNOT_RETRIEVE_ROWS(UnsupportedOperationException.class, "Cannot retrieve number of rows from join segment"),
UNION_WITH_COMPLEX_OPERAND(DruidException.class, "Only Table and Values are supported as inputs for Union"), UNION_WITH_COMPLEX_OPERAND(DruidException.class, "Only Table and Values are supported as inputs for Union"),
UNION_MORE_STRICT_ROWTYPE_CHECK(DruidException.class, "Row signature mismatch in Union inputs"), UNION_MORE_STRICT_ROWTYPE_CHECK(DruidException.class, "Row signature mismatch in Union inputs"),
JOIN_CONDITION_NOT_PUSHED_CONDITION(DruidException.class, "SQL requires a join with '.*' condition"), JOIN_CONDITION_NOT_PUSHED_CONDITION(DruidException.class, "SQL requires a join with '.*' condition"),