SP1 - Details for Query 5247

Submitted Time: 2026/05/22 14:22:01
Duration: 2 s
Succeeded Jobs: 8214 8215 8216 8220 8224 8231

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: 852 number of dynamic part: 0 written output: 30.6 KiB"]; 2 [labelType="html" label=" WriteFiles "]; subgraph cluster3 { isCluster="true"; label="WholeStageCodegen (13)\n \nduration: 334 ms"; 4 [labelType="html" label=" Project "]; 5 [labelType="html" label=" Project "]; 6 [labelType="html" label="Filter number of output rows: 852"]; 7 [labelType="html" label="SortMergeJoin number of output rows: 48,385 spill size: 0.0 B"]; } subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (11)\n \nduration: 398 ms"; 9 [labelType="html" label="Sort sort time: 6 ms peak memory: 18.0 MiB spill size: 0.0 B"]; } 10 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 1794.1 KiB number of coalesced partitions: 1"]; 11 [labelType="html" label="Exchange shuffle records written: 48,276 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 9 ms (4 ms, 5 ms, 5 ms (stage 16915.0: task 23556)) 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: 48,276 local bytes read: 1739.9 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)) 7.1 MiB (2.8 MiB, 4.3 MiB, 4.3 MiB (stage 16915.0: task 23556)) 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)) 1739.9 KiB (701.4 KiB, 1038.5 KiB, 1038.5 KiB (stage 16915.0: task 23556))"]; subgraph cluster12 { isCluster="true"; label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n345 ms (106 ms, 239 ms, 239 ms (stage 16915.0: task 23556))"; 13 [labelType="html" label=" Project "]; 14 [labelType="html" label="SortMergeJoin number of output rows: 48,276 spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 16915.0: task 23549))"]; } subgraph cluster15 { isCluster="true"; label="WholeStageCodegen (8)\n \nduration: 0 ms"; 16 [labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 4 ms (1 ms, 3 ms, 3 ms (stage 16915.0: task 23556)) peak memory total (min, med, max (stageId: taskId)) 35.0 MiB (17.0 MiB, 18.0 MiB, 18.0 MiB (stage 16915.0: task 23556)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 16915.0: task 23549))"]; } 17 [labelType="html" label="AQEShuffleRead number of partitions: 2 partition data size total (min, med, max (stageId: taskId)) 905.4 KiB (362.1 KiB, 543.2 KiB, 543.2 KiB (driver)) number of coalesced partitions: 2"]; 18 [labelType="html" label="Exchange shuffle records written: 76,289 local merged chunks fetched: 0 shuffle write time: 4 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: 76,289 local bytes read total (min, med, max (stageId: taskId)) 873.9 KiB (349.3 KiB, 524.6 KiB, 524.6 KiB (stage 16915.0: task 23556)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 16915.0: task 23549)) 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.5 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: 873.9 KiB"]; subgraph cluster19 { isCluster="true"; label="WholeStageCodegen (7)\n \nduration: 205 ms"; 20 [labelType="html" label=" Project "]; } 21 [labelType="html" label="CartesianProduct number of output rows: 76,289"]; subgraph cluster22 { isCluster="true"; label="WholeStageCodegen (5)\n \nduration: 205 ms"; 23 [labelType="html" label=" Project "]; 24 [labelType="html" label="Filter number of output rows: 76,289"]; } 25 [labelType="html" label="Window spill size: 0.0 B"]; subgraph cluster26 { isCluster="true"; label="WholeStageCodegen (4)\n \nduration: 308 ms"; 27 [labelType="html" label="Sort sort time: 18 ms peak memory: 18.0 MiB spill size: 0.0 B"]; } 28 [labelType="html" label="AQEShuffleRead number of partitions: 1 partition data size: 994.4 KiB number of coalesced partitions: 1"]; 29 [labelType="html" label="Exchange shuffle records written: 76,289 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 7 ms (2 ms, 5 ms, 5 ms (stage 16899.0: task 23497)) 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: 76,289 local bytes read: 952.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.3 MiB (1083.8 KiB, 3.3 MiB, 3.3 MiB (stage 16899.0: task 23497)) 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)) 952.6 KiB (233.9 KiB, 718.7 KiB, 718.7 KiB (stage 16899.0: task 23497))"]; subgraph cluster30 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n304 ms (67 ms, 237 ms, 237 ms (stage 16899.0: task 23497))"; 31 [labelType="html" label=" Project "]; 32 [labelType="html" label="Filter number of output rows: 76,289"]; } 33 [labelType="html" label="Scan csv number of output rows: 76,289 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: 5 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))\n754 ms (274 ms, 480 ms, 480 ms (stage 16915.0: task 23556))"; 39 [labelType="html" label="Sort sort time total (min, med, max (stageId: taskId)) 14 ms (4 ms, 10 ms, 10 ms (stage 16915.0: task 23556)) peak memory total (min, med, max (stageId: taskId)) 33.5 MiB (16.5 MiB, 17.0 MiB, 17.0 MiB (stage 16915.0: task 23556)) spill size total (min, med, max (stageId: taskId)) 0.0 B (0.0 B, 0.0 B, 0.0 B (stage 16915.0: task 23549))"]; } 40 [labelType="html" label="AQEShuffleRead number of partitions: 2 partition data size total (min, med, max (stageId: taskId)) 2001.1 KiB (800.3 KiB, 1200.8 KiB, 1200.8 KiB (driver)) number of coalesced partitions: 2"]; 41 [labelType="html" label="Exchange shuffle records written: 48,276 local merged chunks fetched: 0 shuffle write time total (min, med, max (stageId: taskId)) 37 ms (2 ms, 2 ms, 7 ms (stage 16900.0: task 23499)) 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: 48,276 local bytes read total (min, med, max (stageId: taskId)) 1900.3 KiB (760.3 KiB, 1140.0 KiB, 1140.0 KiB (stage 16915.0: task 23556)) fetch wait time total (min, med, max (stageId: taskId)) 0 ms (0 ms, 0 ms, 0 ms (stage 16915.0: task 23549)) 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)) 5.1 MiB (507.5 KiB, 523.1 KiB, 534.1 KiB (stage 16900.0: task 23499)) 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)) 1900.3 KiB (186.1 KiB, 191.1 KiB, 195.5 KiB (stage 16900.0: task 23499))"]; subgraph cluster42 { isCluster="true"; label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n144 ms (8 ms, 13 ms, 24 ms (stage 16900.0: task 23509))"; 43 [labelType="html" label=" Project "]; 44 [labelType="html" label="Filter number of output rows: 48,276"]; 45 [labelType="html" label="ColumnarToRow number of output rows: 48,276 number of input batches: 20"]; } 46 [labelType="html" label="Scan parquet number of files read: 10 scan time total (min, med, max (stageId: taskId)) 62 ms (3 ms, 6 ms, 13 ms (stage 16900.0: task 23509)) metadata time: 0 ms size of files read: 8.7 MiB number of output rows: 48,276"]; subgraph cluster47 { isCluster="true"; label="WholeStageCodegen (12)\n \nduration: 2.4 m"; 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: 434.0 B number of coalesced partitions: 1"]; 50 [labelType="html" label="Exchange shuffle records written: 7 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: 7 local bytes read: 414.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: 240.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: 414.0 B"]; subgraph cluster51 { isCluster="true"; label="WholeStageCodegen (3)\n \nduration: 3 ms"; 52 [labelType="html" label=" Project "]; 53 [labelType="html" label="Filter number of output rows: 7"]; 54 [labelType="html" label="ColumnarToRow number of output rows: 7 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: 1695.0 B number of output rows: 7"]; 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_188120, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_188120], 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#1309379, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1310369, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1310372]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201]

Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) <=> ))

SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381], [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984], LeftOuter

WholeStageCodegen (13)

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

WholeStageCodegen (11)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 10), ENSURE_REQUIREMENTS, [plan_id=747590]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]

SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379], [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598], Inner

WholeStageCodegen (10)

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

WholeStageCodegen (8)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, 10), ENSURE_REQUIREMENTS, [plan_id=747126]

Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]

WholeStageCodegen (7)

CartesianProduct

Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381]

Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314 <=> 1)

WholeStageCodegen (5)

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

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

WholeStageCodegen (4)

AQEShuffleRead coalesced

Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, 10), ENSURE_REQUIREMENTS, [plan_id=746660]

Project [Numéro Séjour#1309180 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, str_remove_space(Transport admission#1309184, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]

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

WholeStageCodegen (1)

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

Project [APPLICABLE#1307147 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389]

Filter ((isnotnull(REGLES#1307146) AND (RC-SUM = REGLES#1307146)) AND (APPLICABLE#1307147 <=> O))

WholeStageCodegen (6)

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

WholeStageCodegen (9)

AQEShuffleRead coalesced

Exchange hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 10), ENSURE_REQUIREMENTS, [plan_id=746687]

Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]

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

ColumnarToRow

WholeStageCodegen (2)

FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177,COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172), NOT CASE WHEN isnull(StartsWith(COL..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_188182], 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_188009_TRANSPORT_UTILI_188010#1309984 ASC NULLS FIRST], false, 0

WholeStageCodegen (12)

AQEShuffleRead coalesced

Exchange hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984, 10), ENSURE_REQUIREMENTS, [plan_id=746719]

Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1308027, ONLY_ONE) AS 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]

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

