SP1 - Details for Query 2785

Submitted Time: 2026/10/12 09:42:01
Duration: 0.6 s
Succeeded Jobs: 4230 4231 4232 4233 4234 4235 4236 4237

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; subgraph cluster1 { isCluster="true"; label="WholeStageCodegen (16)\n \nduration: 0 ms"; 2 [labelType="html" label="HashAggregate time in aggregation build: 0 ms number of output rows: 1"]; } 3 [labelType="html" label="Exchange shuffle records written: 1 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 1 local bytes read: 59.0 B fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 16.0 B local merged bytes read: 0.0 B number of partitions: 1 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 59.0 B"]; subgraph cluster4 { isCluster="true"; label="WholeStageCodegen (15)\n \nduration: 7 ms"; 5 [labelType="html" label="HashAggregate spill size: 0.0 B time in aggregation build: 6 ms peak memory: 0.0 B number of output rows: 1 number of sort fallback tasks: 0 avg hash probes per key: 0"]; 6 [labelType="html" label=" Project "]; 7 [labelType="html" label="Filter number of output rows: 243"]; 8 [labelType="html" label="SortMergeJoin number of output rows: 6,213 spill size: 0.0 B"]; } subgraph cluster9 { isCluster="true"; label="WholeStageCodegen (13)\n \nduration: 9 ms"; 10 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.3 MiB spill size: 0.0 B"]; } 11 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 38.4 KiB number of coalesced partitions: 1"]; 12 [labelType="html" label="Exchange shuffle records written: 6,213 local merged chunks fetched: 0 shuffle write time: 0 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 6,213 local bytes read: 36.2 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 196.1 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 36.2 KiB"]; subgraph cluster13 { isCluster="true"; label="WholeStageCodegen (12)\n \nduration: 7 ms"; 14 [labelType="html" label=" Project "]; 15 [labelType="html" label="SortMergeJoin number of output rows: 6,213 spill size: 0.0 B"]; } subgraph cluster16 { isCluster="true"; label="WholeStageCodegen (10)\n \nduration: 10 ms"; 17 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.3 MiB spill size: 0.0 B"]; } 18 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 43.8 KiB number of coalesced partitions: 1"]; 19 [labelType="html" label="Exchange shuffle records written: 6,213 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 6,213 local bytes read: 41.5 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 244.6 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 41.5 KiB"]; subgraph cluster20 { isCluster="true"; label="WholeStageCodegen (9)\n \nduration: 40 ms"; 21 [labelType="html" label=" Project "]; 22 [labelType="html" label=" Project "]; } 23 [labelType="html" label="Window spill size: 0.0 B"]; subgraph cluster24 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 78 ms"; 25 [labelType="html" label="Sort sort time: 3 ms peak memory: 16.3 MiB spill size: 0.0 B"]; } 26 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 100.5 KiB number of coalesced partitions: 1"]; 27 [labelType="html" label="Exchange shuffle records written: 6,213 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 6,213 local bytes read: 95.1 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 581.0 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 95.1 KiB"]; subgraph cluster28 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 86 ms"; 29 [labelType="html" label=" Project "]; 30 [labelType="html" label="SortMergeJoin number of output rows: 6,213 spill size: 0.0 B"]; } subgraph cluster31 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 95 ms"; 32 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 33 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 128.5 KiB number of coalesced partitions: 1"]; 34 [labelType="html" label="Exchange shuffle records written: 4,001 local merged chunks fetched: 0 shuffle write time: 2 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 4,001 local bytes read: 122.2 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 468.9 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 122.2 KiB"]; subgraph cluster35 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 25 ms"; 36 [labelType="html" label=" Project "]; } 37 [labelType="html" label="Scan csv number of output rows: 4,001 number of files read: 1 metadata time: 0 ms size of files read: 219.3 KiB"]; subgraph cluster38 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 94 ms"; 39 [labelType="html" label="Sort sort time: 1 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 40 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 40.9 KiB number of coalesced partitions: 1"]; 41 [labelType="html" label="Exchange shuffle records written: 3,810 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 3,810 local bytes read: 38.5 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 1 remote merged chunks fetched: 0 remote blocks read: 0 data size: 208.4 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 38.5 KiB"]; subgraph cluster42 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: 30 ms"; 43 [labelType="html" label=" Project "]; 44 [labelType="html" label="Filter number of output rows: 3,810"]; } 45 [labelType="html" label="Scan csv number of output rows: 3,810 number of files read: 1 metadata time: 0 ms size of files read: 269.6 KiB"]; subgraph cluster46 { isCluster="true"; label="WholeStageCodegen (11)\n \nduration: 0 ms"; 47 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 48 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 4.2 KiB number of coalesced partitions: 1"]; 49 [labelType="html" label="Exchange shuffle records written: 206 local merged chunks fetched: 0 shuffle write time: 1 ms remote merged bytes read: 0.0 B local merged blocks fetched: 0 corrupt merged block chunks: 0 remote merged reqs duration: 0 ms remote merged blocks fetched: 0 records read: 412 local bytes read total (min, med, max (stageId: taskId)) 8.0 KiB (4.0 KiB, 4.0 KiB, 4.0 KiB (stage 8354.0: task 11128)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 8354.0: task 11128)) remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 2 remote merged chunks fetched: 0 remote blocks read: 0 data size: 9.7 KiB local merged bytes read: 0.0 B number of partitions: 10 remote reqs duration: 0 ms remote bytes read to disk: 0.0 B shuffle bytes written: 4.0 KiB"]; subgraph cluster50 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 12 ms"; 51 [labelType="html" label=" Project "]; 52 [labelType="html" label="Filter number of output rows: 206"]; 53 [labelType="html" label="ColumnarToRow number of output rows: 207 number of input batches: 1"]; } 54 [labelType="html" label="Scan parquet number of files read: 1 scan time: 2 ms metadata time: 0 ms size of files read: 4.6 KiB number of output rows: 207"]; subgraph cluster55 { isCluster="true"; label="WholeStageCodegen (14)\n \nduration: 0 ms"; 56 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 57 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 4.2 KiB 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; }

