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: 0 ms<br>number of written files: 1<br>job commit time: 5 ms<br>number of output rows: 1,160<br>number of dynamic part: 0<br>written output: 37.6 KiB"];
2 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (13)\n \nduration: 299 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,160"];
7 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 34,035<br>spill size: 0.0 B"];
}
subgraph cluster8 {
isCluster="true";
label="WholeStageCodegen (11)\n \nduration: 345 ms";
9 [labelType="html" label="<b>Sort</b><br><br>sort time: 3 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,035<br>local merged chunks fetched: 0<br>shuffle write time: 3 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,035<br>local bytes read: 1057.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: 4.5 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: 1057.8 KiB"];
subgraph cluster12 {
isCluster="true";
label="WholeStageCodegen (10)\n \nduration: 101 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,035<br>spill size: 0.0 B"];
}
subgraph cluster15 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 105 ms";
16 [labelType="html" label="<b>Sort</b><br><br>sort time: 3 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: 57 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: 57 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: 90 ms";
27 [labelType="html" label="<b>Sort</b><br><br>sort time: 7 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: 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: 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: 162 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: 6 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: 102 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: 1292.8 KiB<br>number of coalesced partitions: 1"];
41 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 34,035<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>27 ms (1 ms, 2 ms, 6 ms (stage 16027.0: task 22038))<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,035<br>local bytes read: 1234.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 (347.8 KiB, 359.4 KiB, 370.2 KiB (stage 16027.0: task 22038))<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>1234.7 KiB (120.0 KiB, 123.4 KiB, 127.0 KiB (stage 16027.0: task 22038))"];
subgraph cluster42 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n447 ms (9 ms, 50 ms, 54 ms (stage 16027.0: task 22039))";
43 [labelType="html" label="<br><b>Project</b><br><br>"];
44 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 34,035"];
45 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 34,035<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>106 ms (3 ms, 12 ms, 15 ms (stage 16027.0: task 22039))<br>metadata time: 0 ms<br>size of files read: 5.7 MiB<br>number of output rows: 34,035"];
subgraph cluster47 {
isCluster="true";
label="WholeStageCodegen (12)\n \nduration: 306 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: 0 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: 2 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: 1 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#1247028, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1247511, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1247514]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409]
Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) <=> ))
SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030], [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324], LeftOuter
WholeStageCodegen (13)
Sort [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030 ASC NULLS FIRST], false, 0
WholeStageCodegen (11)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 10), ENSURE_REQUIREMENTS, [plan_id=704245]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028], [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137], Inner
WholeStageCodegen (10)
Sort [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028 ASC NULLS FIRST], false, 0
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, 10), ENSURE_REQUIREMENTS, [plan_id=704130]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
WholeStageCodegen (7)
CartesianProduct
Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030]
Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459 <=> 1)
WholeStageCodegen (5)
Window [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443], [1 DESC NULLS LAST]
Sort [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 10), ENSURE_REQUIREMENTS, [plan_id=703782]
Project [Numéro Séjour#1244207 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, str_remove_space(Transport admission#1244211, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Filter (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1244207, #)) THEN false ELSE StartsWith(Numéro Séjour#1244207, #) END AND isnotnull(Numéro Séjour#1244207))
WholeStageCodegen (1)
FileScan csv [Numéro Séjour#1244207,Transport admission#1244211] Batched: false, DataFilters: [NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1244207, #)) 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#1246918 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038]
Filter ((isnotnull(REGLES#1246917) AND (RC-SUM = REGLES#1246917)) AND (APPLICABLE#1246918 <=> O))
WholeStageCodegen (6)
FileScan csv [REGLES#1246917,APPLICABLE#1246918] Batched: false, DataFilters: [isnotnull(REGLES#1246917), (RC-SUM = REGLES#1246917), (APPLICABLE#1246918 <=> 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#1247137 ASC NULLS FIRST], false, 0
WholeStageCodegen (9)
AQEShuffleRead coalesced
Exchange hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 10), ENSURE_REQUIREMENTS, [plan_id=703809]
Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Filter ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945))
ColumnarToRow
WholeStageCodegen (2)
FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946,COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941), 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#1247324 ASC NULLS FIRST], false, 0
WholeStageCodegen (12)
AQEShuffleRead coalesced
Exchange hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324, 10), ENSURE_REQUIREMENTS, [plan_id=703841]
Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Filter isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008] Batched: true, DataFilters: [isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, 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.5 MiB, rowCount=3.40E+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.40E+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#1244207, Transport admission#1244211]
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#1244207, Transport admission#1244211]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1244207, #)) THEN false ELSE StartsWith(Numéro Séjour#1244207, #) END AND isnotnull(Numéro Séjour#1244207))
(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#1244207 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, str_remove_space(Transport admission#1244211, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Input [2]: [Numéro Séjour#1244207, Transport admission#1244211]
(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 10), ENSURE_REQUIREMENTS, [plan_id=703782]
(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: 0
(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: coalesced
(7) Sort [codegen id : 4]
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(8) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443], [1 DESC NULLS LAST]
(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459 <=> 1)
(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459]
(11) Scan csv
Output [2]: [REGLES#1246917, APPLICABLE#1246918]
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#1246917, APPLICABLE#1246918]
Condition : ((isnotnull(REGLES#1246917) AND (RC-SUM = REGLES#1246917)) AND (APPLICABLE#1246918 <=> O))
(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#1246918 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038]
Input [2]: [REGLES#1246917, APPLICABLE#1246918]
(14) CartesianProduct
Join type: Inner
Join condition: None
(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038]
(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, 10), ENSURE_REQUIREMENTS, [plan_id=704130]
(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: 3
(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: coalesced
(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028 ASC NULLS FIRST], false, 0
(20) Scan parquet
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
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#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945))
(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
(24) Exchange
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 10), ENSURE_REQUIREMENTS, [plan_id=703809]
(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: 1
(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: coalesced
(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137 ASC NULLS FIRST], false, 0
(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028]
Right keys [1]: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137]
Join type: Inner
Join condition: None
(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 10), ENSURE_REQUIREMENTS, [plan_id=704245]
(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: 4
(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: coalesced
(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030 ASC NULLS FIRST], false, 0
(34) Scan parquet
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008]
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#1243008]
(36) Filter [codegen id : 3]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE))
(37) Project [codegen id : 3]
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008]
(38) Exchange
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324, 10), ENSURE_REQUIREMENTS, [plan_id=703841]
(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: 2
(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: coalesced
(41) Sort [codegen id : 12]
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324 ASC NULLS FIRST], false, 0
(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030]
Right keys [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Join type: LeftOuter
Join condition: None
(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) <=> ))
(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1247511, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1247514]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409]
(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1247511, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1247514]
(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#1244207, Transport admission#1244211]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#1244207, #)) THEN false ELSE StartsWith(Numéro Séjour#1244207, #) END AND isnotnull(Numéro Séjour#1244207))
(49) Project
Output [2]: [Numéro Séjour#1244207 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, str_remove_space(Transport admission#1244211, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Input [2]: [Numéro Séjour#1244207, Transport admission#1244211]
(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 10), ENSURE_REQUIREMENTS, [plan_id=703705]
(51) Sort
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(52) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443], [1 DESC NULLS LAST]
(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459 <=> 1)
(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#1244443, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#1244445, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#1244459]
(55) Scan csv
Output [2]: [REGLES#1246917, APPLICABLE#1246918]
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#1246917, APPLICABLE#1246918]
Condition : ((isnotnull(REGLES#1246917) AND (RC-SUM = REGLES#1246917)) AND (APPLICABLE#1246918 <=> O))
(57) Project
Output [1]: [APPLICABLE#1246918 AS REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038]
Input [2]: [REGLES#1246917, APPLICABLE#1246918]
(58) CartesianProduct
Join type: Inner
Join condition: None
(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, REGLES_A_APPLIQ_175810_APPLICABLE_175812#1247038]
(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, 10), ENSURE_REQUIREMENTS, [plan_id=703716]
(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028 ASC NULLS FIRST], false, 0
(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945))
(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941 AS 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945 AS 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946 AS 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953 AS 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1246941, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1246945, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1246946, COL_60F7C888_9836_4535_A22F_D43D2994E019#1246953]
(64) Exchange
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: hashpartitioning(03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 10), ENSURE_REQUIREMENTS, [plan_id=703717]
(65) Sort
Input [4]: [03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
Arguments: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137 ASC NULLS FIRST], false, 0
(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028]
Right keys [1]: [03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137]
Join type: Inner
Join condition: None
(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 03_PIVOT_INFORM_175988_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#1247133, 03_PIVOT_INFORM_175988_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#1247137, 03_PIVOT_INFORM_175988_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#1247138, 03_PIVOT_INFORM_175988_COL_60F7C888_9836_4535_A22F_D43D2994E019#1247145]
(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 10), ENSURE_REQUIREMENTS, [plan_id=703726]
(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030 ASC NULLS FIRST], false, 0
(70) Filter
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE))
(71) Project
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008, ONLY_ONE) AS 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#1243008]
(72) Exchange
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: hashpartitioning(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324, 10), ENSURE_REQUIREMENTS, [plan_id=703727]
(73) Sort
Input [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Arguments: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324 ASC NULLS FIRST], false, 0
(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030]
Right keys [1]: [06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Join type: LeftOuter
Join condition: None
(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) <=> ))
(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, SUM) END AND isnotnull(06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#1247309, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, 06_ENTREE_URGEN_175788_TRANSPORT_UTILI_175789#1247324]
(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1247511, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1247514]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#1247030, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#1247383, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409]
(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#1247028, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#1247311, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#1247409, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#1247397, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#1247511, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#1247312, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#1247088, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#1247514]
(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