ColumnarToRow

WholeStageCodegen (3)

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

(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#1309180 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, str_remove_space(Transport admission#1309184, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Input [2]: [Numéro Séjour#1309180, Transport admission#1309184]

(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, 10), ENSURE_REQUIREMENTS, [plan_id=746660]

(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Arguments: 0

(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Arguments: coalesced

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

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

(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314 <=> 1)

(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314]

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

(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#1307147 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389]
Input [2]: [REGLES#1307146, APPLICABLE#1307147]

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

(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389]

(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, 10), ENSURE_REQUIREMENTS, [plan_id=747126]

(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: 3

(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: coalesced

(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379 ASC NULLS FIRST], false, 0

(20) Scan parquet 
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_188182]
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#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]

(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176))

(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]

(24) Exchange
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 10), ENSURE_REQUIREMENTS, [plan_id=746687]

(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: 1

(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: coalesced

(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598 ASC NULLS FIRST], false, 0

(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379]
Right keys [1]: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598]
Join type: Inner
Join condition: None

(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]

(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 10), ENSURE_REQUIREMENTS, [plan_id=747590]

(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: 4

(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: coalesced

(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381 ASC NULLS FIRST], false, 0

(34) Scan parquet 
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1308027]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/06_ENTREE_URGEN_187909_e137eb1d2a46d57c6a1739d46212ce0c/Info_Etab_init_v1.1 CHU Besançon 310126.xlsx_97fd3f27675f4eb87df5084045c03c76]
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#1308027]

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

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

(38) Exchange
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Arguments: hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984, 10), ENSURE_REQUIREMENTS, [plan_id=746719]

(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Arguments: 2

(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Arguments: coalesced

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

(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381]
Right keys [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Join type: LeftOuter
Join condition: None

(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) <=> ))

(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]

(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1310369, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1310372]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201]

(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1310369, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1310372]

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

(49) Project
Output [2]: [Numéro Séjour#1309180 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, str_remove_space(Transport admission#1309184, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Input [2]: [Numéro Séjour#1309180, Transport admission#1309184]

(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, 10), ENSURE_REQUIREMENTS, [plan_id=746583]

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

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

(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314 <=> 1)

(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1309298, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1309300, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1309314]

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

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

(57) Project
Output [1]: [APPLICABLE#1307147 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389]
Input [2]: [REGLES#1307146, APPLICABLE#1307147]

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

(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, REGLES_A_APPLIQ_188031_APPLICABLE_188033#1309389]

(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, 10), ENSURE_REQUIREMENTS, [plan_id=746594]

(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379 ASC NULLS FIRST], false, 0

(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176))

(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1307172, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1307176, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1307177, COL_60F7C888_9836_4535_A22F_D43D2994E019#1307184]

(64) Exchange
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 10), ENSURE_REQUIREMENTS, [plan_id=746595]

(65) Sort
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]
Arguments: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598 ASC NULLS FIRST], false, 0

(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379]
Right keys [1]: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598]
Join type: Inner
Join condition: None

(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1309594, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1309598, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1309599, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#1309606]

(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 10), ENSURE_REQUIREMENTS, [plan_id=746604]

(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381 ASC NULLS FIRST], false, 0

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

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

(72) Exchange
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Arguments: hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984, 10), ENSURE_REQUIREMENTS, [plan_id=746605]

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

(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381]
Right keys [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Join type: LeftOuter
Join condition: None

(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) <=> ))

(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1309957, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#1309984]

(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1310369, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117),  : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381),  : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1310372]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1309381, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1310117, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201]

(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1309379, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1309959, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1310201, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1310150, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1310369, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1309960, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1309495, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1310372]

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