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: 11 ms<br>number of output rows: 854<br>number of dynamic part: 0<br>written output: 30.6 KiB"];
2 [labelType="html" label="<br><b>WriteFiles</b><br><br>"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (13)\n \nduration: 425 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: 854"];
7 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 48,592<br>spill size: 0.0 B"];
}
subgraph cluster8 {
isCluster="true";
label="WholeStageCodegen (11)\n \nduration: 473 ms";
9 [labelType="html" label="<b>Sort</b><br><br>sort time: 6 ms<br>peak memory: 18.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: 1794.1 KiB<br>number of coalesced partitions: 1"];
11 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 48,482<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>10 ms (3 ms, 6 ms, 6 ms (stage 7756.0: task 10189))<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: 48,482<br>local bytes read: 1747.4 KiB<br>fetch wait time: 0 ms<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 2<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>7.1 MiB (2.9 MiB, 4.3 MiB, 4.3 MiB (stage 7756.0: task 10189))<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>1747.4 KiB (703.6 KiB, 1043.8 KiB, 1043.8 KiB (stage 7756.0: task 10189))"];
subgraph cluster12 {
isCluster="true";
label="WholeStageCodegen (10)\n \nduration: total (min, med, max (stageId: taskId))\n271 ms (108 ms, 163 ms, 163 ms (stage 7756.0: task 10184))";
13 [labelType="html" label="<br><b>Project</b><br><br>"];
14 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 48,482<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 7756.0: task 10184))"];
}
subgraph cluster15 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 0 ms";
16 [labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>3 ms (1 ms, 2 ms, 2 ms (stage 7756.0: task 10189))<br>peak memory total (min, med, max (stageId: taskId))<br>35.0 MiB (17.0 MiB, 18.0 MiB, 18.0 MiB (stage 7756.0: task 10189))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 7756.0: task 10184))"];
}
17 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 2<br>partition data size total (min, med, max (stageId: taskId))<br>905.4 KiB (362.1 KiB, 543.2 KiB, 543.2 KiB (driver))<br>number of coalesced partitions: 2"];
18 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 76,289<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: 76,289<br>local bytes read total (min, med, max (stageId: taskId))<br>873.9 KiB (349.3 KiB, 524.6 KiB, 524.6 KiB (stage 7756.0: task 10189))<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 7756.0: task 10184))<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 2<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size: 5.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: 873.9 KiB"];
subgraph cluster19 {
isCluster="true";
label="WholeStageCodegen (7)\n \nduration: 122 ms";
20 [labelType="html" label="<br><b>Project</b><br><br>"];
}
21 [labelType="html" label="<b>CartesianProduct</b><br><br>number of output rows: 76,289"];
subgraph cluster22 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 122 ms";
23 [labelType="html" label="<br><b>Project</b><br><br>"];
24 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 76,289"];
}
25 [labelType="html" label="<b>Window</b><br><br>spill size: 0.0 B"];
subgraph cluster26 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 204 ms";
27 [labelType="html" label="<b>Sort</b><br><br>sort time: 13 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: 994.4 KiB<br>number of coalesced partitions: 1"];
29 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 76,289<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>5 ms (2 ms, 3 ms, 3 ms (stage 7743.0: task 10151))<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: 76,289<br>local bytes read: 952.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: 2<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>4.3 MiB (1083.8 KiB, 3.3 MiB, 3.3 MiB (stage 7743.0: task 10151))<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>952.6 KiB (233.9 KiB, 718.7 KiB, 718.7 KiB (stage 7743.0: task 10151))"];
subgraph cluster30 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n311 ms (114 ms, 197 ms, 197 ms (stage 7743.0: task 10151))";
31 [labelType="html" label="<br><b>Project</b><br><br>"];
32 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 76,289"];
}
33 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 76,289<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 5.3 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: total (min, med, max (stageId: taskId))\n544 ms (216 ms, 328 ms, 328 ms (stage 7756.0: task 10184))";
39 [labelType="html" label="<b>Sort</b><br><br>sort time total (min, med, max (stageId: taskId))<br>8 ms (3 ms, 5 ms, 5 ms (stage 7756.0: task 10189))<br>peak memory total (min, med, max (stageId: taskId))<br>33.5 MiB (16.5 MiB, 17.0 MiB, 17.0 MiB (stage 7756.0: task 10189))<br>spill size total (min, med, max (stageId: taskId))<br>0.0 B (0.0 B, 0.0 B, 0.0 B (stage 7756.0: task 10184))"];
}
40 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 2<br>partition data size total (min, med, max (stageId: taskId))<br>2002.7 KiB (800.1 KiB, 1202.6 KiB, 1202.6 KiB (driver))<br>number of coalesced partitions: 2"];
41 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 48,482<br>local merged chunks fetched: 0<br>shuffle write time total (min, med, max (stageId: taskId))<br>22 ms (1 ms, 2 ms, 3 ms (stage 7744.0: task 10159))<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: 48,482<br>local bytes read total (min, med, max (stageId: taskId))<br>1909.8 KiB (763.1 KiB, 1146.7 KiB, 1146.7 KiB (stage 7756.0: task 10189))<br>fetch wait time total (min, med, max (stageId: taskId))<br>0 ms (0 ms, 0 ms, 0 ms (stage 7756.0: task 10184))<br>remote bytes read: 0.0 B<br>merged fetch fallback count: 0<br>local blocks read: 20<br>remote merged chunks fetched: 0<br>remote blocks read: 0<br>data size total (min, med, max (stageId: taskId))<br>5.1 MiB (510.5 KiB, 521.8 KiB, 531.4 KiB (stage 7744.0: task 10153))<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>1909.8 KiB (186.7 KiB, 190.9 KiB, 194.2 KiB (stage 7744.0: task 10153))"];
subgraph cluster42 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: total (min, med, max (stageId: taskId))\n664 ms (34 ms, 70 ms, 78 ms (stage 7744.0: task 10162))";
43 [labelType="html" label="<br><b>Project</b><br><br>"];
44 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 48,482"];
45 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 48,482<br>number of input batches: 20"];
}
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>109 ms (4 ms, 13 ms, 19 ms (stage 7744.0: task 10153))<br>metadata time: 0 ms<br>size of files read: 8.8 MiB<br>number of output rows: 48,482"];
subgraph cluster47 {
isCluster="true";
label="WholeStageCodegen (12)\n \nduration: 2.9 m";
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: 434.0 B<br>number of coalesced partitions: 1"];
50 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 7<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: 7<br>local bytes read: 414.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: 240.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: 414.0 B"];
subgraph cluster51 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 5 ms";
52 [labelType="html" label="<br><b>Project</b><br><br>"];
53 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 7"];
54 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 7<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: 1695.0 B<br>number of output rows: 7"];
1->0;
2->1;
4->2;
5->4;
6->5;
7->6;
9->7;
10->9;
11->10;
13->11;
14->13;
16->14;
17->16;
18->17;
20->18;
21->20;
23->21;
24->23;
25->24;
27->25;
28->27;
29->28;
31->29;
32->31;
33->32;
35->21;
36->35;
37->36;
39->14;
40->39;
41->40;
43->41;
44->43;
45->44;
46->45;
48->7;
49->48;
50->49;
52->50;
53->52;
54->53;
55->54;
}
56
AdaptiveSparkPlan isFinalPlan=true
Execute InsertIntoHadoopFsRelationCommand file:/data/output/cache/parquet/datablock/05_GR4_SUM_188120, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_188120], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]
WriteFiles
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#640436, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#640439]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258]
Filter (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) <=> ))
SortMergeJoin [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007], [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789], LeftOuter
WholeStageCodegen (13)
Sort [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007 ASC NULLS FIRST], false, 0
WholeStageCodegen (11)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 10), ENSURE_REQUIREMENTS, [plan_id=402438]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
SortMergeJoin [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005], [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421], Inner
WholeStageCodegen (10)
Sort [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005 ASC NULLS FIRST], false, 0
WholeStageCodegen (8)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, 10), ENSURE_REQUIREMENTS, [plan_id=401877]
Project [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
WholeStageCodegen (7)
CartesianProduct
Project [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007]
Filter (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941 <=> 1)
WholeStageCodegen (5)
Window [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925], [1 DESC NULLS LAST]
Sort [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 10), ENSURE_REQUIREMENTS, [plan_id=401436]
Project [Numéro Séjour#638809 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, str_remove_space(Transport admission#638813, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Filter (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#638809, #)) THEN false ELSE StartsWith(Numéro Séjour#638809, #) END AND isnotnull(Numéro Séjour#638809))
WholeStageCodegen (1)
FileScan csv [Numéro Séjour#638809,Transport admission#638813] Batched: false, DataFilters: [NOT CASE WHEN isnull(StartsWith(Numéro Séjour#638809, #)) THEN false ELSE StartsWith(Numéro Séjo..., Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_187896/passage_patient_..., PartitionFilters: [], PushedFilters: [IsNotNull(Numéro Séjour)], ReadSchema: struct<Numéro Séjour:string,Transport admission:string>
Project [APPLICABLE#637814 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015]
Filter ((isnotnull(REGLES#637813) AND (RC-SUM = REGLES#637813)) AND (APPLICABLE#637814 <=> O))
WholeStageCodegen (6)
FileScan csv [REGLES#637813,APPLICABLE#637814] Batched: false, DataFilters: [isnotnull(REGLES#637813), (RC-SUM = REGLES#637813), (APPLICABLE#637814 <=> O)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/REGLES_APPLICAB_187903/REGLES-A-TTT new..., PartitionFilters: [], PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)], ReadSchema: struct<REGLES:string,APPLICABLE:string>
Sort [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421 ASC NULLS FIRST], false, 0
WholeStageCodegen (9)
AQEShuffleRead coalesced
Exchange hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 10), ENSURE_REQUIREMENTS, [plan_id=401463]
Project [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Filter ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087))
ColumnarToRow
WholeStageCodegen (2)
FileScan parquet [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088,COL_60F7C888_9836_4535_A22F_D43D2994E019#638095] Batched: true, DataFilters: [isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083), NOT CASE WHEN isnull(StartsWith(COL_..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_188182], PartitionFilters: [], PushedFilters: [IsNotNull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F), IsNotNull(COL_582B8737_1AAE_44AC_AF57_EB71A..., ReadSchema: struct<COL_F1E7803C_F059_4667_8E32_963E2B3DA65F:string,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8:s...
Sort [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 ASC NULLS FIRST], false, 0
WholeStageCodegen (12)
AQEShuffleRead coalesced
Exchange hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789, 10), ENSURE_REQUIREMENTS, [plan_id=401495]
Project [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE) AS 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Filter isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557] Batched: true, DataFilters: [isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE))], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/06_ENTREE_URGEN_187909_e137eb1d2a46..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Transport+utilis%C3%A9+%C3%A0+l%27admission:string>
== Physical Plan ==
AdaptiveSparkPlan (80)
+- == Final Plan ==
Execute InsertIntoHadoopFsRelationCommand (47)
+- WriteFiles (46)
+- * Project (45)
+- * Project (44)
+- * Filter (43)
+- * SortMergeJoin LeftOuter (42)
:- * Sort (33)
: +- AQEShuffleRead (32)
: +- ShuffleQueryStage (31), Statistics(sizeInBytes=7.1 MiB, rowCount=4.85E+4)
: +- Exchange (30)
: +- * Project (29)
: +- * SortMergeJoin Inner (28)
: :- * Sort (19)
: : +- AQEShuffleRead (18)
: : +- ShuffleQueryStage (17), Statistics(sizeInBytes=5.5 MiB, rowCount=7.63E+4)
: : +- Exchange (16)
: : +- * Project (15)
: : +- CartesianProduct Inner (14)
: : :- * Project (10)
: : : +- * Filter (9)
: : : +- Window (8)
: : : +- * Sort (7)
: : : +- AQEShuffleRead (6)
: : : +- ShuffleQueryStage (5), Statistics(sizeInBytes=4.3 MiB, rowCount=7.63E+4)
: : : +- Exchange (4)
: : : +- * Project (3)
: : : +- * Filter (2)
: : : +- Scan csv (1)
: : +- * Project (13)
: : +- * Filter (12)
: : +- Scan csv (11)
: +- * Sort (27)
: +- AQEShuffleRead (26)
: +- ShuffleQueryStage (25), Statistics(sizeInBytes=5.1 MiB, rowCount=4.85E+4)
: +- Exchange (24)
: +- * Project (23)
: +- * Filter (22)
: +- * ColumnarToRow (21)
: +- Scan parquet (20)
+- * Sort (41)
+- AQEShuffleRead (40)
+- ShuffleQueryStage (39), Statistics(sizeInBytes=240.0 B, rowCount=7)
+- Exchange (38)
+- * Project (37)
+- * Filter (36)
+- * ColumnarToRow (35)
+- Scan parquet (34)
+- == Initial Plan ==
Execute InsertIntoHadoopFsRelationCommand (79)
+- WriteFiles (78)
+- Project (77)
+- Project (76)
+- Filter (75)
+- SortMergeJoin LeftOuter (74)
:- Sort (69)
: +- Exchange (68)
: +- Project (67)
: +- SortMergeJoin Inner (66)
: :- Sort (61)
: : +- Exchange (60)
: : +- Project (59)
: : +- CartesianProduct Inner (58)
: : :- Project (54)
: : : +- Filter (53)
: : : +- Window (52)
: : : +- Sort (51)
: : : +- Exchange (50)
: : : +- Project (49)
: : : +- Filter (48)
: : : +- Scan csv (1)
: : +- Project (57)
: : +- Filter (56)
: : +- Scan csv (55)
: +- Sort (65)
: +- Exchange (64)
: +- Project (63)
: +- Filter (62)
: +- Scan parquet (20)
+- Sort (73)
+- Exchange (72)
+- Project (71)
+- Filter (70)
+- Scan parquet (34)
(1) Scan csv
Output [2]: [Numéro Séjour#638809, Transport admission#638813]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/02_PASSAGE_PATI_187896/passage_patient_Besancon_M122025.csv]
PushedFilters: [IsNotNull(Numéro Séjour)]
ReadSchema: struct<Numéro Séjour:string,Transport admission:string>
(2) Filter [codegen id : 1]
Input [2]: [Numéro Séjour#638809, Transport admission#638813]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#638809, #)) THEN false ELSE StartsWith(Numéro Séjour#638809, #) END AND isnotnull(Numéro Séjour#638809))
(3) Project [codegen id : 1]
Output [2]: [Numéro Séjour#638809 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, str_remove_space(Transport admission#638813, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Input [2]: [Numéro Séjour#638809, Transport admission#638813]
(4) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 10), ENSURE_REQUIREMENTS, [plan_id=401436]
(5) ShuffleQueryStage
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: 0
(6) AQEShuffleRead
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: coalesced
(7) Sort [codegen id : 4]
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(8) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925], [1 DESC NULLS LAST]
(9) Filter [codegen id : 5]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941 <=> 1)
(10) Project [codegen id : 5]
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941]
(11) Scan csv
Output [2]: [REGLES#637813, APPLICABLE#637814]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_187903/REGLES-A-TTT new BESANCON 050226.csv]
PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)]
ReadSchema: struct<REGLES:string,APPLICABLE:string>
(12) Filter [codegen id : 6]
Input [2]: [REGLES#637813, APPLICABLE#637814]
Condition : ((isnotnull(REGLES#637813) AND (RC-SUM = REGLES#637813)) AND (APPLICABLE#637814 <=> O))
(13) Project [codegen id : 6]
Output [1]: [APPLICABLE#637814 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015]
Input [2]: [REGLES#637813, APPLICABLE#637814]
(14) CartesianProduct
Join type: Inner
Join condition: None
(15) Project [codegen id : 7]
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015]
(16) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, 10), ENSURE_REQUIREMENTS, [plan_id=401877]
(17) ShuffleQueryStage
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: 3
(18) AQEShuffleRead
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: coalesced
(19) Sort [codegen id : 8]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005 ASC NULLS FIRST], false, 0
(20) Scan parquet
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
Batched: true
Location: InMemoryFileIndex [file:/data/output/cache/parquet/datablock/03_PIVOT_INFORM_188182]
PushedFilters: [IsNotNull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F), IsNotNull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8)]
ReadSchema: struct<COL_F1E7803C_F059_4667_8E32_963E2B3DA65F:string,COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8:string,COL_5F8E1D72_6344_42AB_A08C_3B4735439F46:string,COL_60F7C888_9836_4535_A22F_D43D2994E019:string>
(21) ColumnarToRow [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
(22) Filter [codegen id : 2]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087))
(23) Project [codegen id : 2]
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
(24) Exchange
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 10), ENSURE_REQUIREMENTS, [plan_id=401463]
(25) ShuffleQueryStage
Output [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: 1
(26) AQEShuffleRead
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: coalesced
(27) Sort [codegen id : 9]
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421 ASC NULLS FIRST], false, 0
(28) SortMergeJoin [codegen id : 10]
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005]
Right keys [1]: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421]
Join type: Inner
Join condition: None
(29) Project [codegen id : 10]
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
(30) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 10), ENSURE_REQUIREMENTS, [plan_id=402438]
(31) ShuffleQueryStage
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: 4
(32) AQEShuffleRead
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: coalesced
(33) Sort [codegen id : 11]
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007 ASC NULLS FIRST], false, 0
(34) Scan parquet
Output [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/06_ENTREE_URGEN_187909_e137eb1d2a46d57c6a1739d46212ce0c/Info_Etab_init_v1.1 CHU Besançon 310126.xlsx_6f66514fc3c14c4f5ed87e98ec6cdc0f]
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#638557]
(36) Filter [codegen id : 3]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE))
(37) Project [codegen id : 3]
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE) AS 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557]
(38) Exchange
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789, 10), ENSURE_REQUIREMENTS, [plan_id=401495]
(39) ShuffleQueryStage
Output [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: 2
(40) AQEShuffleRead
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: coalesced
(41) Sort [codegen id : 12]
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 ASC NULLS FIRST], false, 0
(42) SortMergeJoin [codegen id : 13]
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007]
Right keys [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Join type: LeftOuter
Join condition: None
(43) Filter [codegen id : 13]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) <=> ))
(44) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
(45) Project [codegen id : 13]
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#640436, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#640439]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258]
(46) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#640436, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#640439]
(47) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_188120, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_188120], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]
(48) Filter
Input [2]: [Numéro Séjour#638809, Transport admission#638813]
Condition : (NOT CASE WHEN isnull(StartsWith(Numéro Séjour#638809, #)) THEN false ELSE StartsWith(Numéro Séjour#638809, #) END AND isnotnull(Numéro Séjour#638809))
(49) Project
Output [2]: [Numéro Séjour#638809 AS COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, str_remove_space(Transport admission#638813, ONLY_ONE) AS COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Input [2]: [Numéro Séjour#638809, Transport admission#638813]
(50) Exchange
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: hashpartitioning(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 10), ENSURE_REQUIREMENTS, [plan_id=401344]
(51) Sort
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 ASC NULLS FIRST, 1 DESC NULLS LAST], false, 0
(52) Window
Input [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927]
Arguments: [row_number() windowspecdefinition(COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, 1 DESC NULLS LAST, specifiedwindowframe(RowFrame, unboundedpreceding$(), currentrow$())) AS COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941], [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925], [1 DESC NULLS LAST]
(53) Filter
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941]
Condition : (COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941 <=> 1)
(54) Project
Output [2]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925 AS COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927 AS COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007]
Input [3]: [COL_2AF4FE05_74B1_4A24_9BC1_7612D6ED731D#638925, COL_E1010A22_775B_43B4_B8CA_4603C0801D28#638927, COL_6B340AEB_6908_4A50_8AD6_FE561D33FBE0#638941]
(55) Scan csv
Output [2]: [REGLES#637813, APPLICABLE#637814]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/REGLES_APPLICAB_187903/REGLES-A-TTT new BESANCON 050226.csv]
PushedFilters: [IsNotNull(REGLES), EqualTo(REGLES,RC-SUM), EqualNullSafe(APPLICABLE,O)]
ReadSchema: struct<REGLES:string,APPLICABLE:string>
(56) Filter
Input [2]: [REGLES#637813, APPLICABLE#637814]
Condition : ((isnotnull(REGLES#637813) AND (RC-SUM = REGLES#637813)) AND (APPLICABLE#637814 <=> O))
(57) Project
Output [1]: [APPLICABLE#637814 AS REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015]
Input [2]: [REGLES#637813, APPLICABLE#637814]
(58) CartesianProduct
Join type: Inner
Join condition: None
(59) Project
Output [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015 AS COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, REGLES_A_APPLIQ_188031_APPLICABLE_188033#639015]
(60) Exchange
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: hashpartitioning(COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, 10), ENSURE_REQUIREMENTS, [plan_id=401355]
(61) Sort
Input [3]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005 ASC NULLS FIRST], false, 0
(62) Filter
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
Condition : ((isnotnull(COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083) AND NOT CASE WHEN isnull(StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #)) THEN false ELSE StartsWith(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, #) END) AND isnotnull(COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087))
(63) Project
Output [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083 AS 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087 AS 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088 AS 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095 AS 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Input [4]: [COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#638083, COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#638087, COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#638088, COL_60F7C888_9836_4535_A22F_D43D2994E019#638095]
(64) Exchange
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: hashpartitioning(03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 10), ENSURE_REQUIREMENTS, [plan_id=401356]
(65) Sort
Input [4]: [03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
Arguments: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421 ASC NULLS FIRST], false, 0
(66) SortMergeJoin
Left keys [1]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005]
Right keys [1]: [03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421]
Join type: Inner
Join condition: None
(67) Project
Output [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429 AS COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417 AS COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422 AS COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 03_PIVOT_INFORM_188182_COL_F1E7803C_F059_4667_8E32_963E2B3DA65F#639417, 03_PIVOT_INFORM_188182_COL_582B8737_1AAE_44AC_AF57_EB71A05E19B8#639421, 03_PIVOT_INFORM_188182_COL_5F8E1D72_6344_42AB_A08C_3B4735439F46#639422, 03_PIVOT_INFORM_188182_COL_60F7C888_9836_4535_A22F_D43D2994E019#639429]
(68) Exchange
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: hashpartitioning(COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 10), ENSURE_REQUIREMENTS, [plan_id=401365]
(69) Sort
Input [6]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277]
Arguments: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007 ASC NULLS FIRST], false, 0
(70) Filter
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557]
Condition : isnotnull(str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE))
(71) Project
Output [1]: [str_remove_space(Transport+utilis%C3%A9+%C3%A0+l%27admission#638557, ONLY_ONE) AS 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Input [1]: [Transport+utilis%C3%A9+%C3%A0+l%27admission#638557]
(72) Exchange
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: hashpartitioning(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789, 10), ENSURE_REQUIREMENTS, [plan_id=401366]
(73) Sort
Input [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Arguments: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 ASC NULLS FIRST], false, 0
(74) SortMergeJoin
Left keys [1]: [COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007]
Right keys [1]: [06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Join type: LeftOuter
Join condition: None
(75) Filter
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
Condition : (isnotnull(str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null))) AND NOT (str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) <=> ))
(76) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789 AS COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule((CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM-, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), str_if_with_rule((NOT CASE WHEN isnull(Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM)) THEN false ELSE Contains(COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, SUM) END AND isnotnull(06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789)), str_join(array(SUM+, !, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), ), null)) AS COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_create(RC-SUM) AS COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258]
Input [7]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_B82C3EFD_07A4_496B_9BD7_0D2B4E3458A8#639774, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, 06_ENTREE_URGEN_188009_TRANSPORT_UTILI_188010#639789]
(77) Project
Output [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, str_if_with_rule((isnotnull(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246) AND NOT (COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246 <=> )), str_join(array(str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, +) END, str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Switch de forfait (SUM*), Ajout de forfait), str_if_with_rule(CASE WHEN isnull(Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -)) THEN false ELSE Contains(COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, -) END, Suppression de Forfait, )), COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777), @), ) AS COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#640436, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, str_if_with_rule(isnotnull(COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), str_join(array(Transport Eligible SUM, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232), : ), str_join(array(Transport Non Eligible SUM , COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007), : )) AS COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#640439]
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_D98BB81A_010E_4A93_9951_E277D8CF157A#639007, COL_FD823B89_B169_4B25_9EAB_581D44D543B2#640232, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258]
(78) WriteFiles
Input [8]: [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5#639005, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557#639776, COL_5047AF2B_F05A_487E_9152_F4FE82797C45#640258, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0#640246, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569#640436, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153#639777, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135#639277, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7#640439]
(79) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: file:/data/output/cache/parquet/datablock/05_GR4_SUM_188120, false, Parquet, [path=file:///data/output/cache/parquet/datablock/05_GR4_SUM_188120], Overwrite, [COL_A2523D82_F590_40F1_85E5_30011BEEEDF5, COL_02D44CEA_1031_4290_8F23_AB2C6AE7B557, COL_5047AF2B_F05A_487E_9152_F4FE82797C45, COL_070B5B98_14EA_42D5_A6A0_7EDB0FD6E2B0, COL_FEC7AB55_AB69_43FE_9E2B_2AC5EA7FE569, COL_E5B890C4_5DF6_4B3D_B992_5BFD4F692153, COL_D744E1A7_E834_46FC_A00F_DFB5E9D2E135, COL_786AACC4_3E04_4312_A7F0_A2F045C018D7]
(80) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true