SP1 - Details for Query 4612

Submitted Time: 2026/05/20 14:35:34
Duration: 0.6 s
Succeeded Jobs: 7224 7225 7226 7227 7228 7229

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

digraph G { 0 [labelType="html" label=" AdaptiveSparkPlan "]; 1 [labelType="html" label="Execute InsertIntoHadoopFsRelationCommand task commit time: 0 ms number of written files: 1 job commit time: 9 ms number of output rows: 0 number of dynamic part: 0 written output: 1459.0 B"]; 2 [labelType="html" label=" WriteFiles "]; subgraph cluster3 { isCluster="true"; label="WholeStageCodegen (13)\n \nduration: 92 ms"; 4 [labelType="html" label=" Project "]; 5 [labelType="html" label=" Project "]; 6 [labelType="html" label="Filter number of output rows: 0"]; 7 [labelType="html" label="SortMergeJoin number of output rows: 10,259 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (11)\n \nduration: 124 ms"; 9 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.3 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 312.0 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 10,259 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: 10,259 local bytes read: 292.3 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: 1455.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: 292.3 KiB"]; subgraph cluster12 { isCluster="true"; label="WholeStageCodegen (10)\n \nduration: 42 ms"; 13 [labelType="html" label=" Project "]; 14 [labelType="html" label="SortMergeJoin number of output rows: 10,259 spill size: 0.0 B"]; } subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 45 ms"; 16 [labelType="html" label="Sort sort time: 3 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 17 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 122.4 KiB number of coalesced partitions: 1"]; 18 [labelType="html" label="Exchange shuffle records written: 15,028 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: 15,028 local bytes read: 116.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: 1043.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: 116.5 KiB"]; subgraph cluster19 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 16 ms"; 20 [labelType="html" label=" Project "]; } 21 [labelType="html" label="CartesianProduct number of output rows: 15,028"]; subgraph cluster22 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 16 ms"; 23 [labelType="html" label=" Project "]; 24 [labelType="html" label="Filter number of output rows: 15,028"]; } 25 [labelType="html" label="Window spill size: 0.0 B"]; subgraph cluster26 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 36 ms"; 27 [labelType="html" label="Sort sort time: 6 ms peak memory: 16.5 MiB spill size: 0.0 B"]; } 28 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 141.3 KiB number of coalesced partitions: 1"]; 29 [labelType="html" label="Exchange shuffle records written: 15,028 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: 15,028 local bytes read: 134.0 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: 808.3 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: 134.0 KiB"]; subgraph cluster30 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 44 ms"; 31 [labelType="html" label=" Project "]; 32 [labelType="html" label="Filter number of output rows: 15,028"]; } 33 [labelType="html" label="Scan csv number of output rows: 15,028 number of files read: 1 metadata time: 0 ms size of files read: 717.1 KiB"]; subgraph cluster34 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 7 ms"; 35 [labelType="html" label=" Project "]; 36 [labelType="html" label="Filter number of output rows: 1"]; } 37 [labelType="html" label="Scan csv number of output rows: 1 number of files read: 1 metadata time: 0 ms size of files read: 175.0 B"]; subgraph cluster38 { isCluster="true"; label="WholeStageCodegen (9)\n \nduration: 43 ms"; 39 [labelType="html" label="Sort sort time: 2 ms peak memory: 16.3 MiB spill size: 0.0 B"]; } 40 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 374.1 KiB number of coalesced partitions: 1"]; 41 [labelType="html" label="Exchange shuffle records written: 10,259 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 43 ms (2 ms, 4 ms, 5 ms (stage 14826.0: task 20629)) 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: 10,259 local bytes read: 354.8 KiB fetch wait time: 0 ms remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 10 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 1059.1 KiB (102.6 KiB, 106.1 KiB, 108.2 KiB (stage 14826.0: task 20630)) 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 total (min, med, max (stageId: taskId)) 354.8 KiB (34.5 KiB, 35.4 KiB, 36.4 KiB (stage 14826.0: task 20628))"]; subgraph cluster42 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n201 ms (8 ms, 24 ms, 26 ms (stage 14826.0: task 20635))"; 43 [labelType="html" label=" Project "]; 44 [labelType="html" label="Filter number of output rows: 10,259"]; 45 [labelType="html" label="ColumnarToRow number of output rows: 10,259 number of input batches: 10"]; } 46 [labelType="html" label="Scan parquet number of files read: 10 scan time total (min, med, max (stageId: taskId)) 91 ms (3 ms, 11 ms, 13 ms (stage 14826.0: task 20635)) metadata time: 0 ms size of files read: 1869.8 KiB number of output rows: 10,259"]; subgraph cluster47 { isCluster="true"; label="WholeStageCodegen (12)\n \nduration: 123 ms"; 48 [labelType="html" label="Sort sort time: 0 ms peak memory: 16.1 MiB spill size: 0.0 B"]; } 49 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 224.0 B number of coalesced partitions: 1"]; 50 [labelType="html" label="Exchange shuffle records written: 3 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 local bytes read: 212.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: 80.0 B 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: 212.0 B"]; subgraph cluster51 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 4 ms"; 52 [labelType="html" label=" Project "]; 53 [labelType="html" label="Filter number of output rows: 3"]; 54 [labelType="html" label="ColumnarToRow number of output rows: 3 number of input batches: 1"]; } 55 [labelType="html" label="Scan parquet number of files read: 1 scan time: 2 ms metadata time: 0 ms size of files read: 1533.0 B number of output rows: 3"]; 1->0; 2->1; 4->2; 5->4; 6->5; 7->6; 9->7; 10->9; 11->10; 13->11; 14->13; 16->14; 17->16; 18->17; 20->18; 21->20; 23->21; 24->23; 25->24; 27->25; 28->27; 29->28; 31->29; 32->31; 33->32; 35->21; 36->35; 37->36; 39->14; 40->39; 41->40; 43->41; 44->43; 45->44; 46->45; 48->7; 49->48; 50->49; 52->50; 53->52; 54->53; 55->54; }

