digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (16)\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 (15)\n \nduration: 11 ms";
5 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 11 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="<br><b>Project</b><br><br>"];
7 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 243"];
8 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6,213<br>spill size: 0.0 B"];
}
subgraph cluster9 {
isCluster="true";
label="WholeStageCodegen (13)\n \nduration: 13 ms";
10 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.3 MiB<br>spill size: 0.0 B"];
}
11 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 38.4 KiB<br>number of coalesced partitions: 1"];
12 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 6,213<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: 6,213<br>local bytes read: 36.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: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 196.1 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: 36.2 KiB"];
subgraph cluster13 {
isCluster="true";
label="WholeStageCodegen (12)\n \nduration: 7 ms";
14 [labelType="html" label="<br><b>Project</b><br><br>"];
15 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6,213<br>spill size: 0.0 B"];
}
subgraph cluster16 {
isCluster="true";
label="WholeStageCodegen (10)\n \nduration: 9 ms";
17 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.3 MiB<br>spill size: 0.0 B"];
}
18 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 43.8 KiB<br>number of coalesced partitions: 1"];
19 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 6,213<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: 6,213<br>local bytes read: 41.5 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: 244.6 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: 41.5 KiB"];
subgraph cluster20 {
isCluster="true";
label="WholeStageCodegen (9)\n \nduration: 23 ms";
21 [labelType="html" label="<br><b>Project</b><br><br>"];
22 [labelType="html" label="<br><b>Project</b><br><br>"];
}
23 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster24 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 55 ms";
25 [labelType="html" label="<b>Sort</b><br><br>sort time: 4 ms<br>peak memory: 16.3 MiB<br>spill size: 0.0 B"];
}
26 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 100.5 KiB<br>number of coalesced partitions: 1"];
27 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 6,213<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: 6,213<br>local bytes read: 95.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: 581.0 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: 95.1 KiB"];
subgraph cluster28 {
isCluster="true";
label="WholeStageCodegen (7)\n \nduration: 72 ms";
29 [labelType="html" label="<br><b>Project</b><br><br>"];
30 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6,213<br>spill size: 0.0 B"];
}
subgraph cluster31 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 80 ms";
32 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
33 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 128.5 KiB<br>number of coalesced partitions: 1"];
34 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 4,001<br>local merged chunks fetched: 0<br>shuffle write time: 2 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: 4,001<br>local bytes read: 122.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: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 468.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: 122.2 KiB"];
subgraph cluster35 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 21 ms";
36 [labelType="html" label="<br><b>Project</b><br><br>"];
}
37 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 4,001<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 219.3 KiB"];
subgraph cluster38 {
isCluster="true";
label="WholeStageCodegen (6)\n \nduration: 79 ms";
39 [labelType="html" label="<b>Sort</b><br><br>sort time: 1 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
40 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 40.9 KiB<br>number of coalesced partitions: 1"];
41 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 3,810<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: 3,810<br>local bytes read: 38.5 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: 208.4 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: 38.5 KiB"];
subgraph cluster42 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 25 ms";
43 [labelType="html" label="<br><b>Project</b><br><br>"];
44 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 3,810"];
}
45 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 3,810<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 269.6 KiB"];
subgraph cluster46 {
isCluster="true";
label="WholeStageCodegen (11)\n \nduration: 0 ms";
47 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
48 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 4.2 KiB<br>number of coalesced partitions: 1"];
49 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 206<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: 412<br>local bytes read total (min, med, max (stageId: taskId))<br>8.0 KiB (4.0 KiB, 4.0 KiB, 4.0 KiB (stage 8054.0: task 11023))<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 8054.0: task 11023))<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: 9.7 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.0 KiB"];
subgraph cluster50 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 14 ms";
51 [labelType="html" label="<br><b>Project</b><br><br>"];
52 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 206"];
53 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 207<br>number of input batches: 1"];
}
54 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 3 ms<br>metadata time: 0 ms<br>size of files read: 4.6 KiB<br>number of output rows: 207"];
subgraph cluster55 {
isCluster="true";
label="WholeStageCodegen (14)\n \nduration: 0 ms";
56 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
57 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 4.2 KiB<br>number of coalesced partitions: 1"];
2->0;
3->2;
5->3;
6->5;
7->6;
8->7;
10->8;
11->10;
12->11;
14->12;
15->14;
17->15;
18->17;
19->18;
21->19;
22->21;
23->22;
25->23;
26->25;
27->26;
29->27;
30->29;
32->30;
33->32;
34->33;
36->34;
37->36;
39->30;
40->39;
41->40;
43->41;
44->43;
45->44;
47->15;
48->47;
49->48;
51->49;
52->51;
53->52;
54->53;
56->8;
57->56;
49->57;
}
58
AdaptiveSparkPlan isFinalPlan=true
HashAggregate(keys=[], functions=[count(1)])
WholeStageCodegen (16)
Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=386257]
HashAggregate(keys=[], functions=[partial_count(1)])
Project
Filter CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null) > 0.0) END
SortMergeJoin [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932))
WholeStageCodegen (15)
Sort [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825 ASC NULLS FIRST], false, 0
WholeStageCodegen (13)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, 10), ENSURE_REQUIREMENTS, [plan_id=386170]
Project [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
SortMergeJoin [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851))
WholeStageCodegen (12)
Sort [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261 ASC NULLS FIRST], false, 0
WholeStageCodegen (10)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, 10), ENSURE_REQUIREMENTS, [plan_id=386064]
Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L]
WholeStageCodegen (9)
Window [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST]
Sort [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST], false, 0
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, 10), ENSURE_REQUIREMENTS, [plan_id=385871]
Project [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COURRIERS_FICTI_227799__STATUT#576285 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
SortMergeJoin [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259], [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284], LeftOuter
WholeStageCodegen (7)
Sort [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST], false, 0
WholeStageCodegen (5)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, 10), ENSURE_REQUIREMENTS, [plan_id=385580]
Project [ipp#575958 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, iep#575959 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, code_acte#575960 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, code_spe#575961 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, date_acte#575962 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, parcours#575964 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
WholeStageCodegen (1)
FileScan csv [ipp#575958,iep#575959,code_acte#575960,code_spe#575961,date_acte#575962,parcours#575964] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/FADCB12B_36CA_40FC_B01F_3DD2C64D5..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<ipp:string,iep:string,code_acte:string,code_spe:string,date_acte:string,parcours:string>
Sort [COURRIERS_FICTI_227799__IEP#576283 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#576284 ASC NULLS FIRST], false, 0
WholeStageCodegen (6)
AQEShuffleRead coalesced
Exchange hashpartitioning(COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, 10), ENSURE_REQUIREMENTS, [plan_id=385593]
Project [iep#575878 AS COURRIERS_FICTI_227799__IEP#576283, ipp#575877 AS COURRIERS_FICTI_227799__IPP#576284, statut#575882 AS COURRIERS_FICTI_227799__STATUT#576285]
Filter (isnotnull(iep#575878) AND isnotnull(ipp#575877))
WholeStageCodegen (2)
FileScan csv [ipp#575877,iep#575878,statut#575882] Batched: false, DataFilters: [isnotnull(iep#575878), isnotnull(ipp#575877)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/5DC66825_AB06_470F_8B00_2AE6C1370..., PartitionFilters: [], PushedFilters: [IsNotNull(iep), IsNotNull(ipp)], ReadSchema: struct<ipp:string,iep:string,statut:string>
Sort [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849 ASC NULLS FIRST], false, 0
WholeStageCodegen (11)
AQEShuffleRead coalesced
Exchange hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, 10), ENSURE_REQUIREMENTS, [plan_id=385622]
Project [Code+Acte#576022 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, str_to_dec(str_replace(Montant#576023, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Filter ((isnotnull(Code+Acte#576022) AND isnotnull(str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR)))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Code+Acte#576022,Montant#576023,Date_effet#576025,Date_r%C3%A9vocation#576026] Batched: true, DataFilters: [isnotnull(Code+Acte#576022), isnotnull(str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris,..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/B327EFC6_2C56_4F02_941C_F0209F65C43..., PartitionFilters: [], PushedFilters: [IsNotNull(`Code+Acte`)], ReadSchema: struct<Code+Acte:string,Montant:string,Date_effet:string,Date_r%C3%A9vocation:string>
Sort [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930 ASC NULLS FIRST], false, 0
WholeStageCodegen (14)
AQEShuffleRead coalesced
== Physical Plan ==
AdaptiveSparkPlan (87)
+- == Final Plan ==
* HashAggregate (51)
+- ShuffleQueryStage (50), Statistics(sizeInBytes=16.0 B, rowCount=1)
+- Exchange (49)
+- * HashAggregate (48)
+- * Project (47)
+- * Filter (46)
+- * SortMergeJoin LeftOuter (45)
:- * Sort (40)
: +- AQEShuffleRead (39)
: +- ShuffleQueryStage (38), Statistics(sizeInBytes=196.1 KiB, rowCount=6.21E+3)
: +- Exchange (37)
: +- * Project (36)
: +- * SortMergeJoin LeftOuter (35)
: :- * Sort (26)
: : +- AQEShuffleRead (25)
: : +- ShuffleQueryStage (24), Statistics(sizeInBytes=244.6 KiB, rowCount=6.21E+3)
: : +- Exchange (23)
: : +- * Project (22)
: : +- * Project (21)
: : +- Window (20)
: : +- * Sort (19)
: : +- AQEShuffleRead (18)
: : +- ShuffleQueryStage (17), Statistics(sizeInBytes=581.0 KiB, rowCount=6.21E+3)
: : +- Exchange (16)
: : +- * Project (15)
: : +- * SortMergeJoin LeftOuter (14)
: : :- * Sort (6)
: : : +- AQEShuffleRead (5)
: : : +- ShuffleQueryStage (4), Statistics(sizeInBytes=468.9 KiB, rowCount=4.00E+3)
: : : +- Exchange (3)
: : : +- * Project (2)
: : : +- Scan csv (1)
: : +- * Sort (13)
: : +- AQEShuffleRead (12)
: : +- ShuffleQueryStage (11), Statistics(sizeInBytes=208.4 KiB, rowCount=3.81E+3)
: : +- Exchange (10)
: : +- * Project (9)
: : +- * Filter (8)
: : +- Scan csv (7)
: +- * Sort (34)
: +- AQEShuffleRead (33)
: +- ShuffleQueryStage (32), Statistics(sizeInBytes=9.7 KiB, rowCount=206)
: +- Exchange (31)
: +- * Project (30)
: +- * Filter (29)
: +- * ColumnarToRow (28)
: +- Scan parquet (27)
+- * Sort (44)
+- AQEShuffleRead (43)
+- ShuffleQueryStage (42), Statistics(sizeInBytes=9.7 KiB, rowCount=206)
+- ReusedExchange (41)
+- == Initial Plan ==
HashAggregate (86)
+- Exchange (85)
+- HashAggregate (84)
+- Project (83)
+- Filter (82)
+- SortMergeJoin LeftOuter (81)
:- Sort (75)
: +- Exchange (74)
: +- Project (73)
: +- SortMergeJoin LeftOuter (72)
: :- Sort (67)
: : +- Exchange (66)
: : +- Project (65)
: : +- Project (64)
: : +- Window (63)
: : +- Sort (62)
: : +- Exchange (61)
: : +- Project (60)
: : +- SortMergeJoin LeftOuter (59)
: : :- Sort (54)
: : : +- Exchange (53)
: : : +- Project (52)
: : : +- Scan csv (1)
: : +- Sort (58)
: : +- Exchange (57)
: : +- Project (56)
: : +- Filter (55)
: : +- Scan csv (7)
: +- Sort (71)
: +- Exchange (70)
: +- Project (69)
: +- Filter (68)
: +- Scan parquet (27)
+- Sort (80)
+- Exchange (79)
+- Project (78)
+- Filter (77)
+- Scan parquet (76)
(1) Scan csv
Output [6]: [ipp#575958, iep#575959, code_acte#575960, code_spe#575961, date_acte#575962, parcours#575964]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/FADCB12B_36CA_40FC_B01F_3DD2C64D526A/current/actes_fictifs.csv]
ReadSchema: struct<ipp:string,iep:string,code_acte:string,code_spe:string,date_acte:string,parcours:string>
(2) Project [codegen id : 1]
Output [6]: [ipp#575958 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, iep#575959 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, code_acte#575960 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, code_spe#575961 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, date_acte#575962 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, parcours#575964 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Input [6]: [ipp#575958, iep#575959, code_acte#575960, code_spe#575961, date_acte#575962, parcours#575964]
(3) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, 10), ENSURE_REQUIREMENTS, [plan_id=385580]
(4) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: 0
(5) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: coalesced
(6) Sort [codegen id : 5]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST], false, 0
(7) Scan csv
Output [3]: [ipp#575877, iep#575878, statut#575882]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/5DC66825_AB06_470F_8B00_2AE6C1370A39/current/courriers_fictifs.csv]
PushedFilters: [IsNotNull(iep), IsNotNull(ipp)]
ReadSchema: struct<ipp:string,iep:string,statut:string>
(8) Filter [codegen id : 2]
Input [3]: [ipp#575877, iep#575878, statut#575882]
Condition : (isnotnull(iep#575878) AND isnotnull(ipp#575877))
(9) Project [codegen id : 2]
Output [3]: [iep#575878 AS COURRIERS_FICTI_227799__IEP#576283, ipp#575877 AS COURRIERS_FICTI_227799__IPP#576284, statut#575882 AS COURRIERS_FICTI_227799__STATUT#576285]
Input [3]: [ipp#575877, iep#575878, statut#575882]
(10) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, 10), ENSURE_REQUIREMENTS, [plan_id=385593]
(11) ShuffleQueryStage
Output [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: 1
(12) AQEShuffleRead
Input [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: coalesced
(13) Sort [codegen id : 6]
Input [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: [COURRIERS_FICTI_227799__IEP#576283 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#576284 ASC NULLS FIRST], false, 0
(14) SortMergeJoin [codegen id : 7]
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 7]
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COURRIERS_FICTI_227799__STATUT#576285 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
(16) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, 10), ENSURE_REQUIREMENTS, [plan_id=385871]
(17) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: 5
(18) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: coalesced
(19) Sort [codegen id : 8]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST], false, 0
(20) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST]
(21) Project [codegen id : 9]
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569]
(22) Project [codegen id : 9]
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L]
(23) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, 10), ENSURE_REQUIREMENTS, [plan_id=386064]
(24) ShuffleQueryStage
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: 6
(25) AQEShuffleRead
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: coalesced
(26) Sort [codegen id : 10]
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261 ASC NULLS FIRST], false, 0
(27) Scan parquet
Output [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/B327EFC6_2C56_4F02_941C_F0209F65C43D_f96390024f47ad1fd8d43d92a6c7a982/Region-PUBMET_tarifs_forfait_urgences_(1).xlsx_9f5cc06a8bb7ca4fd2c05636743786ea]
PushedFilters: [IsNotNull(`Code+Acte`)]
ReadSchema: struct<Code+Acte:string,Montant:string,Date_effet:string,Date_r%C3%A9vocation:string>
(28) ColumnarToRow [codegen id : 3]
Input [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
(29) Filter [codegen id : 3]
Input [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
Condition : ((isnotnull(Code+Acte#576022) AND isnotnull(str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR)))
(30) Project [codegen id : 3]
Output [4]: [Code+Acte#576022 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, str_to_dec(str_replace(Montant#576023, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Input [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
(31) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, 10), ENSURE_REQUIREMENTS, [plan_id=385622]
(32) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: 2
(33) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: coalesced
(34) Sort [codegen id : 11]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849 ASC NULLS FIRST], false, 0
(35) SortMergeJoin [codegen id : 12]
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851))
(36) Project [codegen id : 12]
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
(37) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, 10), ENSURE_REQUIREMENTS, [plan_id=386170]
(38) ShuffleQueryStage
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: 7
(39) AQEShuffleRead
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: coalesced
(40) Sort [codegen id : 13]
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825 ASC NULLS FIRST], false, 0
(41) ReusedExchange [Reuses operator id: 31]
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
(42) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Arguments: 4
(43) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Arguments: coalesced
(44) Sort [codegen id : 14]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930 ASC NULLS FIRST], false, 0
(45) SortMergeJoin [codegen id : 15]
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932))
(46) Filter [codegen id : 15]
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null) > 0.0) END
(47) Project [codegen id : 15]
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
(48) HashAggregate [codegen id : 15]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#577530L]
Results [1]: [count#577531L]
(49) Exchange
Input [1]: [count#577531L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=386257]
(50) ShuffleQueryStage
Output [1]: [count#577531L]
Arguments: 8
(51) HashAggregate [codegen id : 16]
Input [1]: [count#577531L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#577527L]
Results [1]: [count(1)#577527L AS count#577528L]
(52) Project
Output [6]: [ipp#575958 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, iep#575959 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, code_acte#575960 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, code_spe#575961 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, date_acte#575962 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, parcours#575964 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Input [6]: [ipp#575958, iep#575959, code_acte#575960, code_spe#575961, date_acte#575962, parcours#575964]
(53) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, 10), ENSURE_REQUIREMENTS, [plan_id=385472]
(54) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST], false, 0
(55) Filter
Input [3]: [ipp#575877, iep#575878, statut#575882]
Condition : (isnotnull(iep#575878) AND isnotnull(ipp#575877))
(56) Project
Output [3]: [iep#575878 AS COURRIERS_FICTI_227799__IEP#576283, ipp#575877 AS COURRIERS_FICTI_227799__IPP#576284, statut#575882 AS COURRIERS_FICTI_227799__STATUT#576285]
Input [3]: [ipp#575877, iep#575878, statut#575882]
(57) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, 10), ENSURE_REQUIREMENTS, [plan_id=385473]
(58) Sort
Input [3]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
Arguments: [COURRIERS_FICTI_227799__IEP#576283 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#576284 ASC NULLS FIRST], false, 0
(59) SortMergeJoin
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284]
Join type: LeftOuter
Join condition: None
(60) Project
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COURRIERS_FICTI_227799__STATUT#576285 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_5106492B_ACCD_4032_975C_75C2C163EB89#576260, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#576263, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COURRIERS_FICTI_227799__IEP#576283, COURRIERS_FICTI_227799__IPP#576284, COURRIERS_FICTI_227799__STATUT#576285]
(61) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, 10), ENSURE_REQUIREMENTS, [plan_id=385479]
(62) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST], false, 0
(63) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 ASC NULLS LAST]
(64) Project
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#576259, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#576262, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#576569]
(65) Project
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#576265, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#576437, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_31435B2E_C261_4915_84A4_88A1109C6780#576735L]
(66) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, 10), ENSURE_REQUIREMENTS, [plan_id=385488]
(67) Sort
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261 ASC NULLS FIRST], false, 0
(68) Filter
Input [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
Condition : ((isnotnull(Code+Acte#576022) AND isnotnull(str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR)))
(69) Project
Output [4]: [Code+Acte#576022 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, str_to_datez(Date_effet#576025, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, str_to_datez(Date_r%C3%A9vocation#576026, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, str_to_dec(str_replace(Montant#576023, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Input [4]: [Code+Acte#576022, Montant#576023, Date_effet#576025, Date_r%C3%A9vocation#576026]
(70) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, 10), ENSURE_REQUIREMENTS, [plan_id=385489]
(71) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849 ASC NULLS FIRST], false, 0
(72) SortMergeJoin
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851))
(73) Project
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#576261, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576849, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576850, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576851, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576852]
(74) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, 10), ENSURE_REQUIREMENTS, [plan_id=385498]
(75) Sort
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825 ASC NULLS FIRST], false, 0
(76) Scan parquet
Output [4]: [Code+Acte#576940, Montant#576941, Date_effet#576943, Date_r%C3%A9vocation#576944]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/B327EFC6_2C56_4F02_941C_F0209F65C43D_f96390024f47ad1fd8d43d92a6c7a982/Region-PUBMET_tarifs_forfait_urgences_(1).xlsx_9f5cc06a8bb7ca4fd2c05636743786ea]
PushedFilters: [IsNotNull(`Code+Acte`)]
ReadSchema: struct<Code+Acte:string,Montant:string,Date_effet:string,Date_r%C3%A9vocation:string>
(77) Filter
Input [4]: [Code+Acte#576940, Montant#576941, Date_effet#576943, Date_r%C3%A9vocation#576944]
Condition : ((isnotnull(Code+Acte#576940) AND isnotnull(str_to_datez(Date_effet#576943, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#576944, dd/MM/yyyy, Europe/Paris, fr_FR)))
(78) Project
Output [4]: [Code+Acte#576940 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, str_to_datez(Date_effet#576943, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, str_to_datez(Date_r%C3%A9vocation#576944, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, str_to_dec(str_replace(Montant#576941, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Input [4]: [Code+Acte#576940, Montant#576941, Date_effet#576943, Date_r%C3%A9vocation#576944]
(79) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, 10), ENSURE_REQUIREMENTS, [plan_id=385499]
(80) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930 ASC NULLS FIRST], false, 0
(81) SortMergeJoin
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932))
(82) Filter
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905)), null) > 0.0) END
(83) Project
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#576439, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#576825, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#576905, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#576930, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#576931, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#576932, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#576933]
(84) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#577530L]
Results [1]: [count#577531L]
(85) Exchange
Input [1]: [count#577531L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=385507]
(86) HashAggregate
Input [1]: [count#577531L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#577527L]
Results [1]: [count(1)#577527L AS count#577528L]
(87) AdaptiveSparkPlan
Output [1]: [count#577528L]
Arguments: isFinalPlan=true