AdaptiveSparkPlan isFinalPlan=true

HashAggregate(keys=[], functions=[count(1)])

WholeStageCodegen (16)

Exchange SinglePartition, ENSURE_REQUIREMENTS, [plan_id=397307]

HashAggregate(keys=[], functions=[partial_count(1)])

Project

Filter CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null) > 0.0) END

SortMergeJoin [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997))

WholeStageCodegen (15)

Sort [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890 ASC NULLS FIRST], false, 0

WholeStageCodegen (13)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, 10), ENSURE_REQUIREMENTS, [plan_id=397220]

Project [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]

SortMergeJoin [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326], [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914], LeftOuter, ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916))

WholeStageCodegen (12)

Sort [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326 ASC NULLS FIRST], false, 0

WholeStageCodegen (10)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, 10), ENSURE_REQUIREMENTS, [plan_id=397114]

Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, ONLY_ONE), RIGHT, 1), )), ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]

Project [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L]

WholeStageCodegen (9)

Window [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST]

Sort [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST], false, 0

WholeStageCodegen (8)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, 10), ENSURE_REQUIREMENTS, [plan_id=396978]

Project [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COURRIERS_FICTI_227799__STATUT#593350 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]

SortMergeJoin [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324], [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349], LeftOuter

WholeStageCodegen (7)

Sort [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST], false, 0

WholeStageCodegen (5)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, 10), ENSURE_REQUIREMENTS, [plan_id=396615]