AdaptiveSparkPlan isFinalPlan=true

Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/datablock/05_GR4_SUM_172330, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_172330], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]

WriteFiles

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1157859, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1157862]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749]

Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) <=> ))

SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370], [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664], LeftOuter

WholeStageCodegen (13)

Sort [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370 ASC NULLS FIRST], false, 0

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 10), ENSURE_REQUIREMENTS, [plan_id=656791]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]

SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368], [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477], Inner

WholeStageCodegen (10)

Sort [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368 ASC NULLS FIRST], false, 0

WholeStageCodegen (8)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, 10), ENSURE_REQUIREMENTS, [plan_id=656679]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]

WholeStageCodegen (7)

CartesianProduct

Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370]

Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877 <=> 1)

WholeStageCodegen (5)

Window [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859], [1 DESC NULLS LAST]

Sort [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 10), ENSURE_REQUIREMENTS, [plan_id=656404]

Project [Numéro Séjour#1146639 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, str_remove_space(Transport admission#1146643, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]

Filter (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1146639, #)) THEN false ELSE StartsWith(Numéro Séjour#1146639, #) END AND isnotnull(Numéro Séjour#1146639))

WholeStageCodegen (1)

FileScan csv [Numéro Séjour#1146639,Transport admission#1146643] Batched: false, DataFilters: [NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1146639, #)) THEN false ELSE StartsWith(Numéro Séj..., Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_172095/passage_Patient_..., PartitionFilters: [], PushedFilters: [IsNotNull(Numéro Séjour)], ReadSchema: struct<Numéro Séjour:string,Transport admission:string>

Project [APPLICABLE#1157326 AS REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378]

Filter ((isnotnull(REGLES#1157325) AND (RC-SUM = REGLES#1157325)) AND (APPLICABLE#1157326 <=> O))

WholeStageCodegen (6)

FileScan csv [REGLES#1157325,APPLICABLE#1157326] Batched: false, DataFilters: [isnotnull(REGLES#1157325), (RC-SUM = REGLES#1157325), (APPLICABLE#1157326 <=> O)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/REGLES_APPLICAB_172102/REGLES-A-TTT new..., PartitionFilters: [], PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)], ReadSchema: struct<REGLES:string,APPLICABLE:string>

Sort [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477 ASC NULLS FIRST], false, 0

WholeStageCodegen (9)

AQEShuffleRead coalesced

Exchange hashpartitioning(03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 10), ENSURE_REQUIREMENTS, [plan_id=656431]

Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983 AS 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987 AS 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988 AS 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995 AS 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]

Filter ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987))

ColumnarToRow

WholeStageCodegen (2)

FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988,COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983), NOT CASE WHEN isnull(StartsWith(COL..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_172408], PartitionFilters: [], PushedFilters: [IsNotNull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F), IsNotNull(COL_582B8737_1AAE_44AC_AF57_EB71A..., ReadSchema: struct<COL_F1E7803C_F059_4667_8E32_963E2B3DA65F:string,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8:s...

Sort [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 ASC NULLS FIRST], false, 0

WholeStageCodegen (12)

AQEShuffleRead coalesced

Exchange hashpartitioning(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664, 10), ENSURE_REQUIREMENTS, [plan_id=656463]

Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE) AS 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]

Filter isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE))

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846] Batched: true, DataFilters: [isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE))], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/06_ENTREE_URGEN_172108_a2e0287aacc0..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Transport+utilis%C3%A9+%C3%A0+l%27admission:string>

