digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 0 ms";
2 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
}
3 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1<br>local merged chunks fetched: 0<br>shuffle write time: 0 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 1<br>local bytes read: 59.0 B<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 16.0 B<br>local merged bytes read: 0.0 B<br>number of partitions: 1<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 59.0 B"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 6 ms";
5 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 6 ms<br>peak memory: 0.0 B<br>number of output rows: 1<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0"];
6 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 3 ms<br>peak memory: 64.2 MiB<br>number of output rows: 255<br>number of sort fallback tasks: 0<br>avg hash probes per key: 1"];
}
7 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 14.5 KiB<br>number of coalesced partitions: 1"];
8 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 510<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>3 ms (1 ms, 2 ms, 2 ms (stage 1930.0: task 1683))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 510<br>local bytes read: 14.3 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 2<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>46.2 KiB (23.1 KiB, 23.1 KiB, 23.1 KiB (stage 1930.0: task 1682))<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>14.3 KiB (7.1 KiB, 7.1 KiB, 7.1 KiB (stage 1930.0: task 1682))"];
subgraph cluster9 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: total (min, med, max (stageId: taskId))\n477 ms (230 ms, 247 ms, 247 ms (stage 1930.0: task 1682))";
10 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build total (min, med, max (stageId: taskId))<br>454 ms (224 ms, 230 ms, 230 ms (stage 1930.0: task 1682))<br>peak memory total (min, med, max (stageId: taskId))<br>128.5 MiB (64.2 MiB, 64.2 MiB, 64.2 MiB (stage 1930.0: task 1682))<br>number of output rows: 510<br>number of sort fallback tasks: 0<br>avg hash probes per key (min, med, max (stageId: taskId)):<br>(1, 1, 1 (stage 1930.0: task 1682))"];
}
11 [labelType="html" label="<br><b>Union</b><br><br>"];
subgraph cluster12 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 244 ms";
13 [labelType="html" label="<br><b>Project</b><br><br>"];
14 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 255"];
15 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"cp_codpos\", \"cp_burdis\", \"cp_codpays\", \"cp_coduti\", \"cp_datmaj\", \"cp_codinsee\" FROM \"xplore\".\"h_codpos\") as x) [numPartitions=1] </b><br><br>number of output rows: 39,005"];
}
subgraph cluster16 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 228 ms";
17 [labelType="html" label="<br><b>Project</b><br><br>"];
18 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 255"];
19 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"cp_codpos\", \"cp_burdis\", \"cp_codpays\", \"cp_coduti\", \"cp_datmaj\", \"cp_codinsee\" FROM \"xplore2\".\"h_codpos\") as x) [numPartitions=1] </b><br><br>number of output rows: 39,005"];
}
2->0;
3->2;
5->3;
6->5;
7->6;
8->7;
10->8;
11->10;
13->11;
14->13;
15->14;
17->11;
18->17;
19->18;
}
20
AdaptiveSparkPlan isFinalPlan=true
HashAggregate(keys=[], functions=[count(1)])
WholeStageCodegen (5)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=36088]
HashAggregate(keys=[], functions=[partial_count(1)])
HashAggregate(keys=[CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362], functions=[])
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362, 10), ENSURE_REQUIREMENTS, [plan_id=35849]
HashAggregate(keys=[CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362], functions=[])
WholeStageCodegen (3)
Union
Project [cp_burdis#665315 AS CP_BURDIS_437228#665356, cp_codinsee#665319 AS CP_CODINSEE_437232#665357, cp_codpays#665316 AS CP_CODPAYS_437229#665358, cp_codpos#665314 AS CP_CODPOS_437227#665359, cp_coduti#665317 AS CP_CODUTI_437230#665360, cp_datmaj#665318 AS CP_DATMAJ_437231#665361, null AS ORIGINE_440138#665362]
Filter ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpos#665314)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpos#665314)), MAIN) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_burdis#665315)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_burdis#665315)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpays#665316)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpays#665316)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_coduti#665317)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_coduti#665317)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_datmaj#665318)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_datmaj#665318)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codinsee#665319)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codinsee#665319)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), MAIN)) THEN false ELSE Contains(str_remove_accent(null), MAIN) END)
Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore"."h_codpos") as x) [numPartitions=1] [cp_burdis#665315,cp_codinsee#665319,cp_codpays#665316,cp_codpos#665314,cp_coduti#665317,cp_datmaj#665318] PushedFilters: [], ReadSchema: struct<cp_burdis:string,cp_codinsee:string,cp_codpays:string,cp_codpos:string,cp_coduti:string,cp...
WholeStageCodegen (1)
Project [cp_burdis#665371 AS CP_BURDIS_437228#665412, cp_codinsee#665375 AS CP_CODINSEE_437232#665413, cp_codpays#665372 AS CP_CODPAYS_437229#665414, cp_codpos#665370 AS CP_CODPOS_437227#665415, cp_coduti#665373 AS CP_CODUTI_437230#665416, cp_datmaj#665374 AS CP_DATMAJ_437231#665417, null AS ORIGINE_440138#665418]
Filter ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpos#665370)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpos#665370)), MAIN) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_burdis#665371)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_burdis#665371)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpays#665372)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpays#665372)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_coduti#665373)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_coduti#665373)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_datmaj#665374)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_datmaj#665374)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codinsee#665375)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codinsee#665375)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), MAIN)) THEN false ELSE Contains(str_remove_accent(null), MAIN) END)
Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore2"."h_codpos") as x) [numPartitions=1] [cp_burdis#665371,cp_codinsee#665375,cp_codpays#665372,cp_codpos#665370,cp_coduti#665373,cp_datmaj#665374] PushedFilters: [], ReadSchema: struct<cp_burdis:string,cp_codinsee:string,cp_codpays:string,cp_codpos:string,cp_coduti:string,cp...
WholeStageCodegen (2)
== Physical Plan ==
AdaptiveSparkPlan (24)
+- == Final Plan ==
* HashAggregate (16)
+- ShuffleQueryStage (15), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (14)
+- * HashAggregate (13)
+- * HashAggregate (12)
+- AQEShuffleRead (11)
+- ShuffleQueryStage (10), Statistics(sizeInBytes=46.2 KiB, rowCount=510)
+- Exchange (9)
+- * HashAggregate (8)
+- Union (7)
:- * Project (3)
: +- * Filter (2)
: +- * Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore"."h_codpos") as x) [numPartitions=1] (1)
+- * Project (6)
+- * Filter (5)
+- * Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore2"."h_codpos") as x) [numPartitions=1] (4)
+- == Initial Plan ==
HashAggregate (23)
+- Exchange (22)
+- HashAggregate (21)
+- HashAggregate (20)
+- Exchange (19)
+- HashAggregate (18)
+- Union (17)
:- Project (3)
: +- Filter (2)
: +- Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore"."h_codpos") as x) [numPartitions=1] (1)
+- Project (6)
+- Filter (5)
+- Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore2"."h_codpos") as x) [numPartitions=1] (4)
(1) Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore"."h_codpos") as x) [numPartitions=1] [codegen id : 1]
Output [6]: [cp_burdis#665315, cp_codinsee#665319, cp_codpays#665316, cp_codpos#665314, cp_coduti#665317, cp_datmaj#665318]
ReadSchema: struct<cp_burdis:string,cp_codinsee:string,cp_codpays:string,cp_codpos:string,cp_coduti:string,cp_datmaj:string>
(2) Filter [codegen id : 1]
Input [6]: [cp_burdis#665315, cp_codinsee#665319, cp_codpays#665316, cp_codpos#665314, cp_coduti#665317, cp_datmaj#665318]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpos#665314)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpos#665314)), MAIN) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_burdis#665315)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_burdis#665315)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpays#665316)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpays#665316)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_coduti#665317)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_coduti#665317)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_datmaj#665318)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_datmaj#665318)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codinsee#665319)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codinsee#665319)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), MAIN)) THEN false ELSE Contains(str_remove_accent(null), MAIN) END)
(3) Project [codegen id : 1]
Output [7]: [cp_burdis#665315 AS CP_BURDIS_437228#665356, cp_codinsee#665319 AS CP_CODINSEE_437232#665357, cp_codpays#665316 AS CP_CODPAYS_437229#665358, cp_codpos#665314 AS CP_CODPOS_437227#665359, cp_coduti#665317 AS CP_CODUTI_437230#665360, cp_datmaj#665318 AS CP_DATMAJ_437231#665361, null AS ORIGINE_440138#665362]
Input [6]: [cp_burdis#665315, cp_codinsee#665319, cp_codpays#665316, cp_codpos#665314, cp_coduti#665317, cp_datmaj#665318]
(4) Scan JDBCRelation((SELECT "cp_codpos", "cp_burdis", "cp_codpays", "cp_coduti", "cp_datmaj", "cp_codinsee" FROM "xplore2"."h_codpos") as x) [numPartitions=1] [codegen id : 2]
Output [6]: [cp_burdis#665371, cp_codinsee#665375, cp_codpays#665372, cp_codpos#665370, cp_coduti#665373, cp_datmaj#665374]
ReadSchema: struct<cp_burdis:string,cp_codinsee:string,cp_codpays:string,cp_codpos:string,cp_coduti:string,cp_datmaj:string>
(5) Filter [codegen id : 2]
Input [6]: [cp_burdis#665371, cp_codinsee#665375, cp_codpays#665372, cp_codpos#665370, cp_coduti#665373, cp_datmaj#665374]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpos#665370)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpos#665370)), MAIN) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_burdis#665371)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_burdis#665371)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codpays#665372)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codpays#665372)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_coduti#665373)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_coduti#665373)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_datmaj#665374)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_datmaj#665374)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(cp_codinsee#665375)), MAIN)) THEN false ELSE Contains(str_remove_accent(upper(cp_codinsee#665375)), MAIN) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), MAIN)) THEN false ELSE Contains(str_remove_accent(null), MAIN) END)
(6) Project [codegen id : 2]
Output [7]: [cp_burdis#665371 AS CP_BURDIS_437228#665412, cp_codinsee#665375 AS CP_CODINSEE_437232#665413, cp_codpays#665372 AS CP_CODPAYS_437229#665414, cp_codpos#665370 AS CP_CODPOS_437227#665415, cp_coduti#665373 AS CP_CODUTI_437230#665416, cp_datmaj#665374 AS CP_DATMAJ_437231#665417, null AS ORIGINE_440138#665418]
Input [6]: [cp_burdis#665371, cp_codinsee#665375, cp_codpays#665372, cp_codpos#665370, cp_coduti#665373, cp_datmaj#665374]
(7) Union
(8) HashAggregate [codegen id : 3]
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Keys [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Functions: []
Aggregate Attributes: []
Results [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
(9) Exchange
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Arguments: hashpartitioning(CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362, 10), ENSURE_REQUIREMENTS, [plan_id=35849]
(10) ShuffleQueryStage
Output [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Arguments: 0
(11) AQEShuffleRead
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Arguments: coalesced
(12) HashAggregate [codegen id : 4]
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Keys [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Functions: []
Aggregate Attributes: []
Results: []
(13) HashAggregate [codegen id : 4]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#665894L]
Results [1]: [count#665895L]
(14) Exchange
Input [1]: [count#665895L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=36088]
(15) ShuffleQueryStage
Output [1]: [count#665895L]
Arguments: 1
(16) HashAggregate [codegen id : 5]
Input [1]: [count#665895L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#665784L]
Results [1]: [count(1)#665784L AS COL_3a441c8b-a829-43d9-af64-c63eb8145229#665786L]
(17) Union
(18) HashAggregate
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Keys [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Functions: []
Aggregate Attributes: []
Results [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
(19) Exchange
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Arguments: hashpartitioning(CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362, 10), ENSURE_REQUIREMENTS, [plan_id=35817]
(20) HashAggregate
Input [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Keys [7]: [CP_BURDIS_437228#665356, CP_CODINSEE_437232#665357, CP_CODPAYS_437229#665358, CP_CODPOS_437227#665359, CP_CODUTI_437230#665360, CP_DATMAJ_437231#665361, ORIGINE_440138#665362]
Functions: []
Aggregate Attributes: []
Results: []
(21) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#665894L]
Results [1]: [count#665895L]
(22) Exchange
Input [1]: [count#665895L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=35821]
(23) HashAggregate
Input [1]: [count#665895L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#665784L]
Results [1]: [count(1)#665784L AS COL_3a441c8b-a829-43d9-af64-c63eb8145229#665786L]
(24) AdaptiveSparkPlan
Output [1]: [COL_3a441c8b-a829-43d9-af64-c63eb8145229#665786L]
Arguments: isFinalPlan=true