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

add/.etc

This commit is contained in:
Zoltan Haindrich 2024-07-30 10:16:03 +00:00
parent ed9ef1f635
commit 4157a8f105
2 changed files with 39 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
extensions-core/multi-stage-query/src/test/quidem/org.apache.druid.msq.exec.MSQQuidemTest/msq1.iq
View File

@ -94,7 +94,7 @@ order by 1;
"finalize" : true, "finalize" : true,
"maxParseExceptions" : 0, "maxParseExceptions" : 0,
"plannerStrategy" : "DECOUPLED", "plannerStrategy" : "DECOUPLED",
"sqlQueryId" : "959637f0-a795-41f2-9cf0-f12e29361401", "sqlQueryId" : "1e9ae92b-02e5-4506-be2e-8d89ce1dc77d",
"sqlStringifyArrays" : false "sqlStringifyArrays" : false
} }
} }
@ -127,8 +127,8 @@ order by 1;
"partitionCount" : 1, "partitionCount" : 1,
"shuffle" : "globalSort", "shuffle" : "globalSort",
"output" : "localStorage", "output" : "localStorage",
"startTime" : "2024-07-25T03:33:28.256Z", "startTime" : "2024-07-26T04:26:29.003Z",
"duration" : 754, "duration" : 724,
"sort" : true "sort" : true
}, { }, {
"stageNumber" : 1, "stageNumber" : 1,
@ -200,7 +200,7 @@ order by 1;
"finalize" : true, "finalize" : true,
"maxParseExceptions" : 0, "maxParseExceptions" : 0,
"plannerStrategy" : "DECOUPLED", "plannerStrategy" : "DECOUPLED",
"sqlQueryId" : "959637f0-a795-41f2-9cf0-f12e29361401", "sqlQueryId" : "1e9ae92b-02e5-4506-be2e-8d89ce1dc77d",
"sqlStringifyArrays" : false "sqlStringifyArrays" : false
} }
} }
@ -221,12 +221,11 @@ order by 1;
"workerCount" : 1, "workerCount" : 1,
"partitionCount" : 1, "partitionCount" : 1,
"output" : "localStorage", "output" : "localStorage",
"startTime" : "2024-07-25T03:33:29.010Z", "startTime" : "2024-07-26T04:26:29.727Z",
"duration" : 2 "duration" : 2
} ] } ]
!msqPlan !msqPlan
# 227 # 227
LogicalSort(sort0=[$0], dir0=[ASC]) LogicalSort(sort0=[$0], dir0=[ASC])
LogicalAggregate(group=[{0}], cnt=[COUNT($1)], aall=[COUNT()]) LogicalAggregate(group=[{0}], cnt=[COUNT($1)], aall=[COUNT()])
LogicalProject(cityName=[$2], $f1=[CASE(>($17, 0), $1, null:VARCHAR)]) LogicalProject(cityName=[$2], $f1=[CASE(>($17, 0), $1, null:VARCHAR)])
@ -305,3 +304,5 @@ DruidAggregate(group=[{0}], cnt=[COUNT($1) FILTER $2], aall=[COUNT()], druid=[lo
} }
!nativePlan !nativePlan

32
extensions-core/multi-stage-query/src/test/quidem/org.apache.druid.msq.exec.MSQQuidemTest/msq2.iq Normal file
View File

@ -0,0 +1,32 @@
!set isNative false
!set isMSQ true
!set plannerStrategy DECOUPLED
!if (isMSQ) {
!use druidtest://?componentSupplier=DrillWindowQueryMSQComponentSupplier
!}
!if (isNative) {
!use druidtest://?numMergeBuffers=3
!}
!set outputformat mysql
select 2;
+--------+
| EXPR$0 |
+--------+
| 2 |
+--------+
(1 row)
!ok
!msqPlan
!if (isMSQ) {
!msqPlan
!}
!if (isNative) {
!msqPlan
!}