Details

== Physical Plan ==
AdaptiveSparkPlan (80)
+- == Final Plan ==
   Execute InsertIntoHadoopFsRelationCommand (47)
   +- WriteFiles (46)
      +- * Project (45)
         +- * Project (44)
            +- * Filter (43)
               +- * SortMergeJoin LeftOuter (42)
                  :- * Sort (33)
                  :  +- AQEShuffleRead (32)
                  :     +- ShuffleQueryStage (31), Statistics(sizeInBytes=1455.0 KiB, rowCount=1.03E+4)
                  :        +- Exchange (30)
                  :           +- * Project (29)
                  :              +- * SortMergeJoin Inner (28)
                  :                 :- * Sort (19)
                  :                 :  +- AQEShuffleRead (18)
                  :                 :     +- ShuffleQueryStage (17), Statistics(sizeInBytes=1043.1 KiB, rowCount=1.50E+4)
                  :                 :        +- Exchange (16)
                  :                 :           +- * Project (15)
                  :                 :              +- CartesianProduct Inner (14)
                  :                 :                 :- * Project (10)
                  :                 :                 :  +- * Filter (9)
                  :                 :                 :     +- Window (8)
                  :                 :                 :        +- * Sort (7)
                  :                 :                 :           +- AQEShuffleRead (6)
                  :                 :                 :              +- ShuffleQueryStage (5), Statistics(sizeInBytes=808.3 KiB, rowCount=1.50E+4)
                  :                 :                 :                 +- Exchange (4)
                  :                 :                 :                    +- * Project (3)
                  :                 :                 :                       +- * Filter (2)
                  :                 :                 :                          +- Scan csv  (1)
                  :                 :                 +- * Project (13)
                  :                 :                    +- * Filter (12)
                  :                 :                       +- Scan csv  (11)
                  :                 +- * Sort (27)
                  :                    +- AQEShuffleRead (26)
                  :                       +- ShuffleQueryStage (25), Statistics(sizeInBytes=1059.1 KiB, rowCount=1.03E+4)
                  :                          +- Exchange (24)
                  :                             +- * Project (23)
                  :                                +- * Filter (22)
                  :                                   +- * ColumnarToRow (21)
                  :                                      +- Scan parquet  (20)
                  +- * Sort (41)
                     +- AQEShuffleRead (40)
                        +- ShuffleQueryStage (39), Statistics(sizeInBytes=80.0 B, rowCount=3)
                           +- Exchange (38)
                              +- * Project (37)
                                 +- * Filter (36)
                                    +- * ColumnarToRow (35)
                                       +- Scan parquet  (34)
