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: 13 ms";
5 [labelType="html" label="<b>HashAggregate</b><br><br>spill size: 0.0 B<br>time in aggregation build: 13 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: 16 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: 9 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: 12 ms";
17 [labelType="html" label="<b>Sort</b><br><br>sort time: 1 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: 22 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: 58 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: 112 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: 125 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: 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: 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: 24 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: 123 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: 28 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 8114.0: task 11044))<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 8114.0: task 11044))<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: 18 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: 7 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=388458]
HashAggregate(keys=[], functions=[partial_count(1)])
Project
Filter CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null) > 0.0) END
SortMergeJoin [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345))
WholeStageCodegen (15)
Sort [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238 ASC NULLS FIRST], false, 0
WholeStageCodegen (13)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, 10), ENSURE_REQUIREMENTS, [plan_id=388371]
Project [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
SortMergeJoin [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264))
WholeStageCodegen (12)
Sort [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674 ASC NULLS FIRST], false, 0
WholeStageCodegen (10)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, 10), ENSURE_REQUIREMENTS, [plan_id=388265]
Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L]
WholeStageCodegen (9)
Window [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST]
Sort [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST], false, 0
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, 10), ENSURE_REQUIREMENTS, [plan_id=388072]
Project [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COURRIERS_FICTI_227799__STATUT#579698 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
SortMergeJoin [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672], [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697], LeftOuter
WholeStageCodegen (7)
Sort [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST], false, 0
WholeStageCodegen (5)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, 10), ENSURE_REQUIREMENTS, [plan_id=387781]
Project [ipp#579371 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, iep#579372 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, code_acte#579373 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, code_spe#579374 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, date_acte#579375 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, parcours#579377 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
WholeStageCodegen (1)
FileScan csv [ipp#579371,iep#579372,code_acte#579373,code_spe#579374,date_acte#579375,parcours#579377] 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#579696 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#579697 ASC NULLS FIRST], false, 0
WholeStageCodegen (6)
AQEShuffleRead coalesced
Exchange hashpartitioning(COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, 10), ENSURE_REQUIREMENTS, [plan_id=387794]
Project [iep#579291 AS COURRIERS_FICTI_227799__IEP#579696, ipp#579290 AS COURRIERS_FICTI_227799__IPP#579697, statut#579295 AS COURRIERS_FICTI_227799__STATUT#579698]
Filter (isnotnull(iep#579291) AND isnotnull(ipp#579290))
WholeStageCodegen (2)
FileScan csv [ipp#579290,iep#579291,statut#579295] Batched: false, DataFilters: [isnotnull(iep#579291), isnotnull(ipp#579290)], 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#580262 ASC NULLS FIRST], false, 0
WholeStageCodegen (11)
AQEShuffleRead coalesced
Exchange hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, 10), ENSURE_REQUIREMENTS, [plan_id=387823]
Project [Code+Acte#579435 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, str_to_dec(str_replace(Montant#579436, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Filter ((isnotnull(Code+Acte#579435) AND isnotnull(str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR)))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Code+Acte#579435,Montant#579436,Date_effet#579438,Date_r%C3%A9vocation#579439] Batched: true, DataFilters: [isnotnull(Code+Acte#579435), isnotnull(str_to_datez(Date_effet#579438, 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#580343 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#579371, iep#579372, code_acte#579373, code_spe#579374, date_acte#579375, parcours#579377]
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#579371 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, iep#579372 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, code_acte#579373 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, code_spe#579374 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, date_acte#579375 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, parcours#579377 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Input [6]: [ipp#579371, iep#579372, code_acte#579373, code_spe#579374, date_acte#579375, parcours#579377]
(3) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, 10), ENSURE_REQUIREMENTS, [plan_id=387781]
(4) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: 0
(5) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: coalesced
(6) Sort [codegen id : 5]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST], false, 0
(7) Scan csv
Output [3]: [ipp#579290, iep#579291, statut#579295]
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#579290, iep#579291, statut#579295]
Condition : (isnotnull(iep#579291) AND isnotnull(ipp#579290))
(9) Project [codegen id : 2]
Output [3]: [iep#579291 AS COURRIERS_FICTI_227799__IEP#579696, ipp#579290 AS COURRIERS_FICTI_227799__IPP#579697, statut#579295 AS COURRIERS_FICTI_227799__STATUT#579698]
Input [3]: [ipp#579290, iep#579291, statut#579295]
(10) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, 10), ENSURE_REQUIREMENTS, [plan_id=387794]
(11) ShuffleQueryStage
Output [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: 1
(12) AQEShuffleRead
Input [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: coalesced
(13) Sort [codegen id : 6]
Input [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: [COURRIERS_FICTI_227799__IEP#579696 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#579697 ASC NULLS FIRST], false, 0
(14) SortMergeJoin [codegen id : 7]
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697]
Join type: LeftOuter
Join condition: None
(15) Project [codegen id : 7]
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COURRIERS_FICTI_227799__STATUT#579698 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
(16) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, 10), ENSURE_REQUIREMENTS, [plan_id=388072]
(17) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: 5
(18) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: coalesced
(19) Sort [codegen id : 8]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST], false, 0
(20) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST]
(21) Project [codegen id : 9]
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982]
(22) Project [codegen id : 9]
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L]
(23) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, 10), ENSURE_REQUIREMENTS, [plan_id=388265]
(24) ShuffleQueryStage
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: 6
(25) AQEShuffleRead
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: coalesced
(26) Sort [codegen id : 10]
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674 ASC NULLS FIRST], false, 0
(27) Scan parquet
Output [4]: [Code+Acte#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
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#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
(29) Filter [codegen id : 3]
Input [4]: [Code+Acte#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
Condition : ((isnotnull(Code+Acte#579435) AND isnotnull(str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR)))
(30) Project [codegen id : 3]
Output [4]: [Code+Acte#579435 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, str_to_dec(str_replace(Montant#579436, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Input [4]: [Code+Acte#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
(31) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, 10), ENSURE_REQUIREMENTS, [plan_id=387823]
(32) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: 2
(33) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: coalesced
(34) Sort [codegen id : 11]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262 ASC NULLS FIRST], false, 0
(35) SortMergeJoin [codegen id : 12]
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264))
(36) Project [codegen id : 12]
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
(37) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, 10), ENSURE_REQUIREMENTS, [plan_id=388371]
(38) ShuffleQueryStage
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: 7
(39) AQEShuffleRead
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: coalesced
(40) Sort [codegen id : 13]
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238 ASC NULLS FIRST], false, 0
(41) ReusedExchange [Reuses operator id: 31]
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
(42) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Arguments: 4
(43) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Arguments: coalesced
(44) Sort [codegen id : 14]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343 ASC NULLS FIRST], false, 0
(45) SortMergeJoin [codegen id : 15]
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345))
(46) Filter [codegen id : 15]
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null) > 0.0) END
(47) Project [codegen id : 15]
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
(48) HashAggregate [codegen id : 15]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#580943L]
Results [1]: [count#580944L]
(49) Exchange
Input [1]: [count#580944L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=388458]
(50) ShuffleQueryStage
Output [1]: [count#580944L]
Arguments: 8
(51) HashAggregate [codegen id : 16]
Input [1]: [count#580944L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#580940L]
Results [1]: [count(1)#580940L AS count#580941L]
(52) Project
Output [6]: [ipp#579371 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, iep#579372 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, code_acte#579373 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, code_spe#579374 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, date_acte#579375 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, parcours#579377 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Input [6]: [ipp#579371, iep#579372, code_acte#579373, code_spe#579374, date_acte#579375, parcours#579377]
(53) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, 10), ENSURE_REQUIREMENTS, [plan_id=387673]
(54) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST], false, 0
(55) Filter
Input [3]: [ipp#579290, iep#579291, statut#579295]
Condition : (isnotnull(iep#579291) AND isnotnull(ipp#579290))
(56) Project
Output [3]: [iep#579291 AS COURRIERS_FICTI_227799__IEP#579696, ipp#579290 AS COURRIERS_FICTI_227799__IPP#579697, statut#579295 AS COURRIERS_FICTI_227799__STATUT#579698]
Input [3]: [ipp#579290, iep#579291, statut#579295]
(57) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, 10), ENSURE_REQUIREMENTS, [plan_id=387674]
(58) Sort
Input [3]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
Arguments: [COURRIERS_FICTI_227799__IEP#579696 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#579697 ASC NULLS FIRST], false, 0
(59) SortMergeJoin
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697]
Join type: LeftOuter
Join condition: None
(60) Project
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COURRIERS_FICTI_227799__STATUT#579698 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_5106492B_ACCD_4032_975C_75C2C163EB89#579673, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#579676, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COURRIERS_FICTI_227799__IEP#579696, COURRIERS_FICTI_227799__IPP#579697, COURRIERS_FICTI_227799__STATUT#579698]
(61) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, 10), ENSURE_REQUIREMENTS, [plan_id=387680]
(62) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST], false, 0
(63) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 ASC NULLS LAST]
(64) Project
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#579672, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#579675, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#579982]
(65) Project
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#579678, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#579850, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_31435B2E_C261_4915_84A4_88A1109C6780#580148L]
(66) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, 10), ENSURE_REQUIREMENTS, [plan_id=387689]
(67) Sort
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674 ASC NULLS FIRST], false, 0
(68) Filter
Input [4]: [Code+Acte#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
Condition : ((isnotnull(Code+Acte#579435) AND isnotnull(str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR)))
(69) Project
Output [4]: [Code+Acte#579435 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, str_to_datez(Date_effet#579438, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, str_to_datez(Date_r%C3%A9vocation#579439, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, str_to_dec(str_replace(Montant#579436, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Input [4]: [Code+Acte#579435, Montant#579436, Date_effet#579438, Date_r%C3%A9vocation#579439]
(70) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, 10), ENSURE_REQUIREMENTS, [plan_id=387690]
(71) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262 ASC NULLS FIRST], false, 0
(72) SortMergeJoin
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264))
(73) Project
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#579674, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580262, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580263, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580264, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580265]
(74) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, 10), ENSURE_REQUIREMENTS, [plan_id=387699]
(75) Sort
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238 ASC NULLS FIRST], false, 0
(76) Scan parquet
Output [4]: [Code+Acte#580353, Montant#580354, Date_effet#580356, Date_r%C3%A9vocation#580357]
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#580353, Montant#580354, Date_effet#580356, Date_r%C3%A9vocation#580357]
Condition : ((isnotnull(Code+Acte#580353) AND isnotnull(str_to_datez(Date_effet#580356, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#580357, dd/MM/yyyy, Europe/Paris, fr_FR)))
(78) Project
Output [4]: [Code+Acte#580353 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, str_to_datez(Date_effet#580356, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, str_to_datez(Date_r%C3%A9vocation#580357, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, str_to_dec(str_replace(Montant#580354, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Input [4]: [Code+Acte#580353, Montant#580354, Date_effet#580356, Date_r%C3%A9vocation#580357]
(79) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, 10), ENSURE_REQUIREMENTS, [plan_id=387700]
(80) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343 ASC NULLS FIRST], false, 0
(81) SortMergeJoin
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345))
(82) Filter
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318)), null) > 0.0) END
(83) Project
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#579852, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#580238, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#580318, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#580343, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#580344, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#580345, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#580346]
(84) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#580943L]
Results [1]: [count#580944L]
(85) Exchange
Input [1]: [count#580944L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=387708]
(86) HashAggregate
Input [1]: [count#580944L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#580940L]
Results [1]: [count(1)#580940L AS count#580941L]
(87) AdaptiveSparkPlan
Output [1]: [count#580941L]
Arguments: isFinalPlan=true