SP1 - Details for Query 4056

Submitted Time: 2026/10/15 14:15:32
Duration: 1 s
Succeeded Jobs: 6294 6295 6296 6297 6298 6303

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: 14 ms number of output rows: 321 number of dynamic part: 0 written output: 12.4 KiB"]; 2 [labelType="html" label=" WriteFiles "]; subgraph cluster3 { isCluster="true"; label="WholeStageCodegen (13)\n \nduration: 276 ms"; 4 [labelType="html" label=" Project "]; 5 [labelType="html" label=" Project "]; 6 [labelType="html" label="Filter number of output rows: 321"]; 7 [labelType="html" label="SortMergeJoin number of output rows: 38,684 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (11)\n \nduration: 322 ms"; 9 [labelType="html" label="Sort sort time: 1 ms peak memory: 17.0 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 1305.5 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 38,684 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 5 ms (2 ms, 3 ms, 3 ms (stage 12821.0: task 16864)) 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: 38,684 local bytes read: 1212.4 KiB fetch wait time: 0 ms 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 total (min, med, max (stageId: taskId)) 5.7 MiB (2.9 MiB, 2.9 MiB, 2.9 MiB (stage 12821.0: task 16864)) 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)) 1212.4 KiB (604.6 KiB, 607.8 KiB, 607.8 KiB (stage 12821.0: task 16864))"]; subgraph cluster12 { isCluster="true"; label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n217 ms (90 ms, 127 ms, 127 ms (stage 12821.0: task 16864))"; 13 [labelType="html" label=" Project "]; 14 [labelType="html" label="SortMergeJoin number of output rows: 38,684 spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 12821.0: task 16865))"]; } subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; 16 [labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 10 ms (5 ms, 5 ms, 5 ms (stage 12821.0: task 16865)) peak memory total (min, med, max (stageId: taskId)) 34.0 MiB (17.0 MiB, 17.0 MiB, 17.0 MiB (stage 12821.0: task 16865)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 12821.0: task 16865))"]; } 17 [labelType="html" label="AQEShuffleRead number of partitions: 2 partition data size total (min, med, max (stageId: taskId)) 674.0 KiB (333.9 KiB, 340.1 KiB, 340.1 KiB (driver)) number of coalesced partitions: 2"]; 18 [labelType="html" label="Exchange shuffle records written: 73,164 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: 73,164 local bytes read total (min, med, max (stageId: taskId)) 628.8 KiB (314.0 KiB, 314.9 KiB, 314.9 KiB (stage 12821.0: task 16865)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 12821.0: task 16865)) 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: 5.3 MiB 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: 628.8 KiB"]; subgraph cluster19 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 93 ms"; 20 [labelType="html" label=" Project "]; } 21 [labelType="html" label="CartesianProduct number of output rows: 73,164"]; subgraph cluster22 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 94 ms"; 23 [labelType="html" label=" Project "]; 24 [labelType="html" label="Filter number of output rows: 73,164"]; } 25 [labelType="html" label="Window spill size: 0.0 B"]; subgraph cluster26 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 157 ms"; 27 [labelType="html" label="Sort sort time: 27 ms peak memory: 18.0 MiB spill size: 0.0 B"]; } 28 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 741.5 KiB number of coalesced partitions: 1"]; 29 [labelType="html" label="Exchange shuffle records written: 73,164 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 4 ms (2 ms, 2 ms, 2 ms (stage 12813.0: task 16850)) 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: 73,164 local bytes read: 696.6 KiB fetch wait time: 0 ms 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 total (min, med, max (stageId: taskId)) 4.2 MiB (1074.6 KiB, 3.2 MiB, 3.2 MiB (stage 12813.0: task 16850)) 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)) 696.6 KiB (173.7 KiB, 523.0 KiB, 523.0 KiB (stage 12813.0: task 16850))"]; subgraph cluster30 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n266 ms (81 ms, 185 ms, 185 ms (stage 12813.0: task 16850))"; 31 [labelType="html" label=" Project "]; 32 [labelType="html" label="Filter number of output rows: 73,164"]; } 33 [labelType="html" label="Scan csv number of output rows: 73,164 number of files read: 1 metadata time: 0 ms size of files read: 5.3 MiB"]; subgraph cluster34 { isCluster="true"; label="WholeStageCodegen (6)\n \nduration: 6 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: total (min, med, max (stageId: taskId))\n436 ms (182 ms, 254 ms, 254 ms (stage 12821.0: task 16864))"; 39 [labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 13 ms (4 ms, 9 ms, 9 ms (stage 12821.0: task 16864)) peak memory total (min, med, max (stageId: taskId)) 33.0 MiB (16.5 MiB, 16.5 MiB, 16.5 MiB (stage 12821.0: task 16865)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 12821.0: task 16865))"]; } 40 [labelType="html" label="AQEShuffleRead number of partitions: 2 partition data size total (min, med, max (stageId: taskId)) 1388.2 KiB (690.7 KiB, 697.4 KiB, 697.4 KiB (driver)) number of coalesced partitions: 2"]; 41 [labelType="html" label="Exchange shuffle records written: 38,684 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 31 ms (1 ms, 3 ms, 4 ms (stage 12814.0: task 16859)) 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: 38,684 local bytes read total (min, med, max (stageId: taskId)) 1323.9 KiB (660.5 KiB, 663.4 KiB, 663.4 KiB (stage 12821.0: task 16864)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 12821.0: task 16865)) remote bytes read: 0.0 B merged fetch fallback count: 0 local blocks read: 20 remote merged chunks fetched: 0 remote blocks read: 0 data size total (min, med, max (stageId: taskId)) 4.0 MiB (406.7 KiB, 411.3 KiB, 416.9 KiB (stage 12814.0: task 16852)) 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)) 1323.9 KiB (131.0 KiB, 132.4 KiB, 133.8 KiB (stage 12814.0: task 16852))"]; subgraph cluster42 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n208 ms (7 ms, 21 ms, 37 ms (stage 12814.0: task 16856))"; 43 [labelType="html" label=" Project "]; 44 [labelType="html" label="Filter number of output rows: 38,684"]; 45 [labelType="html" label="ColumnarToRow number of output rows: 38,684 number of input batches: 10"]; } 46 [labelType="html" label="Scan parquet number of files read: 10 scan time total (min, med, max (stageId: taskId)) 117 ms (3 ms, 13 ms, 27 ms (stage 12814.0: task 16856)) metadata time: 0 ms size of files read: 6.0 MiB number of output rows: 38,684"]; subgraph cluster47 { isCluster="true"; label="WholeStageCodegen (12)\n \nduration: 1.91 h"; 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: 312.0 B number of coalesced partitions: 1"]; 50 [labelType="html" label="Exchange shuffle records written: 4 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: 4 local bytes read: 296.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: 120.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: 296.0 B"]; subgraph cluster51 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 2 ms"; 52 [labelType="html" label=" Project "]; 53 [labelType="html" label="Filter number of output rows: 4"]; 54 [labelType="html" label="ColumnarToRow number of output rows: 4 number of input batches: 1"]; } 55 [labelType="html" label="Scan parquet number of files read: 1 scan time: 1 ms metadata time: 0 ms size of files read: 1648.0 B number of output rows: 4"]; 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_234822, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_234822], 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#938311, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#939046, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#939049]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906]

Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) <=> ))

SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313], [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761], LeftOuter

WholeStageCodegen (13)

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

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 10), ENSURE_REQUIREMENTS, [plan_id=616777]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]

SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311], [03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451], Inner

WholeStageCodegen (10)

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

WholeStageCodegen (8)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, 10), ENSURE_REQUIREMENTS, [plan_id=616317]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]

WholeStageCodegen (7)

CartesianProduct

Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313]

Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158 <=> 1)

WholeStageCodegen (5)

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

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

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, 10), ENSURE_REQUIREMENTS, [plan_id=615913]

Project [Numéro Séjour#938026 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, str_remove_space(Transport admission#938030, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]

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

WholeStageCodegen (1)

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

Project [APPLICABLE#936072 AS REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321]

Filter ((isnotnull(REGLES#936071) AND (RC-SUM = REGLES#936071)) AND (APPLICABLE#936072 <=> O))

WholeStageCodegen (6)

FileScan csv [REGLES#936071,APPLICABLE#936072] Batched: false, DataFilters: [isnotnull(REGLES#936071), (RC-SUM = REGLES#936071), (APPLICABLE#936072 <=> O)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/REGLES_APPLICAB_234572/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_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451 ASC NULLS FIRST], false, 0

WholeStageCodegen (9)

AQEShuffleRead coalesced

Exchange hashpartitioning(03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 10), ENSURE_REQUIREMENTS, [plan_id=615940]

Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210 AS 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214 AS 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215 AS 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222 AS 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]

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

ColumnarToRow

WholeStageCodegen (2)

FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215,COL_60F7C888_9836_4535_A22F_D43D2994E019#938222] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210), NOT CASE WHEN isnull(StartsWith(COL_..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_234720], 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_234677_TRANSPORT_UTILI_234678#938761 ASC NULLS FIRST], false, 0

WholeStageCodegen (12)

AQEShuffleRead coalesced

Exchange hashpartitioning(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761, 10), ENSURE_REQUIREMENTS, [plan_id=615972]

Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#931804, ONLY_ONE) AS 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]

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

ColumnarToRow

WholeStageCodegen (3)

FileScan parquet [Transport+utilis%C3%A9+%C3%A0+l%27admission#931804] Batched: true, DataFilters: [isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#931804, ONLY_ONE))], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/06_ENTREE_URGEN_234577_d6fde8acf96a..., 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=5.7 MiB, rowCount=3.87E+4)
                  :        +- Exchange (30)
                  :           +- * Project (29)
                  :              +- * SortMergeJoin Inner (28)
                  :                 :- * Sort (19)
                  :                 :  +- AQEShuffleRead (18)
                  :                 :     +- ShuffleQueryStage (17), Statistics(sizeInBytes=5.3 MiB, rowCount=7.32E+4)
                  :                 :        +- Exchange (16)
                  :                 :           +- * Project (15)
                  :                 :              +- CartesianProduct Inner (14)
                  :                 :                 :- * Project (10)
                  :                 :                 :  +- * Filter (9)
                  :                 :                 :     +- Window (8)
                  :                 :                 :        +- * Sort (7)
                  :                 :                 :           +- AQEShuffleRead (6)
                  :                 :                 :              +- ShuffleQueryStage (5), Statistics(sizeInBytes=4.2 MiB, rowCount=7.32E+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=4.0 MiB, rowCount=3.87E+4)
                  :                          +- Exchange (24)
                  :                             +- * Project (23)
                  :                                +- * Filter (22)
                  :                                   +- * ColumnarToRow (21)
                  :                                      +- Scan parquet  (20)
                  +- * Sort (41)
                     +- AQEShuffleRead (40)
                        +- ShuffleQueryStage (39), Statistics(sizeInBytes=120.0 B, rowCount=4)
                           +- 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#938026, Transport admission#938030]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_234565/passage_Patient_Argentueil_M122026.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#938026, Transport admission#938030]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#938026, #)) THEN false ELSE StartsWith(Numéro Séjour#938026, #) END AND isnotnull(Numéro Séjour#938026))

(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#938026 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, str_remove_space(Transport admission#938030, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Input [2]: [Numéro Séjour#938026, Transport admission#938030]

(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, 10), ENSURE_REQUIREMENTS, [plan_id=615913]

(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Arguments: 0

(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Arguments: coalesced

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

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

(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158 <=> 1)

(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158]

(11) Scan csv 
Output [2]: [REGLES#936071, APPLICABLE#936072]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_234572/REGLES-A-TTT new.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#936071, APPLICABLE#936072]
Condition : ((isnotnull(REGLES#936071) AND (RC-SUM = REGLES#936071)) AND (APPLICABLE#936072 <=> O))

(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#936072 AS REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321]
Input [2]: [REGLES#936071, APPLICABLE#936072]

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

(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321]

(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, 10), ENSURE_REQUIREMENTS, [plan_id=616317]

(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: 3

(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: coalesced

(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311 ASC NULLS FIRST], false, 0

(20) Scan parquet 
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_234720]
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#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]

(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214))

(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210 AS 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214 AS 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215 AS 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222 AS 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]

(24) Exchange
Input [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: hashpartitioning(03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 10), ENSURE_REQUIREMENTS, [plan_id=615940]

(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: 1

(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: coalesced

(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: [03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451 ASC NULLS FIRST], false, 0

(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311]
Right keys [1]: [03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451]
Join type: Inner
Join condition: None

(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]

(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 10), ENSURE_REQUIREMENTS, [plan_id=616777]

(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: 4

(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: coalesced

(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313 ASC NULLS FIRST], false, 0

(34) Scan parquet 
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#931804]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/06_ENTREE_URGEN_234577_d6fde8acf96a1590d271789b705e96ed/Info_Etab_init_v1.1 Argenteuil 151026.xlsx_14b7d5b3c7820d86fa14f35038d5fc8b]
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#931804]

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

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

(38) Exchange
Input [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Arguments: hashpartitioning(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761, 10), ENSURE_REQUIREMENTS, [plan_id=615972]

(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Arguments: 2

(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Arguments: coalesced

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

(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313]
Right keys [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Join type: LeftOuter
Join condition: None

(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) <=> ))

(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]

(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#939046, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#939049]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906]

(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#939046, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#939049]

(47) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_234822, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_234822], 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#938026, Transport admission#938030]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#938026, #)) THEN false ELSE StartsWith(Numéro Séjour#938026, #) END AND isnotnull(Numéro Séjour#938026))

(49) Project
Output [2]: [Numéro Séjour#938026 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, str_remove_space(Transport admission#938030, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Input [2]: [Numéro Séjour#938026, Transport admission#938030]

(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, 10), ENSURE_REQUIREMENTS, [plan_id=615836]

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

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

(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158 <=> 1)

(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#938142, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#938144, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#938158]

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

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

(57) Project
Output [1]: [APPLICABLE#936072 AS REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321]
Input [2]: [REGLES#936071, APPLICABLE#936072]

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

(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, REGLES_A_APPLIQ_234699_APPLICABLE_234701#938321]

(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, 10), ENSURE_REQUIREMENTS, [plan_id=615847]

(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311 ASC NULLS FIRST], false, 0

(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214))

(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210 AS 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214 AS 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215 AS 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222 AS 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938210, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938214, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938215, COL_60F7C888_9836_4535_A22F_D43D2994E019#938222]

(64) Exchange
Input [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: hashpartitioning(03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 10), ENSURE_REQUIREMENTS, [plan_id=615848]

(65) Sort
Input [4]: [03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]
Arguments: [03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451 ASC NULLS FIRST], false, 0

(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311]
Right keys [1]: [03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451]
Join type: Inner
Join condition: None

(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 03_PIVOT_INFORM_234720_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#938447, 03_PIVOT_INFORM_234720_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#938451, 03_PIVOT_INFORM_234720_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#938452, 03_PIVOT_INFORM_234720_COL_60F7C888_9836_4535_A22F_D43D2994E019#938459]

(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 10), ENSURE_REQUIREMENTS, [plan_id=615857]

(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313 ASC NULLS FIRST], false, 0

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

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

(72) Exchange
Input [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Arguments: hashpartitioning(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761, 10), ENSURE_REQUIREMENTS, [plan_id=615858]

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

(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313]
Right keys [1]: [06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Join type: LeftOuter
Join condition: None

(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) <=> ))

(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, SUM) END AND isnotnull(06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#938746, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, 06_ENTREE_URGEN_234677_TRANSPORT_UTILI_234678#938761]

(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#939046, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#939049]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#938313, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#938879, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906]

(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#938311, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#938748, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#938906, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#938894, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#939046, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#938749, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#938404, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#939049]

(79) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_234822, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_234822], 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