+- == Initial Plan ==
   Execute InsertIntoHadoopFsRelationCommand (79)
   +- WriteFiles (78)
      +- Project (77)
         +- Project (76)
            +- Filter (75)
               +- SortMergeJoin LeftOuter (74)
                  :- Sort (69)
                  :  +- Exchange (68)
                  :     +- Project (67)
                  :        +- SortMergeJoin Inner (66)
                  :           :- Sort (61)
                  :           :  +- Exchange (60)
                  :           :     +- Project (59)
                  :           :        +- CartesianProduct Inner (58)
                  :           :           :- Project (54)
                  :           :           :  +- Filter (53)
                  :           :           :     +- Window (52)
                  :           :           :        +- Sort (51)
                  :           :           :           +- Exchange (50)
                  :           :           :              +- Project (49)
                  :           :           :                 +- Filter (48)
                  :           :           :                    +- Scan csv  (1)
                  :           :           +- Project (57)
                  :           :              +- Filter (56)
                  :           :                 +- Scan csv  (55)
                  :           +- Sort (65)
                  :              +- Exchange (64)
                  :                 +- Project (63)
                  :                    +- Filter (62)
                  :                       +- Scan parquet  (20)
                  +- Sort (73)
                     +- Exchange (72)
                        +- Project (71)
                           +- Filter (70)
                              +- Scan parquet  (34)


