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: 108"];
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: 96 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: 98 ms";
10 [labelType="html" label="<b>Sort</b><br><br>sort time: 1 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: 29 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: 13.5 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: 17 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: 4 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: 760 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: 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: 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: 3 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#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1105534, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Filter ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), R531)) THEN false ELSE Contains(str_remove_accent(null), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531) END)
SortMergeJoin [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463], [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553], LeftOuter
WholeStageCodegen (8)
Project [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533]
SortMergeJoin [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463], [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481], LeftOuter
WholeStageCodegen (6)
Sort [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463 ASC NULLS FIRST], false, 0
WholeStageCodegen (4)
AQEShuffleRead coalesced
Exchange hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, 10), ENSURE_REQUIREMENTS, [plan_id=717858]
Project [str_complete(str_remove_space(Numéro Séjour#1104839, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, str_remove_extend(str_remove_space(code_Cim10#1104840, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Filter isnotnull(code_Cim10#1104840)
WholeStageCodegen (1)
FileScan csv [Numéro Séjour#1104839,code_Cim10#1104840] Batched: false, DataFilters: [isnotnull(code_Cim10#1104840)], 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#1105481 ASC NULLS FIRST], false, 0
WholeStageCodegen (5)
AQEShuffleRead coalesced
Exchange hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481, 10), ENSURE_REQUIREMENTS, [plan_id=717885]
Project [str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Filter isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT))
ColumnarToRow
WholeStageCodegen (2)
FileScan parquet [Code+CIM+10#1104874] Batched: true, DataFilters: [isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104..., 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#1105553 ASC NULLS FIRST], false, 0
WholeStageCodegen (7)
AQEShuffleRead coalesced
Exchange hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553, 10), ENSURE_REQUIREMENTS, [plan_id=717915]
Project [str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Filter isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT))
ColumnarToRow
WholeStageCodegen (3)
FileScan parquet [Code+CIM+10#1105309] Batched: true, DataFilters: [isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105..., 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#1104839, code_Cim10#1104840]
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#1104839, code_Cim10#1104840]
Condition : isnotnull(code_Cim10#1104840)
(3) Project [codegen id : 1]
Output [2]: [str_complete(str_remove_space(Numéro Séjour#1104839, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, str_remove_extend(str_remove_space(code_Cim10#1104840, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Input [2]: [Numéro Séjour#1104839, code_Cim10#1104840]
(4) Exchange
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, 10), ENSURE_REQUIREMENTS, [plan_id=717858]
(5) ShuffleQueryStage
Output [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: 0
(6) AQEShuffleRead
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: coalesced
(7) Sort [codegen id : 4]
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463 ASC NULLS FIRST], false, 0
(8) Scan parquet
Output [1]: [Code+CIM+10#1104874]
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#1104874]
(10) Filter [codegen id : 2]
Input [1]: [Code+CIM+10#1104874]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT))
(11) Project [codegen id : 2]
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Input [1]: [Code+CIM+10#1104874]
(12) Exchange
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481, 10), ENSURE_REQUIREMENTS, [plan_id=717885]
(13) ShuffleQueryStage
Output [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: 1
(14) AQEShuffleRead
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: coalesced
(15) Sort [codegen id : 5]
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481 ASC NULLS FIRST], false, 0
(16) SortMergeJoin [codegen id : 6]
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Right keys [1]: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Join type: LeftOuter
Join condition: None
(17) Project [codegen id : 6]
Output [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533]
Input [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
(18) Scan parquet
Output [1]: [Code+CIM+10#1105309]
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#1105309]
(20) Filter [codegen id : 3]
Input [1]: [Code+CIM+10#1105309]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT))
(21) Project [codegen id : 3]
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Input [1]: [Code+CIM+10#1105309]
(22) Exchange
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553, 10), ENSURE_REQUIREMENTS, [plan_id=717915]
(23) ShuffleQueryStage
Output [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: 2
(24) AQEShuffleRead
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: coalesced
(25) Sort [codegen id : 7]
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553 ASC NULLS FIRST], false, 0
(26) SortMergeJoin [codegen id : 8]
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Right keys [1]: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Join type: LeftOuter
Join condition: None
(27) Filter [codegen id : 8]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), R531)) THEN false ELSE Contains(str_remove_accent(null), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531) END)
(28) Project [codegen id : 8]
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1105534, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
(29) CollectLimit
Input [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, COL_63526921_A0EA_4239_B888_806A810EA728#1105534, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Arguments: 1500
(30) Filter
Input [2]: [Numéro Séjour#1104839, code_Cim10#1104840]
Condition : isnotnull(code_Cim10#1104840)
(31) Project
Output [2]: [str_complete(str_remove_space(Numéro Séjour#1104839, ALL), 0, 9, LEFT) AS COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, str_remove_extend(str_remove_space(code_Cim10#1104840, ALL), [.]) AS COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Input [2]: [Numéro Séjour#1104839, code_Cim10#1104840]
(32) Exchange
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: hashpartitioning(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, 10), ENSURE_REQUIREMENTS, [plan_id=717833]
(33) Sort
Input [2]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Arguments: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463 ASC NULLS FIRST], false, 0
(34) Filter
Input [1]: [Code+CIM+10#1104874]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT))
(35) Project
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1104874, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Input [1]: [Code+CIM+10#1104874]
(36) Exchange
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: hashpartitioning(DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481, 10), ENSURE_REQUIREMENTS, [plan_id=717834]
(37) Sort
Input [2]: [DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Arguments: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481 ASC NULLS FIRST], false, 0
(38) SortMergeJoin
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Right keys [1]: [DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
Join type: LeftOuter
Join condition: None
(39) Project
Output [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, str_if_with_rule(isnotnull(DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475), 1, 0) AS COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475 AS COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533]
Input [4]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, DIAGNOSTIC_PE1__232766_CODE_CIM_10_232767#1105475, DIAGNOSTIC_PE1__232766_CODE_CIM10_NORM_232773#1105481]
(40) Filter
Input [1]: [Code+CIM+10#1105309]
Condition : isnotnull(str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT))
(41) Project
Output [2]: [str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, str_remove_space(str_remove_extend(str_remove_space(str_remove_extend(Code+CIM+10#1105309, [.]), RIGHT), [.]), RIGHT) AS DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Input [1]: [Code+CIM+10#1105309]
(42) Exchange
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: hashpartitioning(DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553, 10), ENSURE_REQUIREMENTS, [plan_id=717841]
(43) Sort
Input [2]: [DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Arguments: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553 ASC NULLS FIRST], false, 0
(44) SortMergeJoin
Left keys [1]: [COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463]
Right keys [1]: [DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Join type: LeftOuter
Join condition: None
(45) Filter
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
Condition : ((((((CASE WHEN isnull(Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_A188B73D_4933_4923_828E_687FE72CE189#1105462)), R531) END OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531)) THEN false ELSE Contains(str_remove_accent(upper(COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(null), R531)) THEN false ELSE Contains(str_remove_accent(null), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531)) THEN false ELSE Contains(str_remove_accent(upper(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547)), R531) END) OR CASE WHEN isnull(Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531)) THEN false ELSE Contains(str_remove_accent(upper(str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0))), R531) END)
(46) Project
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, null AS COL_63526921_A0EA_4239_B888_806A810EA728#1105534, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547 AS COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, str_if_with_rule(isnotnull(DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547), 1, 0) AS COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Input [6]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, DIAGNOSTIC_PE2__232849_CODE_CIM_10_232850#1105547, DIAGNOSTIC_PE2__232849_CODE_CIM10_NORM_232856#1105553]
(47) CollectLimit
Input [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, COL_63526921_A0EA_4239_B888_806A810EA728#1105534, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Arguments: 1500
(48) AdaptiveSparkPlan
Output [7]: [COL_A188B73D_4933_4923_828E_687FE72CE189#1105462, COL_D1E62AC3_9D22_4956_8B06_3DF990F627F2#1105463, COL_8E83DA5F_0319_4C71_A57F_EB8028C126EB#1105532, COL_FBBF269F_6C60_4151_97F8_E09621CDA28C#1105533, COL_63526921_A0EA_4239_B888_806A810EA728#1105534, COL_17A0F81D_FDA8_42AC_B142_4E64FA588FEA#1105605, COL_CEA89754_0D9E_4D31_BC11_226DBE26276F#1105606]
Arguments: isFinalPlan=true