digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<b>SortAggregate</b><br><br>number of output rows: 1"];
2 [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: 149.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: 120.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: 149.0 B"];
3 [labelType="html" label="<b>SortAggregate</b><br><br>number of output rows: 1"];
subgraph cluster4 {
isCluster="true";
label="WholeStageCodegen (9)\n \nduration: 293 ms";
5 [labelType="html" label="<br><b>Project</b><br><br>"];
6 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 21,131<br>spill size: 0.0 B"];
}
subgraph cluster7 {
isCluster="true";
label="WholeStageCodegen (7)\n \nduration: 618 ms";
8 [labelType="html" label="<b>Sort</b><br><br>sort time: 3 ms<br>peak memory: 16.5 MiB<br>spill size: 0.0 B"];
}
9 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 349.1 KiB<br>number of coalesced partitions: 1"];
10 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 21,127<br>local merged chunks fetched: 0<br>shuffle write time: 1 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: 21,127<br>local bytes read: 340.1 KiB<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: 1492.2 KiB<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: 340.1 KiB"];
subgraph cluster11 {
isCluster="true";
label="WholeStageCodegen (6)\n \nduration: 51 ms";
12 [labelType="html" label="<br><b>Project</b><br><br>"];
13 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 21,127<br>spill size: 0.0 B"];
}
subgraph cluster14 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 174 ms";
15 [labelType="html" label="<b>Sort</b><br><br>sort time: 9 ms<br>peak memory: 16.5 MiB<br>spill size: 0.0 B"];
}
16 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 449.6 KiB<br>number of coalesced partitions: 1"];
17 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 21,121<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>5 ms (1 ms, 1 ms, 1 ms (stage 20858.0: task 27151))<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: 21,121<br>local bytes read: 424.2 KiB<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>1320.1 KiB (41.4 KiB, 639.3 KiB, 639.3 KiB (stage 20858.0: task 27149))<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>424.2 KiB (14.7 KiB, 203.1 KiB, 206.5 KiB (stage 20858.0: task 27149))"];
subgraph cluster18 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n596 ms (101 ms, 238 ms, 257 ms (stage 20858.0: task 27150))";
19 [labelType="html" label="<br><b>Project</b><br><br>"];
}
20 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 21,121<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 8.3 MiB"];
subgraph cluster21 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 1.4 m";
22 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
23 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 0 ms<br>peak memory: 256.0 KiB<br>number of output rows: 445<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0"];
}
24 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 5.0 KiB<br>number of coalesced partitions: 1"];
25 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 445<br>local merged chunks fetched: 0<br>shuffle write time: 1 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: 445<br>local bytes read: 4.8 KiB<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: 13.9 KiB<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: 4.8 KiB"];
subgraph cluster26 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 17 ms";
27 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 12 ms<br>peak memory: 256.0 KiB<br>number of output rows: 445<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0"];
28 [labelType="html" label="<br><b>Project</b><br><br>"];
}
29 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 1,216<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 111.6 KiB"];
subgraph cluster30 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 614 ms";
31 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
32 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 0 ms<br>peak memory: 256.0 KiB<br>number of output rows: 464<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0"];
}
33 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 5.2 KiB<br>number of coalesced partitions: 1"];
34 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 464<br>local merged chunks fetched: 0<br>shuffle write time: 1 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: 464<br>local bytes read: 5.0 KiB<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: 14.5 KiB<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: 5.0 KiB"];
subgraph cluster35 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 12 ms";
36 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 8 ms<br>peak memory: 256.0 KiB<br>number of output rows: 464<br>number of sort fallback tasks: 0<br>avg hash probes per key: 0"];
37 [labelType="html" label="<br><b>Project</b><br><br>"];
}
38 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 486<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 50.8 KiB"];
1->0;
2->1;
3->2;
5->3;
6->5;
8->6;
9->8;
10->9;
12->10;
13->12;
15->13;
16->15;
17->16;
19->17;
20->19;
22->13;
23->22;
24->23;
25->24;
27->25;
28->27;
29->28;
31->6;
32->31;
33->32;
34->33;
36->34;
37->36;
38->37;
}
39
AdaptiveSparkPlan isFinalPlan=true
SortAggregate(key=[], functions=[count(1), count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)])
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1026583]
SortAggregate(key=[], functions=[partial_count(1), partial_count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)])
Project [str_if_with_rule(isnull(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180), str_join(array(str_join(array(séjour, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811), :), absent de VisualValoSej et présent dans Fichcomp DMI/MO), ), ) AS COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330]
SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707], [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832], FullOuter
WholeStageCodegen (9)
Sort [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
WholeStageCodegen (7)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026500]
Project [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 AS COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
SortMergeJoin [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707], [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721], FullOuter
WholeStageCodegen (6)
Sort [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026291]
Project [NO_ADMIN#1651308 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, str_remove_space(NO_ADMIN#1651308, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
WholeStageCodegen (1)
FileScan csv [NO_ADMIN#1651308] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/VISUALVALOSEJOU_237544/420780652.2025.1..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<NO_ADMIN:string>
Sort [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 ASC NULLS FIRST], false, 0
HashAggregate(keys=[COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183], functions=[])
WholeStageCodegen (5)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183, 10), ENSURE_REQUIREMENTS, [plan_id=1026304]
HashAggregate(keys=[COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183], functions=[])
Project [str_remove_space(str_extract_middle(_c0#1653078, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
WholeStageCodegen (2)
FileScan csv [_c0#1653078] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/DMI_M12_2025_237543/DMI-M12-2025 - BIS...., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<_c0:string>
Sort [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832 ASC NULLS FIRST], false, 0
HashAggregate(keys=[COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993], functions=[])
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993, 10), ENSURE_REQUIREMENTS, [plan_id=1026324]
HashAggregate(keys=[COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993], functions=[])
Project [str_remove_space(str_extract_middle(_c0#1652874, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
WholeStageCodegen (3)
FileScan csv [_c0#1652874] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/MOLECULES_ONERE_237545/MO-M12-2025.txt], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<_c0:string>
== Physical Plan ==
AdaptiveSparkPlan (57)
+- == Final Plan ==
SortAggregate (34)
+- ShuffleQueryStage (33), Statistics(sizeInBytes=120.0 B, rowCount=1)
+- Exchange (32)
+- SortAggregate (31)
+- * Project (30)
+- * SortMergeJoin FullOuter (29)
:- * Sort (20)
: +- AQEShuffleRead (19)
: +- ShuffleQueryStage (18), Statistics(sizeInBytes=1492.2 KiB, rowCount=2.11E+4)
: +- Exchange (17)
: +- * Project (16)
: +- * SortMergeJoin FullOuter (15)
: :- * Sort (6)
: : +- AQEShuffleRead (5)
: : +- ShuffleQueryStage (4), Statistics(sizeInBytes=1320.1 KiB, rowCount=2.11E+4)
: : +- Exchange (3)
: : +- * Project (2)
: : +- Scan csv (1)
: +- * Sort (14)
: +- * HashAggregate (13)
: +- AQEShuffleRead (12)
: +- ShuffleQueryStage (11), Statistics(sizeInBytes=13.9 KiB, rowCount=445)
: +- Exchange (10)
: +- * HashAggregate (9)
: +- * Project (8)
: +- Scan csv (7)
+- * Sort (28)
+- * HashAggregate (27)
+- AQEShuffleRead (26)
+- ShuffleQueryStage (25), Statistics(sizeInBytes=14.5 KiB, rowCount=464)
+- Exchange (24)
+- * HashAggregate (23)
+- * Project (22)
+- Scan csv (21)
+- == Initial Plan ==
SortAggregate (56)
+- Exchange (55)
+- SortAggregate (54)
+- Project (53)
+- SortMergeJoin FullOuter (52)
:- Sort (46)
: +- Exchange (45)
: +- Project (44)
: +- SortMergeJoin FullOuter (43)
: :- Sort (37)
: : +- Exchange (36)
: : +- Project (35)
: : +- Scan csv (1)
: +- Sort (42)
: +- HashAggregate (41)
: +- Exchange (40)
: +- HashAggregate (39)
: +- Project (38)
: +- Scan csv (7)
+- Sort (51)
+- HashAggregate (50)
+- Exchange (49)
+- HashAggregate (48)
+- Project (47)
+- Scan csv (21)
(1) Scan csv
Output [1]: [NO_ADMIN#1651308]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/VISUALVALOSEJOU_237544/420780652.2025.12.MCO.VisualValoSejours.csv]
ReadSchema: struct<NO_ADMIN:string>
(2) Project [codegen id : 1]
Output [2]: [NO_ADMIN#1651308 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, str_remove_space(NO_ADMIN#1651308, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Input [1]: [NO_ADMIN#1651308]
(3) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026291]
(4) ShuffleQueryStage
Output [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: 0
(5) AQEShuffleRead
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: coalesced
(6) Sort [codegen id : 4]
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
(7) Scan csv
Output [1]: [_c0#1653078]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/DMI_M12_2025_237543/DMI-M12-2025 - BIS.txt]
ReadSchema: struct<_c0:string>
(8) Project [codegen id : 2]
Output [1]: [str_remove_space(str_extract_middle(_c0#1653078, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Input [1]: [_c0#1653078]
(9) HashAggregate [codegen id : 2]
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
(10) Exchange
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Arguments: hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183, 10), ENSURE_REQUIREMENTS, [plan_id=1026304]
(11) ShuffleQueryStage
Output [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Arguments: 1
(12) AQEShuffleRead
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Arguments: coalesced
(13) HashAggregate [codegen id : 5]
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183 AS 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
(14) Sort [codegen id : 5]
Input [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
Arguments: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 ASC NULLS FIRST], false, 0
(15) SortMergeJoin [codegen id : 6]
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Right keys [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
Join type: FullOuter
Join condition: None
(16) Project [codegen id : 6]
Output [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 AS COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
(17) Exchange
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026500]
(18) ShuffleQueryStage
Output [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: 3
(19) AQEShuffleRead
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: coalesced
(20) Sort [codegen id : 7]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
(21) Scan csv
Output [1]: [_c0#1652874]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/MOLECULES_ONERE_237545/MO-M12-2025.txt]
ReadSchema: struct<_c0:string>
(22) Project [codegen id : 3]
Output [1]: [str_remove_space(str_extract_middle(_c0#1652874, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Input [1]: [_c0#1652874]
(23) HashAggregate [codegen id : 3]
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
(24) Exchange
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Arguments: hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993, 10), ENSURE_REQUIREMENTS, [plan_id=1026324]
(25) ShuffleQueryStage
Output [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Arguments: 2
(26) AQEShuffleRead
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Arguments: coalesced
(27) HashAggregate [codegen id : 8]
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993 AS 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
(28) Sort [codegen id : 8]
Input [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
Arguments: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832 ASC NULLS FIRST], false, 0
(29) SortMergeJoin [codegen id : 9]
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Right keys [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
Join type: FullOuter
Join condition: None
(30) Project [codegen id : 9]
Output [1]: [str_if_with_rule(isnull(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180), str_join(array(str_join(array(séjour, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811), :), absent de VisualValoSej et présent dans Fichcomp DMI/MO), ), ) AS COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330]
Input [4]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
(31) SortAggregate
Input [1]: [COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330]
Keys: []
Functions [4]: [partial_count(1), partial_count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)]
Aggregate Attributes [4]: [count#1655401L, count#1655402L, min#1655403, max#1655404]
Results [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
(32) Exchange
Input [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1026583]
(33) ShuffleQueryStage
Output [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
Arguments: 4
(34) SortAggregate
Input [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
Keys: []
Functions [4]: [count(1), count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)]
Aggregate Attributes [4]: [count(1)#1655357L, count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655360L, min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655363, max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655365]
Results [4]: [count(1)#1655357L AS COL_125A5E52_9A2A_4ABD_A883_7B73348511951#1655359L, count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655360L AS COL_125A5E52_9A2A_4ABD_A883_7B73348511952#1655362L, min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655363 AS COL_125A5E52_9A2A_4ABD_A883_7B73348511954#1655364, max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655365 AS COL_125A5E52_9A2A_4ABD_A883_7B73348511955#1655366]
(35) Project
Output [2]: [NO_ADMIN#1651308 AS COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, str_remove_space(NO_ADMIN#1651308, ALL) AS COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Input [1]: [NO_ADMIN#1651308]
(36) Exchange
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026226]
(37) Sort
Input [2]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
(38) Project
Output [1]: [str_remove_space(str_extract_middle(_c0#1653078, 12, 20), ALL) AS COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Input [1]: [_c0#1653078]
(39) HashAggregate
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
(40) Exchange
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Arguments: hashpartitioning(COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183, 10), ENSURE_REQUIREMENTS, [plan_id=1026222]
(41) HashAggregate
Input [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Keys [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_9D7AAEDE_94EE_40AF_8530_BC9D1F27742A#1653183 AS 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
(42) Sort
Input [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
Arguments: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 ASC NULLS FIRST], false, 0
(43) SortMergeJoin
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Right keys [1]: [01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
Join type: FullOuter
Join condition: None
(44) Project
Output [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721 AS COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 01_DMI_DECOUPAG_237714_COL_1D1ABD09_1E00_4FA7_81FE_A558E22F6A6D#1654721]
(45) Exchange
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: hashpartitioning(COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, 10), ENSURE_REQUIREMENTS, [plan_id=1026235]
(46) Sort
Input [3]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811]
Arguments: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707 ASC NULLS FIRST], false, 0
(47) Project
Output [1]: [str_remove_space(str_extract_middle(_c0#1652874, 12, 20), ALL) AS COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Input [1]: [_c0#1652874]
(48) HashAggregate
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
(49) Exchange
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Arguments: hashpartitioning(COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993, 10), ENSURE_REQUIREMENTS, [plan_id=1026231]
(50) HashAggregate
Input [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Keys [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993]
Functions: []
Aggregate Attributes: []
Results [1]: [COL_45066C9F_40FD_4BE1_ACAF_6139C274CECB#1652993 AS 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
(51) Sort
Input [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
Arguments: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832 ASC NULLS FIRST], false, 0
(52) SortMergeJoin
Left keys [1]: [COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707]
Right keys [1]: [01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
Join type: FullOuter
Join condition: None
(53) Project
Output [1]: [str_if_with_rule(isnull(COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180), str_join(array(str_join(array(séjour, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811), :), absent de VisualValoSej et présent dans Fichcomp DMI/MO), ), ) AS COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330]
Input [4]: [COL_5C76D7BA_A38A_4050_92DD_40D15A692CCA#1654180, COL_7948E047_29EE_472A_BFFC_723098878DAD#1654707, COL_D83A595E_7901_4A79_9DA3_AB68A1511B8A#1654811, 01_MOLECULES_ON_237708_COL_EE4AB0B4_F37E_40C0_9292_9E68BF166E36#1654832]
(54) SortAggregate
Input [1]: [COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330]
Keys: []
Functions [4]: [partial_count(1), partial_count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), partial_max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)]
Aggregate Attributes [4]: [count#1655401L, count#1655402L, min#1655403, max#1655404]
Results [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
(55) Exchange
Input [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=1026242]
(56) SortAggregate
Input [4]: [count#1655405L, count#1655406L, min#1655407, max#1655408]
Keys: []
Functions [4]: [count(1), count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330), max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)]
Aggregate Attributes [4]: [count(1)#1655357L, count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655360L, min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655363, max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655365]
Results [4]: [count(1)#1655357L AS COL_125A5E52_9A2A_4ABD_A883_7B73348511951#1655359L, count(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655360L AS COL_125A5E52_9A2A_4ABD_A883_7B73348511952#1655362L, min(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655363 AS COL_125A5E52_9A2A_4ABD_A883_7B73348511954#1655364, max(COL_125A5E52_9A2A_4ABD_A883_7B7334851195#1655330)#1655365 AS COL_125A5E52_9A2A_4ABD_A883_7B73348511955#1655366]
(57) AdaptiveSparkPlan
Output [4]: [COL_125A5E52_9A2A_4ABD_A883_7B73348511951#1655359L, COL_125A5E52_9A2A_4ABD_A883_7B73348511952#1655362L, COL_125A5E52_9A2A_4ABD_A883_7B73348511954#1655364, COL_125A5E52_9A2A_4ABD_A883_7B73348511955#1655366]
Arguments: isFinalPlan=true