digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 2 ms<br>number of written files: 1<br>job commit time: 8 ms<br>number of output rows: 1,174<br>number of dynamic part: 0<br>written output: 37.9 KiB"];
2 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (13)\n \nduration: 305 ms";
4 [labelType="html" label="<br><b>Project</b><br><br>"];
5 [labelType="html" label="<br><b>Project</b><br><br>"];
6 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 1,174"];
7 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 34,259<br>spill size: 0.0 B"];
}
subgraph cluster8 {
isCluster="true";
label="WholeStageCodegen (11)\n \nduration: 469 ms";
9 [labelType="html" label="<b>Sort</b><br><br>sort time: 4 ms<br>peak memory: 17.0 MiB<br>spill size: 0.0 B"];
}
10 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 1105.9 KiB<br>number of coalesced partitions: 1"];
11 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 34,259<br>local merged chunks fetched: 0<br>shuffle write time: 4 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 34,259<br>local bytes read: 1068.0 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 4.6 MiB<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 1068.0 KiB"];
subgraph cluster12 {
isCluster="true";
label="WholeStageCodegen (10)\n \nduration: 98 ms";
13 [labelType="html" label="<br><b>Project</b><br><br>"];
14 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 34,259<br>spill size: 0.0 B"];
}
subgraph cluster15 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 100 ms";
16 [labelType="html" label="<b>Sort</b><br><br>sort time: 4 ms<br>peak memory: 18.0 MiB<br>spill size: 0.0 B"];
}
17 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 464.6 KiB<br>number of coalesced partitions: 1"];
18 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 45,934<br>local merged chunks fetched: 0<br>shuffle write time: 2 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 45,934<br>local bytes read: 454.6 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 2.8 MiB<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 454.6 KiB"];
subgraph cluster19 {
isCluster="true";
label="WholeStageCodegen (7)\n \nduration: 60 ms";
20 [labelType="html" label="<br><b>Project</b><br><br>"];
}
21 [labelType="html" label="<b>CartesianProduct</b><br><br>number of output rows: 45,934"];
subgraph cluster22 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 60 ms";
23 [labelType="html" label="<br><b>Project</b><br><br>"];
24 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 45,934"];
}
25 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster26 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 89 ms";
27 [labelType="html" label="<b>Sort</b><br><br>sort time: 8 ms<br>peak memory: 18.0 MiB<br>spill size: 0.0 B"];
}
28 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 511.0 KiB<br>number of coalesced partitions: 1"];
29 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 45,934<br>local merged chunks fetched: 0<br>shuffle write time: 4 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 45,934<br>local bytes read: 499.8 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 2.1 MiB<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 499.8 KiB"];
subgraph cluster30 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 132 ms";
31 [labelType="html" label="<br><b>Project</b><br><br>"];
32 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 45,934"];
}
33 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 45,934<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 2.7 MiB"];
subgraph cluster34 {
isCluster="true";
label="WholeStageCodegen (6)\n \nduration: 3 ms";
35 [labelType="html" label="<br><b>Project</b><br><br>"];
36 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 1"];
}
37 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 1<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 175.0 B"];
subgraph cluster38 {
isCluster="true";
label="WholeStageCodegen (9)\n \nduration: 98 ms";
39 [labelType="html" label="<b>Sort</b><br><br>sort time: 5 ms<br>peak memory: 17.0 MiB<br>spill size: 0.0 B"];
}
40 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 1301.5 KiB<br>number of coalesced partitions: 1"];
41 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 34,259<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>46 ms (2 ms, 4 ms, 6 ms (stage 15155.0: task 20988))<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 34,259<br>local bytes read: 1244.7 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 10<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>3.5 MiB (354.1 KiB, 366.5 KiB, 368.2 KiB (stage 15155.0: task 20987))<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written total (min, med, max (stageId: taskId))<br>1244.7 KiB (121.5 KiB, 125.6 KiB, 126.6 KiB (stage 15155.0: task 20987))"];
subgraph cluster42 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n345 ms (13 ms, 36 ms, 42 ms (stage 15155.0: task 20991))";
43 [labelType="html" label="<br><b>Project</b><br><br>"];
44 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 34,259"];
45 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 34,259<br>number of input batches: 10"];
}
46 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 10<br>scan time total (min, med, max (stageId: taskId))<br>98 ms (5 ms, 10 ms, 14 ms (stage 15155.0: task 20993))<br>metadata time: 0 ms<br>size of files read: 5.7 MiB<br>number of output rows: 34,259"];
subgraph cluster47 {
isCluster="true";
label="WholeStageCodegen (12)\n \nduration: 430 ms";
48 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
49 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 288.0 B<br>number of coalesced partitions: 1"];
50 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 4<br>local merged chunks fetched: 0<br>shuffle write time: 1 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 4<br>local bytes read: 272.0 B<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 1<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 96.0 B<br>local merged bytes read: 0.0 B<br>number of partitions: 10<br>remote reqs duration: 0 ms<br>remote bytes read to disk: 0.0 B<br>shuffle bytes written: 272.0 B"];
subgraph cluster51 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 6 ms";
52 [labelType="html" label="<br><b>Project</b><br><br>"];
53 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 4"];
54 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 4<br>number of input batches: 1"];
}
55 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 3 ms<br>metadata time: 0 ms<br>size of files read: 1568.0 B<br>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;
}
56
AdaptiveSparkPlan isFinalPlan=true
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/datablock/05_GR4_SUM_175910, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_175910], 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#1178831, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1179354, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1179357]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252]
Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) <=> ))
SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833], [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159], LeftOuter
WholeStageCodegen (13)
Sort [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833 ASC NULLS FIRST], false, 0
WholeStageCodegen (11)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 10), ENSURE_REQUIREMENTS, [plan_id=614777]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831], [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940], Inner
WholeStageCodegen (10)
Sort [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831 ASC NULLS FIRST], false, 0
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, 10), ENSURE_REQUIREMENTS, [plan_id=614665]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
WholeStageCodegen (7)
CartesianProduct
Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833]
Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738 <=> 1)
WholeStageCodegen (5)
Window [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703], [1 DESC NULLS LAST]
Sort [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 10), ENSURE_REQUIREMENTS, [plan_id=614317]
Project [Numéro Séjour#1174552 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, str_remove_space(Transport admission#1174556, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Filter (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1174552, #)) THEN false ELSE StartsWith(Numéro Séjour#1174552, #) END AND isnotnull(Numéro Séjour#1174552))
WholeStageCodegen (1)
FileScan csv [Numéro Séjour#1174552,Transport admission#1174556] Batched: false, DataFilters: [NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1174552, #)) THEN false ELSE StartsWith(Numéro Séj..., Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_175675/passage_patient_..., PartitionFilters: [], PushedFilters: [IsNotNull(Numéro Séjour)], ReadSchema: struct<Numéro Séjour:string,Transport admission:string>
Project [APPLICABLE#1178709 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841]
Filter ((isnotnull(REGLES#1178708) AND (RC-SUM = REGLES#1178708)) AND (APPLICABLE#1178709 <=> O))
WholeStageCodegen (6)
FileScan csv [REGLES#1178708,APPLICABLE#1178709] Batched: false, DataFilters: [isnotnull(REGLES#1178708), (RC-SUM = REGLES#1178708), (APPLICABLE#1178709 <=> O)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/REGLES_APPLICAB_175682/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_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940 ASC NULLS FIRST], false, 0
WholeStageCodegen (9)
AQEShuffleRead coalesced
Exchange hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 10), ENSURE_REQUIREMENTS, [plan_id=614344]
Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Filter ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748))
ColumnarToRow
WholeStageCodegen (2)
FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749,COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744), NOT CASE WHEN isnull(StartsWith(COL..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_175988], 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_175788_TRANSPORT_UTILI_175789#1179159 ASC NULLS FIRST], false, 0
WholeStageCodegen (12)
AQEShuffleRead coalesced
Exchange hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159, 10), ENSURE_REQUIREMENTS, [plan_id=614376]
Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Filter isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494] Batched: true, DataFilters: [isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE))], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/06_ENTREE_URGEN_175688_83ddda109565..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Transport+utilis%C3%A9+%C3%A0+l%27admission:string>
== 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=4.6 MiB, rowCount=3.43E+4)
: +- Exchange (30)
: +- * Project (29)
: +- * SortMergeJoin Inner (28)
: :- * Sort (19)
: : +- AQEShuffleRead (18)
: : +- ShuffleQueryStage (17), Statistics(sizeInBytes=2.8 MiB, rowCount=4.59E+4)
: : +- Exchange (16)
: : +- * Project (15)
: : +- CartesianProduct Inner (14)
: : :- * Project (10)
: : : +- * Filter (9)
: : : +- Window (8)
: : : +- * Sort (7)
: : : +- AQEShuffleRead (6)
: : : +- ShuffleQueryStage (5), Statistics(sizeInBytes=2.1 MiB, rowCount=4.59E+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=3.5 MiB, rowCount=3.43E+4)
: +- Exchange (24)
: +- * Project (23)
: +- * Filter (22)
: +- * ColumnarToRow (21)
: +- Scan parquet (20)
+- * Sort (41)
+- AQEShuffleRead (40)
+- ShuffleQueryStage (39), Statistics(sizeInBytes=96.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#1174552, Transport admission#1174556]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_175675/passage_patient_Grasse_2025.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#1174552, Transport admission#1174556]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1174552, #)) THEN false ELSE StartsWith(Numéro Séjour#1174552, #) END AND isnotnull(Numéro Séjour#1174552))
(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#1174552 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, str_remove_space(Transport admission#1174556, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Input [2]: [Numéro Séjour#1174552, Transport admission#1174556]
(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 10), ENSURE_REQUIREMENTS, [plan_id=614317]
(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: 0
(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: coalesced
(7) Sort [codegen id : 4]
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(8) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703], [1 DESC NULLS LAST]
(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738 <=> 1)
(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738]
(11) Scan csv
Output [2]: [REGLES#1178708, APPLICABLE#1178709]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_175682/REGLES-A-TTT new GRASSE 290126.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#1178708, APPLICABLE#1178709]
Condition : ((isnotnull(REGLES#1178708) AND (RC-SUM = REGLES#1178708)) AND (APPLICABLE#1178709 <=> O))
(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#1178709 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841]
Input [2]: [REGLES#1178708, APPLICABLE#1178709]
(14) CartesianProduct
Join type: Inner
Join condition: None
(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841]
(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, 10), ENSURE_REQUIREMENTS, [plan_id=614665]
(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: 3
(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: coalesced
(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831 ASC NULLS FIRST], false, 0
(20) Scan parquet
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_175988]
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#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748))
(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
(24) Exchange
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 10), ENSURE_REQUIREMENTS, [plan_id=614344]
(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: 1
(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: coalesced
(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940 ASC NULLS FIRST], false, 0
(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831]
Right keys [1]: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940]
Join type: Inner
Join condition: None
(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 10), ENSURE_REQUIREMENTS, [plan_id=614777]
(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: 4
(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: coalesced
(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833 ASC NULLS FIRST], false, 0
(34) Scan parquet
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/06_ENTREE_URGEN_175688_83ddda10956563bee34e43ba3c64c262/Info_Etab_init_v1.1 GRASSE 280126v2.xlsx_a173219fe4bc799218f2e0cb9d34b4ae]
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#1172494]
(36) Filter [codegen id : 3]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE))
(37) Project [codegen id : 3]
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494]
(38) Exchange
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159, 10), ENSURE_REQUIREMENTS, [plan_id=614376]
(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: 2
(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: coalesced
(41) Sort [codegen id : 12]
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159 ASC NULLS FIRST], false, 0
(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833]
Right keys [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Join type: LeftOuter
Join condition: None
(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) <=> ))
(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1179354, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1179357]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252]
(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1179354, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1179357]
(47) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_175910, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_175910], 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#1174552, Transport admission#1174556]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1174552, #)) THEN false ELSE StartsWith(Numéro Séjour#1174552, #) END AND isnotnull(Numéro Séjour#1174552))
(49) Project
Output [2]: [Numéro Séjour#1174552 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, str_remove_space(Transport admission#1174556, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Input [2]: [Numéro Séjour#1174552, Transport admission#1174556]
(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 10), ENSURE_REQUIREMENTS, [plan_id=614240]
(51) Sort
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(52) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703], [1 DESC NULLS LAST]
(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738 <=> 1)
(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1174703, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1174705, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1174738]
(55) Scan csv
Output [2]: [REGLES#1178708, APPLICABLE#1178709]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_175682/REGLES-A-TTT new GRASSE 290126.csv]
PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)]
ReadSchema: struct<REGLES:string,APPLICABLE:string>
(56) Filter
Input [2]: [REGLES#1178708, APPLICABLE#1178709]
Condition : ((isnotnull(REGLES#1178708) AND (RC-SUM = REGLES#1178708)) AND (APPLICABLE#1178709 <=> O))
(57) Project
Output [1]: [APPLICABLE#1178709 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841]
Input [2]: [REGLES#1178708, APPLICABLE#1178709]
(58) CartesianProduct
Join type: Inner
Join condition: None
(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1178841]
(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, 10), ENSURE_REQUIREMENTS, [plan_id=614251]
(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831 ASC NULLS FIRST], false, 0
(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748))
(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178744, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178748, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178749, COL_60F7C888_9836_4535_A22F_D43D2994E019#1178756]
(64) Exchange
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 10), ENSURE_REQUIREMENTS, [plan_id=614252]
(65) Sort
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
Arguments: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940 ASC NULLS FIRST], false, 0
(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831]
Right keys [1]: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940]
Join type: Inner
Join condition: None
(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1178936, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1178940, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1178941, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1178948]
(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 10), ENSURE_REQUIREMENTS, [plan_id=614261]
(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833 ASC NULLS FIRST], false, 0
(70) Filter
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE))
(71) Project
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1172494]
(72) Exchange
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159, 10), ENSURE_REQUIREMENTS, [plan_id=614262]
(73) Sort
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Arguments: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159 ASC NULLS FIRST], false, 0
(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833]
Right keys [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Join type: LeftOuter
Join condition: None
(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) <=> ))
(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1179128, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1179159]
(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1179354, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1179357]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1178833, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1179226, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252]
(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1178831, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1179130, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1179252, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1179240, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1179354, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1179131, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1178891, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1179357]
(79) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_175910, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_175910], 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