(1) Scan csv 
Output [2]: [Numéro Séjour#1146639, Transport admission#1146643]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_172095/passage_Patient_Aigle_M12025.csv]
PushedFilters: [IsNotNull(Numéro Séjour)]
ReadSchema: struct<Numéro Séjour:string,Transport admission:string>

(2) Filter [codegen id : 1]
Input [2]: [Numéro Séjour#1146639, Transport admission#1146643]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1146639, #)) THEN false ELSE StartsWith(Numéro Séjour#1146639, #) END AND isnotnull(Numéro Séjour#1146639))

(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#1146639 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, str_remove_space(Transport admission#1146643, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Input [2]: [Numéro Séjour#1146639, Transport admission#1146643]

(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 10), ENSURE_REQUIREMENTS, [plan_id=656404]

(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: 0

(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: coalesced

(7) Sort [codegen id : 4]
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

(8) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859], [1 DESC NULLS LAST]

(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877 <=> 1)

(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877]

(11) Scan csv 
Output [2]: [REGLES#1157325, APPLICABLE#1157326]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_172102/REGLES-A-TTT new Aigle.csv]
PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)]
ReadSchema: struct<REGLES:string,APPLICABLE:string>

(12) Filter [codegen id : 6]
Input [2]: [REGLES#1157325, APPLICABLE#1157326]
Condition : ((isnotnull(REGLES#1157325) AND (RC-SUM = REGLES#1157325)) AND (APPLICABLE#1157326 <=> O))

(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#1157326 AS REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378]
Input [2]: [REGLES#1157325, APPLICABLE#1157326]

(14) CartesianProduct
Join type: Inner
Join condition: None

(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378]

(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, 10), ENSURE_REQUIREMENTS, [plan_id=656679]

(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: 3

(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: coalesced

(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368 ASC NULLS FIRST], false, 0

(20) Scan parquet 
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_172408]
PushedFilters: [IsNotNull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F), IsNotNull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8)]
ReadSchema: struct<COL_F1E7803C_F059_4667_8E32_963E2B3DA65F:string,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8:string,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46:string,COL_60F7C888_9836_4535_A22F_D43D2994E019:string>

(21) ColumnarToRow [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]

(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987))

(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983 AS 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987 AS 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988 AS 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995 AS 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]

(24) Exchange
Input [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: hashpartitioning(03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 10), ENSURE_REQUIREMENTS, [plan_id=656431]

(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: 1

(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: coalesced

(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477 ASC NULLS FIRST], false, 0

(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368]
Right keys [1]: [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477]
Join type: Inner
Join condition: None

(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]

(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 10), ENSURE_REQUIREMENTS, [plan_id=656791]

(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: 4

(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: coalesced

(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370 ASC NULLS FIRST], false, 0

(34) Scan parquet 
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/06_ENTREE_URGEN_172108_a2e0287aacc0ec6c16e62679da21d1c5/Info_Etab_init_v1.1 Aigle.xlsx_6344e904bcd863365d0e53a76a69cdc9]
ReadSchema: struct<Transport+utilis%C3%A9+%C3%A0+l%27admission:string>

(35) ColumnarToRow [codegen id : 3]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]

(36) Filter [codegen id : 3]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE))

(37) Project [codegen id : 3]
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE) AS 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]

(38) Exchange
Input [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: hashpartitioning(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664, 10), ENSURE_REQUIREMENTS, [plan_id=656463]

(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: 2

(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: coalesced

(41) Sort [codegen id : 12]
Input [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 ASC NULLS FIRST], false, 0

(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370]
Right keys [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Join type: LeftOuter
Join condition: None

(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) <=> ))

(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]

(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1157859, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1157862]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749]

(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1157859, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1157862]

(47) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_172330, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_172330], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]

(48) Filter
Input [2]: [Numéro Séjour#1146639, Transport admission#1146643]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1146639, #)) THEN false ELSE StartsWith(Numéro Séjour#1146639, #) END AND isnotnull(Numéro Séjour#1146639))

(49) Project
Output [2]: [Numéro Séjour#1146639 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, str_remove_space(Transport admission#1146643, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Input [2]: [Numéro Séjour#1146639, Transport admission#1146643]

(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 10), ENSURE_REQUIREMENTS, [plan_id=656327]

(51) Sort
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0

(52) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859], [1 DESC NULLS LAST]

(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877 <=> 1)

(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1146859, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1146861, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1146877]

(55) Scan csv 
Output [2]: [REGLES#1157325, APPLICABLE#1157326]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_172102/REGLES-A-TTT new Aigle.csv]
PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)]
ReadSchema: struct<REGLES:string,APPLICABLE:string>

(56) Filter
Input [2]: [REGLES#1157325, APPLICABLE#1157326]
Condition : ((isnotnull(REGLES#1157325) AND (RC-SUM = REGLES#1157325)) AND (APPLICABLE#1157326 <=> O))

(57) Project
Output [1]: [APPLICABLE#1157326 AS REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378]
Input [2]: [REGLES#1157325, APPLICABLE#1157326]

(58) CartesianProduct
Join type: Inner
Join condition: None

(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, REGLES_A_APPLIQ_172230_APPLICABLE_172232#1157378]

(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, 10), ENSURE_REQUIREMENTS, [plan_id=656338]

(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368 ASC NULLS FIRST], false, 0

(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987))

(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983 AS 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987 AS 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988 AS 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995 AS 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1142983, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1142987, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1142988, COL_60F7C888_9836_4535_A22F_D43D2994E019#1142995]

(64) Exchange
Input [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: hashpartitioning(03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 10), ENSURE_REQUIREMENTS, [plan_id=656339]

(65) Sort
Input [4]: [03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]
Arguments: [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477 ASC NULLS FIRST], false, 0

(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368]
Right keys [1]: [03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477]
Join type: Inner
Join condition: None

(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 03_PIVOT_INFORM_172408_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1157473, 03_PIVOT_INFORM_172408_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1157477, 03_PIVOT_INFORM_172408_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1157478, 03_PIVOT_INFORM_172408_COL_60F7C888_9836_4535_A22F_D43D2994E019#1157485]

(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 10), ENSURE_REQUIREMENTS, [plan_id=656348]

(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370 ASC NULLS FIRST], false, 0

(70) Filter
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE))

(71) Project
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846, ONLY_ONE) AS 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1144846]

(72) Exchange
Input [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: hashpartitioning(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664, 10), ENSURE_REQUIREMENTS, [plan_id=656349]

(73) Sort
Input [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Arguments: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 ASC NULLS FIRST], false, 0

(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370]
Right keys [1]: [06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Join type: LeftOuter
Join condition: None

(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) <=> ))

(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, SUM) END AND isnotnull(06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1157649, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, 06_ENTREE_URGEN_172208_TRANSPORT_UTILI_172209#1157664]

(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1157859, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1157862]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1157370, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1157723, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749]

(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1157368, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1157651, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1157749, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1157737, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1157859, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1157652, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1157428, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1157862]

(79) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_172330, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_172330], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]

(80) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true

SQL / DataFrame Properties

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