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>2 ms (0 ms, 0 ms, 1 ms (stage 866.0: task 1162))<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 866.0: task 1161))<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 866.0: task 1162))"];
subgraph cluster5 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n27 ms (5 ms, 8 ms, 14 ms (stage 866.0: task 1162))";
6 [labelType="html" label="<b>HashAggregate</b><br><br>time in aggregation build total (min, med, max (stageId: taskId))<br>27 ms (5 ms, 8 ms, 14 ms (stage 866.0: task 1162))<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>18 ms (5 ms, 5 ms, 8 ms (stage 866.0: task 1163))<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#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L, str_concat(array(Nb RSA UHCD réaffecté, Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#141350]
HashAggregate(keys=[], functions=[sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)])
WholeStageCodegen (2)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14332]
HashAggregate(keys=[], functions=[partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)])
Project [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237]
Filter (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103 <=> nbuhcd))
ColumnarToRow
WholeStageCodegen (1)
FileScan parquet [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099,COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103,COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104,COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105,COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112] Batched: true, DataFilters: [(COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099 <=> 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#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
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,nbuhcd)]
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#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
(3) Filter [codegen id : 1]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
Condition : (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103 <=> nbuhcd))
(4) Project [codegen id : 1]
Output [2]: [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
(5) HashAggregate [codegen id : 1]
Input [2]: [COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236, COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237]
Keys: []
Functions [2]: [partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)]
Aggregate Attributes [2]: [sum#141354L, sum#141355L]
Results [2]: [sum#141356L, sum#141357L]
(6) Exchange
Input [2]: [sum#141356L, sum#141357L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14332]
(7) ShuffleQueryStage
Output [2]: [sum#141356L, sum#141357L]
Arguments: 0
(8) HashAggregate [codegen id : 2]
Input [2]: [sum#141356L, sum#141357L]
Keys: []
Functions [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)]
Aggregate Attributes [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236)#141314L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)#141316L]
Results [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236)#141314L AS COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)#141316L AS COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L]
(9) Project [codegen id : 2]
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L, str_concat(array(Nb RSA UHCD réaffecté, Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#141350]
Input [2]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L]
(10) Filter
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
Condition : (((COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099 <=> 350000055) AND (COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112 <=> 2025-07)) AND (COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103 <=> nbuhcd))
(11) Project
Output [2]: [COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104 AS COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105 AS COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237]
Input [5]: [COL_2DFC29A4_BF4D_4060_AB13_F84848B6A9EC#141099, COL_D6826CBC_1D7A_47AB_846E_D442A882445E#141103, COL_ABA1200A_9BEA_462A_A92A_6F99C03905A0#141104, COL_B89E53A9_1D2B_4FB0_96C5_C318E19ACCA9#141105, COL_B69B2310_3A87_437C_B292_E2D12FC12449#141112]
(12) HashAggregate
Input [2]: [COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236, COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237]
Keys: []
Functions [2]: [partial_sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), partial_sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)]
Aggregate Attributes [2]: [sum#141354L, sum#141355L]
Results [2]: [sum#141356L, sum#141357L]
(13) Exchange
Input [2]: [sum#141356L, sum#141357L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=14310]
(14) HashAggregate
Input [2]: [sum#141356L, sum#141357L]
Keys: []
Functions [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236), sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)]
Aggregate Attributes [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236)#141314L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)#141316L]
Results [2]: [sum(COL_D0F7532F_D91A_4990_AFD3_0CAFCACEDAA5#141236)#141314L AS COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, sum(COL_6A578CCD_A85B_4EEE_B787_0D80845EA7EA#141237)#141316L AS COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L]
(15) Project
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L, str_concat(array(Nb RSA UHCD réaffecté, Année n : , bigint_to_str(COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L), , Nb RSA Année n -1 : , bigint_to_str(COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L))) AS COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#141350]
Input [2]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L]
(16) AdaptiveSparkPlan
Output [3]: [COL_D5F3070D_302E_4C75_81DA_88629D51A748#141315L, COL_AA63740A_F9E0_4541_B6FA_2BA26A14738E#141317L, COL_5EDF5460_6750_4C31_8D3F_78F6BC887AA9#141350]
Arguments: isFinalPlan=true