Project [ipp#593023 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, iep#593024 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, code_acte#593025 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, code_spe#593026 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, date_acte#593027 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, parcours#593029 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]

WholeStageCodegen (1)

FileScan csv [ipp#593023,iep#593024,code_acte#593025,code_spe#593026,date_acte#593027,parcours#593029] 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#593348 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#593349 ASC NULLS FIRST], false, 0

WholeStageCodegen (6)

AQEShuffleRead coalesced

Exchange hashpartitioning(COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, 10), ENSURE_REQUIREMENTS, [plan_id=396628]

Project [iep#592943 AS COURRIERS_FICTI_227799__IEP#593348, ipp#592942 AS COURRIERS_FICTI_227799__IPP#593349, statut#592947 AS COURRIERS_FICTI_227799__STATUT#593350]

Filter (isnotnull(iep#592943) AND isnotnull(ipp#592942))

WholeStageCodegen (2)

FileScan csv [ipp#592942,iep#592943,statut#592947] Batched: false, DataFilters: [isnotnull(iep#592943), isnotnull(ipp#592942)], 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#593914 ASC NULLS FIRST], false, 0

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, 10), ENSURE_REQUIREMENTS, [plan_id=396657]

Project [Code+Acte#593087 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, str_to_dec(str_replace(Montant#593088, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]

Filter ((isnotnull(Code+Acte#593087) AND isnotnull(str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR)))

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [Code+Acte#593087,Montant#593088,Date_effet#593090,Date_r%C3%A9vocation#593091] Batched: true, DataFilters: [isnotnull(Code+Acte#593087), isnotnull(str_to_datez(Date_effet#593090, 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#593995 ASC NULLS FIRST], false, 0

WholeStageCodegen (14)

AQEShuffleRead coalesced

Details

== 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#593023, iep#593024, code_acte#593025, code_spe#593026, date_acte#593027, parcours#593029]
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#593023 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, iep#593024 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, code_acte#593025 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, code_spe#593026 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, date_acte#593027 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, parcours#593029 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Input [6]: [ipp#593023, iep#593024, code_acte#593025, code_spe#593026, date_acte#593027, parcours#593029]

(3) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, 10), ENSURE_REQUIREMENTS, [plan_id=396615]

(4) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: 0

(5) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: coalesced

(6) Sort [codegen id : 5]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST], false, 0

(7) Scan csv 
Output [3]: [ipp#592942, iep#592943, statut#592947]
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#592942, iep#592943, statut#592947]
Condition : (isnotnull(iep#592943) AND isnotnull(ipp#592942))

(9) Project [codegen id : 2]
Output [3]: [iep#592943 AS COURRIERS_FICTI_227799__IEP#593348, ipp#592942 AS COURRIERS_FICTI_227799__IPP#593349, statut#592947 AS COURRIERS_FICTI_227799__STATUT#593350]
Input [3]: [ipp#592942, iep#592943, statut#592947]

(10) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, 10), ENSURE_REQUIREMENTS, [plan_id=396628]

(11) ShuffleQueryStage
Output [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: 1

(12) AQEShuffleRead
Input [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: coalesced

(13) Sort [codegen id : 6]
Input [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: [COURRIERS_FICTI_227799__IEP#593348 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#593349 ASC NULLS FIRST], false, 0

(14) SortMergeJoin [codegen id : 7]
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349]
Join type: LeftOuter
Join condition: None

(15) Project [codegen id : 7]
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COURRIERS_FICTI_227799__STATUT#593350 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]

(16) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, 10), ENSURE_REQUIREMENTS, [plan_id=396978]

(17) ShuffleQueryStage
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: 5

(18) AQEShuffleRead
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: coalesced

(19) Sort [codegen id : 8]
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST], false, 0

(20) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST]

(21) Project [codegen id : 9]
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634]

(22) Project [codegen id : 9]
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, ONLY_ONE), RIGHT, 1), )),  ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L]

(23) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, 10), ENSURE_REQUIREMENTS, [plan_id=397114]

(24) ShuffleQueryStage
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: 6

(25) AQEShuffleRead
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: coalesced

(26) Sort [codegen id : 10]
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326 ASC NULLS FIRST], false, 0

(27) Scan parquet 
Output [4]: [Code+Acte#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]
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#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]

(29) Filter [codegen id : 3]
Input [4]: [Code+Acte#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]
Condition : ((isnotnull(Code+Acte#593087) AND isnotnull(str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR)))

(30) Project [codegen id : 3]
Output [4]: [Code+Acte#593087 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, str_to_dec(str_replace(Montant#593088, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Input [4]: [Code+Acte#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]

(31) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, 10), ENSURE_REQUIREMENTS, [plan_id=396657]

(32) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: 2

(33) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: coalesced

(34) Sort [codegen id : 11]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914 ASC NULLS FIRST], false, 0

(35) SortMergeJoin [codegen id : 12]
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916))

(36) Project [codegen id : 12]
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]

(37) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, 10), ENSURE_REQUIREMENTS, [plan_id=397220]

(38) ShuffleQueryStage
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: 7

(39) AQEShuffleRead
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: coalesced

(40) Sort [codegen id : 13]
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890 ASC NULLS FIRST], false, 0

(41) ReusedExchange [Reuses operator id: 31]
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]

(42) ShuffleQueryStage
Output [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Arguments: 4

(43) AQEShuffleRead
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Arguments: coalesced

(44) Sort [codegen id : 14]
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995 ASC NULLS FIRST], false, 0

(45) SortMergeJoin [codegen id : 15]
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997))

(46) Filter [codegen id : 15]
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null) > 0.0) END

