digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 0 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build: 0 ms<br>number of output rows: 1"];
}
4 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 3<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>1 ms (0 ms, 0 ms, 0 ms (stage 877.0: task 1181))<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: 3<br>local bytes read: 178.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: 3<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>72.0 B (24.0 B, 24.0 B, 24.0 B (stage 877.0: task 1179))<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 total (min, med, max (stageId: taskId))<br>178.0 B (57.0 B, 57.0 B, 64.0 B (stage 877.0: task 1180))"];
subgraph cluster5 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n85 ms (4 ms, 39 ms, 42 ms (stage 877.0: task 1180))";
6 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build total (min, med, max (stageId: taskId))<br>82 ms (4 ms, 36 ms, 42 ms (stage 877.0: task 1180))<br>number of output rows: 3"];
7 [labelType="html" label="<br><b>Project</b><br><br>"];
8 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 7"];
9 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 20,000<br>number of input batches: 5"];
}
10 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 3<br>scan time total (min, med, max (stageId: taskId))<br>78 ms (4 ms, 36 ms, 38 ms (stage 877.0: task 1180))<br>metadata time: 0 ms<br>size of files read: 496.9 KiB<br>number of output rows: 20,000"];
2->0;
3->2;
4->3;
6->4;
7->6;
8->7;
9->8;
10->9;
}
11
AdaptiveSparkPlan isFinalPlan=true
Project [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L, str_concat(array(Nb RSA CMD 28 Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#143725]
HashAggregate(keys=[], functions=[sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)])
WholeStageCodegen (2)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14521]
HashAggregate(keys=[], functions=[partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)])
Project [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773]
Filter (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293 <=> nbrsaseance))
ColumnarToRow
WholeStageCodegen (1)
FileScan parquet [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289,COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293,COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294,COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295,COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302] Batched: true, DataFilters: [(COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289 <=> 350000055), (COL_B69B2310_3A87_437C_B292_E2..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/1_D_2_RTP_2_REP_307318], PartitionFilters: [], PushedFilters: [EqualNullSafe(COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC,350000055), EqualNullSafe(COL_B69B2310_3A..., ReadSchema: struct<COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC:string,COL_D6826CBC_1D7A_47AB_846E_D442A882445E:s...
== Physical Plan ==
AdaptiveSparkPlan (16)
+- == Final Plan ==
* Project (9)
+- * HashAggregate (8)
+- ShuffleQueryStage (7), Statistics(sizeInBytes=72.0 B, rowCount=3)
+- Exchange (6)
+- * HashAggregate (5)
+- * Project (4)
+- * Filter (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
+- == Initial Plan ==
Project (15)
+- HashAggregate (14)
+- Exchange (13)
+- HashAggregate (12)
+- Project (11)
+- Filter (10)
+- Scan parquet (1)
(1) Scan parquet
Output [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/1_D_2_RTP_2_REP_307318]
PushedFilters: [EqualNullSafe(COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC,350000055), EqualNullSafe(COL_B69B2310_3A87_437C_B292_E2D12FC12449,2025-07), EqualNullSafe(COL_D6826CBC_1D7A_47AB_846E_D442A882445E,nbrsaseance)]
ReadSchema: struct<COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC:string,COL_D6826CBC_1D7A_47AB_846E_D442A882445E:string,COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0:int,COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9:int,COL_B69B2310_3A87_437C_B292_E2D12FC12449:string>
(2) ColumnarToRow [codegen id : 1]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
(3) Filter [codegen id : 1]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
Condition : (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293 <=> nbrsaseance))
(4) Project [codegen id : 1]
Output [2]: [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
(5) HashAggregate [codegen id : 1]
Input [2]: [COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772, COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773]
Keys: []
Functions [2]: [partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)]
Aggregate Attributes [2]: [sum#143822L, sum#143823L]
Results [2]: [sum#143824L, sum#143825L]
(6) Exchange
Input [2]: [sum#143824L, sum#143825L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14521]
(7) ShuffleQueryStage
Output [2]: [sum#143824L, sum#143825L]
Arguments: 0
(8) HashAggregate [codegen id : 2]
Input [2]: [sum#143824L, sum#143825L]
Keys: []
Functions [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)]
Aggregate Attributes [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772)#143234L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)#143236L]
Results [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772)#143234L AS COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)#143236L AS COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L]
(9) Project [codegen id : 2]
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L, str_concat(array(Nb RSA CMD 28 Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#143725]
Input [2]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L]
(10) Filter
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
Condition : (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293 <=> nbrsaseance))
(11) Project
Output [2]: [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#142289, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#142293, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#142294, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#142295, COL_B69B2310_3A87_437C_B292_E2D12FC12449#142302]
(12) HashAggregate
Input [2]: [COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772, COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773]
Keys: []
Functions [2]: [partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)]
Aggregate Attributes [2]: [sum#143822L, sum#143823L]
Results [2]: [sum#143824L, sum#143825L]
(13) Exchange
Input [2]: [sum#143824L, sum#143825L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14489]
(14) HashAggregate
Input [2]: [sum#143824L, sum#143825L]
Keys: []
Functions [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)]
Aggregate Attributes [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772)#143234L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)#143236L]
Results [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#142772)#143234L AS COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#142773)#143236L AS COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L]
(15) Project
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L, str_concat(array(Nb RSA CMD 28 Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#143725]
Input [2]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L]
(16) AdaptiveSparkPlan
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#143235L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#143237L, COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#143725]
Arguments: isFinalPlan=true