digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster2 {
isCluster="true";
label="WholeStageCodegen (8)\n \nduration: 72 ms";
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 1"];
5 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6,443<br>spill size: 0.0 B"];
}
subgraph cluster6 {
isCluster="true";
label="WholeStageCodegen (6)\n \nduration: 73 ms";
7 [labelType="html" label="<br><b>Project</b><br><br>"];
8 [labelType="html" label="<b>SortMergeJoin</b><br><br>number of output rows: 6,443<br>spill size: 0.0 B"];
}
subgraph cluster9 {
isCluster="true";
label="WholeStageCodegen (4)\n \nduration: 75 ms";
10 [labelType="html" label="<b>Sort</b><br><br>sort time: 3 ms<br>peak memory: 16.3 MiB<br>spill size: 0.0 B"];
}
11 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 77.2 KiB<br>number of coalesced partitions: 1"];
12 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 6,443<br>local merged chunks fetched: 0<br>shuffle write time: 1 ms<br>remote merged bytes read: 0.0 B<br>local merged blocks fetched: 0<br>corrupt merged block chunks: 0<br>remote merged reqs duration: 0 ms<br>remote merged blocks fetched: 0<br>records read: 6,443<br>local bytes read: 74.9 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: 302.0 KiB<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: 74.9 KiB"];
subgraph cluster13 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 32 ms";
14 [labelType="html" label="<br><b>Project</b><br><br>"];
15 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 6,443"];
}
16 [labelType="html" label="<b>Scan csv </b><br><br>number of output rows: 6,443<br>number of files read: 1<br>metadata time: 0 ms<br>size of files read: 95.2 KiB"];
subgraph cluster17 {
isCluster="true";
label="WholeStageCodegen (5)\n \nduration: 10.3 s";
18 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
19 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 19.3 KiB<br>number of coalesced partitions: 1"];
20 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 1,470<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: 1,470<br>local bytes read: 18.2 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: 57.4 KiB<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: 18.2 KiB"];
subgraph cluster21 {
isCluster="true";
label="WholeStageCodegen (2)\n \nduration: 15 ms";
22 [labelType="html" label="<br><b>Project</b><br><br>"];
23 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 1,470"];
24 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 1,470<br>number of input batches: 1"];
}
25 [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: 42.4 KiB<br>number of output rows: 1,470"];
subgraph cluster26 {
isCluster="true";
label="WholeStageCodegen (7)\n \nduration: 584 ms";
27 [labelType="html" label="<b>Sort</b><br><br>sort time: 0 ms<br>peak memory: 16.1 MiB<br>spill size: 0.0 B"];
}
28 [labelType="html" label="<b>AQEShuffleRead</b><br><br>number of partitions: 1<br>partition data size: 32.6 KiB<br>number of coalesced partitions: 1"];
29 [labelType="html" label="<b>Exchange</b><br><br>shuffle records written: 2,575<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: 2,575<br>local bytes read: 31.2 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: 100.6 KiB<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: 31.2 KiB"];
subgraph cluster30 {
isCluster="true";
label="WholeStageCodegen (3)\n \nduration: 21 ms";
31 [labelType="html" label="<br><b>Project</b><br><br>"];
32 [labelType="html" label="<b>Filter</b><br><br>number of output rows: 2,575"];
33 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 2,577<br>number of input batches: 1"];
}
34 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 4 ms<br>metadata time: 0 ms<br>size of files read: 57.3 KiB<br>number of output rows: 2,577"];
1->0;
3->1;
4->3;
5->4;
7->5;
8->7;
10->8;
11->10;
12->11;
14->12;
15->14;
16->15;
18->8;
19->18;
20->19;
22->20;
23->22;
24->23;
25->24;
27->5;
28->27;
29->28;
31->29;
32->31;
33->32;
34->33;
}
35
AdaptiveSparkPlan isFinalPlan=true
CollectLimit 1500
Project [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1106504, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Filter ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), 001503492)) THEN false ELSE Contains(str_remove_accent(null), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492) END)
SortMergeJoin [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433], [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523], LeftOuter
WholeStageCodegen (8)
Project [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503]
SortMergeJoin [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433], [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451], LeftOuter
WholeStageCodegen (6)
Sort [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433 ASC NULLS FIRST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, 10), ENSURE_REQUIREMENTS, [plan_id=718760]
Project [str_complete(str_remove_space(Numéro Séjour#1105809, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, str_remove_extend(str_remove_space(code_Cim10#1105810, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Filter isnotnull(code_Cim10#1105810)
WholeStageCodegen (1)
FileScan csv [Numéro Séjour#1105809,code_Cim10#1105810] Batched: false, DataFilters: [isnotnull(code_Cim10#1105810)], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/tmp/04_DIAGNOSTICS__232711/diag_Patient_Dec..., PartitionFilters: [], PushedFilters: [IsNotNull(code_Cim10)], ReadSchema: struct<Numéro Séjour:string,code_Cim10:string>
Sort [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451 ASC NULLS FIRST], false, 0
WholeStageCodegen (5)
AQEShuffleRead coalesced
Exchange hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451, 10), ENSURE_REQUIREMENTS, [plan_id=718787]
Project [str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Filter isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT))
ColumnarToRow
WholeStageCodegen (2)
FileScan parquet [Code+CIM+10#1106166] Batched: true, DataFilters: [isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/DIAGNOSTIC_PE1__232729_6a2f250cf05f..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Code+CIM+10:string>
Sort [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523 ASC NULLS FIRST], false, 0
WholeStageCodegen (7)
AQEShuffleRead coalesced
Exchange hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523, 10), ENSURE_REQUIREMENTS, [plan_id=718817]
Project [str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Filter isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Code+CIM+10#1106279] Batched: true, DataFilters: [isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106..., Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/DIAGNOSTIC_PE2__232731_3f61f47cf25f..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Code+CIM+10:string>
== Physical Plan ==
AdaptiveSparkPlan (48)
+- == Final Plan ==
CollectLimit (29)
+- * Project (28)
+- * Filter (27)
+- * SortMergeJoin LeftOuter (26)
:- * Project (17)
: +- * SortMergeJoin LeftOuter (16)
: :- * Sort (7)
: : +- AQEShuffleRead (6)
: : +- ShuffleQueryStage (5), Statistics(sizeInBytes=302.0 KiB, rowCount=6.44E+3)
: : +- Exchange (4)
: : +- * Project (3)
: : +- * Filter (2)
: : +- Scan csv (1)
: +- * Sort (15)
: +- AQEShuffleRead (14)
: +- ShuffleQueryStage (13), Statistics(sizeInBytes=57.4 KiB, rowCount=1.47E+3)
: +- Exchange (12)
: +- * Project (11)
: +- * Filter (10)
: +- * ColumnarToRow (9)
: +- Scan parquet (8)
+- * Sort (25)
+- AQEShuffleRead (24)
+- ShuffleQueryStage (23), Statistics(sizeInBytes=100.6 KiB, rowCount=2.58E+3)
+- Exchange (22)
+- * Project (21)
+- * Filter (20)
+- * ColumnarToRow (19)
+- Scan parquet (18)
+- == Initial Plan ==
CollectLimit (47)
+- Project (46)
+- Filter (45)
+- SortMergeJoin LeftOuter (44)
:- Project (39)
: +- SortMergeJoin LeftOuter (38)
: :- Sort (33)
: : +- Exchange (32)
: : +- Project (31)
: : +- Filter (30)
: : +- Scan csv (1)
: +- Sort (37)
: +- Exchange (36)
: +- Project (35)
: +- Filter (34)
: +- Scan parquet (8)
+- Sort (43)
+- Exchange (42)
+- Project (41)
+- Filter (40)
+- Scan parquet (18)
(1) Scan csv
Output [2]: [Numéro Séjour#1105809, code_Cim10#1105810]
Batched: false
Location: InMemoryFileIndex [file:/data/input/depot/csv/tmp/04_DIAGNOSTICS__232711/diag_Patient_Decize_M122026.csv]
PushedFilters: [IsNotNull(code_Cim10)]
ReadSchema: struct<Numéro Séjour:string,code_Cim10:string>
(2) Filter [codegen id : 1]
Input [2]: [Numéro Séjour#1105809, code_Cim10#1105810]
Condition : isnotnull(code_Cim10#1105810)
(3) Project [codegen id : 1]
Output [2]: [str_complete(str_remove_space(Numéro Séjour#1105809, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, str_remove_extend(str_remove_space(code_Cim10#1105810, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Input [2]: [Numéro Séjour#1105809, code_Cim10#1105810]
(4) Exchange
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, 10), ENSURE_REQUIREMENTS, [plan_id=718760]
(5) ShuffleQueryStage
Output [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: 0
(6) AQEShuffleRead
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: coalesced
(7) Sort [codegen id : 4]
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433 ASC NULLS FIRST], false, 0
(8) Scan parquet
Output [1]: [Code+CIM+10#1106166]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/DIAGNOSTIC_PE1__232729_6a2f250cf05f476ed96a1382aa0a10be/DP_PE1.xlsx_79352aa69ee87d1295d25aed11f23511]
ReadSchema: struct<Code+CIM+10:string>
(9) ColumnarToRow [codegen id : 2]
Input [1]: [Code+CIM+10#1106166]
(10) Filter [codegen id : 2]
Input [1]: [Code+CIM+10#1106166]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT))
(11) Project [codegen id : 2]
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Input [1]: [Code+CIM+10#1106166]
(12) Exchange
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451, 10), ENSURE_REQUIREMENTS, [plan_id=718787]
(13) ShuffleQueryStage
Output [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: 1
(14) AQEShuffleRead
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: coalesced
(15) Sort [codegen id : 5]
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451 ASC NULLS FIRST], false, 0
(16) SortMergeJoin [codegen id : 6]
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Right keys [1]: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Join type: LeftOuter
Join condition: None
(17) Project [codegen id : 6]
Output [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503]
Input [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
(18) Scan parquet
Output [1]: [Code+CIM+10#1106279]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/DIAGNOSTIC_PE2__232731_3f61f47cf25f2cffe6faba07f2a57dc7/DP_PE2.xlsx_8e052a790a9bc5b8446216002454c960]
ReadSchema: struct<Code+CIM+10:string>
(19) ColumnarToRow [codegen id : 3]
Input [1]: [Code+CIM+10#1106279]
(20) Filter [codegen id : 3]
Input [1]: [Code+CIM+10#1106279]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT))
(21) Project [codegen id : 3]
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Input [1]: [Code+CIM+10#1106279]
(22) Exchange
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523, 10), ENSURE_REQUIREMENTS, [plan_id=718817]
(23) ShuffleQueryStage
Output [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: 2
(24) AQEShuffleRead
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: coalesced
(25) Sort [codegen id : 7]
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523 ASC NULLS FIRST], false, 0
(26) SortMergeJoin [codegen id : 8]
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Right keys [1]: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Join type: LeftOuter
Join condition: None
(27) Filter [codegen id : 8]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), 001503492)) THEN false ELSE Contains(str_remove_accent(null), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492) END)
(28) Project [codegen id : 8]
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1106504, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
(29) CollectLimit
Input [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, COL_63526921_A0EA_4239_B888_806A810EA728#1106504, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Arguments: 1500
(30) Filter
Input [2]: [Numéro Séjour#1105809, code_Cim10#1105810]
Condition : isnotnull(code_Cim10#1105810)
(31) Project
Output [2]: [str_complete(str_remove_space(Numéro Séjour#1105809, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, str_remove_extend(str_remove_space(code_Cim10#1105810, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Input [2]: [Numéro Séjour#1105809, code_Cim10#1105810]
(32) Exchange
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, 10), ENSURE_REQUIREMENTS, [plan_id=718735]
(33) Sort
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Arguments: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433 ASC NULLS FIRST], false, 0
(34) Filter
Input [1]: [Code+CIM+10#1106166]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT))
(35) Project
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106166, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Input [1]: [Code+CIM+10#1106166]
(36) Exchange
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451, 10), ENSURE_REQUIREMENTS, [plan_id=718736]
(37) Sort
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Arguments: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451 ASC NULLS FIRST], false, 0
(38) SortMergeJoin
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Right keys [1]: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
Join type: LeftOuter
Join condition: None
(39) Project
Output [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503]
Input [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1106445, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1106451]
(40) Filter
Input [1]: [Code+CIM+10#1106279]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT))
(41) Project
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1106279, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Input [1]: [Code+CIM+10#1106279]
(42) Exchange
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523, 10), ENSURE_REQUIREMENTS, [plan_id=718743]
(43) Sort
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Arguments: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523 ASC NULLS FIRST], false, 0
(44) SortMergeJoin
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433]
Right keys [1]: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Join type: LeftOuter
Join condition: None
(45) Filter
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1106432)), 001503492) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), 001503492)) THEN false ELSE Contains(str_remove_accent(null), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517)), 001503492) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0))), 001503492) END)
(46) Project
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1106504, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1106517, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1106523]
(47) CollectLimit
Input [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, COL_63526921_A0EA_4239_B888_806A810EA728#1106504, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Arguments: 1500
(48) AdaptiveSparkPlan
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1106432, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1106433, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1106502, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1106503, COL_63526921_A0EA_4239_B888_806A810EA728#1106504, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1106575, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1106576]
Arguments: isFinalPlan=true