(47) Project [codegen id : 15]
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]

(48) HashAggregate [codegen id : 15]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#594595L]
Results [1]: [count#594596L]

(49) Exchange
Input [1]: [count#594596L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=397307]

(50) ShuffleQueryStage
Output [1]: [count#594596L]
Arguments: 8

(51) HashAggregate [codegen id : 16]
Input [1]: [count#594596L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#594592L]
Results [1]: [count(1)#594592L AS count#594593L]

(52) Project
Output [6]: [ipp#593023 AS COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, iep#593024 AS COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, code_acte#593025 AS COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, code_spe#593026 AS COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, date_acte#593027 AS COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, parcours#593029 AS COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Input [6]: [ipp#593023, iep#593024, code_acte#593025, code_spe#593026, date_acte#593027, parcours#593029]

(53) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: hashpartitioning(COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, 10), ENSURE_REQUIREMENTS, [plan_id=396507]

(54) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330]
Arguments: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325 ASC NULLS FIRST, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST], false, 0

(55) Filter
Input [3]: [ipp#592942, iep#592943, statut#592947]
Condition : (isnotnull(iep#592943) AND isnotnull(ipp#592942))

(56) Project
Output [3]: [iep#592943 AS COURRIERS_FICTI_227799__IEP#593348, ipp#592942 AS COURRIERS_FICTI_227799__IPP#593349, statut#592947 AS COURRIERS_FICTI_227799__STATUT#593350]
Input [3]: [ipp#592942, iep#592943, statut#592947]

(57) Exchange
Input [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: hashpartitioning(COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, 10), ENSURE_REQUIREMENTS, [plan_id=396508]

(58) Sort
Input [3]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]
Arguments: [COURRIERS_FICTI_227799__IEP#593348 ASC NULLS FIRST, COURRIERS_FICTI_227799__IPP#593349 ASC NULLS FIRST], false, 0

(59) SortMergeJoin
Left keys [2]: [COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324]
Right keys [2]: [COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349]
Join type: LeftOuter
Join condition: None

(60) Project
Output [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COURRIERS_FICTI_227799__STATUT#593350 AS COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, str_to_datez(str_extract(COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, LEFT, 10), dd/MM/yyyy, Europe/Paris, fr_FR) AS COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Input [9]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_5106492B_ACCD_4032_975C_75C2C163EB89#593325, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_4051F7FE_E7A4_46BB_8324_4110A7514371#593328, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COURRIERS_FICTI_227799__IEP#593348, COURRIERS_FICTI_227799__IPP#593349, COURRIERS_FICTI_227799__STATUT#593350]

(61) Exchange
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: hashpartitioning(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, 10), ENSURE_REQUIREMENTS, [plan_id=396514]

(62) Sort
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324 ASC NULLS FIRST, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327 ASC NULLS FIRST, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST], false, 0

(63) Window
Input [6]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504]
Arguments: [lag(COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, -1, null) windowspecdefinition(COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST, specifiedwindowframe(RowFrame, -1, -1)) AS COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634], [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327], [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 ASC NULLS LAST]

(64) Project
Output [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, date_diff(MONTH, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634) AS COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L]
Input [7]: [COL_2481D273_01EA_466C_9500_8360E19AF4FD#593324, COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_C9F5BDA0_9F74_44BD_BE59_2124B410F046#593327, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_A3830018_3F65_4ECA_87D2_DD2D5CB92DD9#593634]

(65) Project
Output [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, str_remove_space(str_if_with_rule((((CASE WHEN isnull(COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L) THEN false ELSE (COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L > 4) END AND CASE WHEN isnull(StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS)) THEN false ELSE StartsWith(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, CS) END) AND (COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502 <=> Validé)) AND (COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330 <=> O)), str_join(array(APC, str_if_with_rule((CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, F) END OR CASE WHEN isnull(Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N)) THEN false ELSE Contains(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, N) END), str_extract(str_remove_space(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, ONLY_ONE), RIGHT, 1), )),  ), null), ONLY_ONE) AS COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Input [5]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_F7466482_6DC2_4D42_A655_77F8A0264B5C#593330, COL_A5D72A2E_03D4_4B92_85C7_7B3DEF22F898#593502, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_31435B2E_C261_4915_84A4_88A1109C6780#593800L]

(66) Exchange
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: hashpartitioning(COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, 10), ENSURE_REQUIREMENTS, [plan_id=396523]

(67) Sort
Input [3]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Arguments: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326 ASC NULLS FIRST], false, 0

(68) Filter
Input [4]: [Code+Acte#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]
Condition : ((isnotnull(Code+Acte#593087) AND isnotnull(str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR)))

(69) Project
Output [4]: [Code+Acte#593087 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, str_to_datez(Date_effet#593090, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, str_to_datez(Date_r%C3%A9vocation#593091, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, str_to_dec(str_replace(Montant#593088, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Input [4]: [Code+Acte#593087, Montant#593088, Date_effet#593090, Date_r%C3%A9vocation#593091]

(70) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, 10), ENSURE_REQUIREMENTS, [plan_id=396524]

(71) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914 ASC NULLS FIRST], false, 0

(72) SortMergeJoin
Left keys [1]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916))

(73) Project
Output [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917 AS COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Input [7]: [COL_21AE0C8E_7400_4993_B2CD_7B7B8C67B612#593326, COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593914, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593915, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593916, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593917]

(74) Exchange
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: hashpartitioning(COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, 10), ENSURE_REQUIREMENTS, [plan_id=396533]

(75) Sort
Input [3]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970]
Arguments: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890 ASC NULLS FIRST], false, 0

(76) Scan parquet 
Output [4]: [Code+Acte#594005, Montant#594006, Date_effet#594008, Date_r%C3%A9vocation#594009]
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#594005, Montant#594006, Date_effet#594008, Date_r%C3%A9vocation#594009]
Condition : ((isnotnull(Code+Acte#594005) AND isnotnull(str_to_datez(Date_effet#594008, dd/MM/yyyy, Europe/Paris, fr_FR))) AND isnotnull(str_to_datez(Date_r%C3%A9vocation#594009, dd/MM/yyyy, Europe/Paris, fr_FR)))

(78) Project
Output [4]: [Code+Acte#594005 AS NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, str_to_datez(Date_effet#594008, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, str_to_datez(Date_r%C3%A9vocation#594009, dd/MM/yyyy, Europe/Paris, fr_FR) AS NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, str_to_dec(str_replace(Montant#594006, ., ,), ##,##) AS NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Input [4]: [Code+Acte#594005, Montant#594006, Date_effet#594008, Date_r%C3%A9vocation#594009]

(79) Exchange
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Arguments: hashpartitioning(NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, 10), ENSURE_REQUIREMENTS, [plan_id=396534]

(80) Sort
Input [4]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Arguments: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995 ASC NULLS FIRST], false, 0

(81) SortMergeJoin
Left keys [1]: [COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890]
Right keys [1]: [NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995]
Join type: LeftOuter
Join condition: ((COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 >= NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996) AND (COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504 <= NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997))

(82) Filter
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]
Condition : CASE WHEN isnull(dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null)) THEN false ELSE (dec_if_with_rule((isnotnull(COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970) AND isnotnull(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998)), dec_diff(array(NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970)), null) > 0.0) END

(83) Project
Output: []
Input [7]: [COL_60FF8B14_AF9B_46D7_8AC7_A4E57CB7EED6#593504, COL_71F90B4F_4662_47F8_8CDC_8D340D91929E#593890, COL_F77763CC_DEA5_48B6_90BB_79BC33B0354C#593970, NOMENCLATURE_TA_227815_COL_379E97DF_7BAF_440C_9E4E_8591EBA1ADA2#593995, NOMENCLATURE_TA_227815_COL_42E31ADD_0D58_4C3A_A5D1_F603C65BA0D5#593996, NOMENCLATURE_TA_227815_COL_F1B40FAE_6290_4F90_AC6C_391899A88964#593997, NOMENCLATURE_TA_227815_COL_7366AAC2_10DF_4BC5_91D6_AB7C50D5C1CA#593998]

(84) HashAggregate
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#594595L]
Results [1]: [count#594596L]

(85) Exchange
Input [1]: [count#594596L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=396542]

(86) HashAggregate
Input [1]: [count#594596L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#594592L]
Results [1]: [count(1)#594592L AS count#594593L]

(87) AdaptiveSparkPlan
Output [1]: [count#594593L]
Arguments: isFinalPlan=true

SQL / DataFrame Properties

Name	Value
spark.sql.optimizer.nestedPredicatePushdown.supportedFileSources	parquet,orc,geoparquet