digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: total (min, med, max (stageId: taskId))\n199 ms (16 ms, 36 ms, 41 ms (stage 468.0: task 488))";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<br><b>Project</b><br><br>"];
4 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 1,104<br>number of input batches: 12"];
}
5 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 12<br>scan time total (min, med, max (stageId: taskId))<br>36 ms (5 ms, 6 ms, 7 ms (stage 468.0: task 488))<br>metadata time: 0 ms<br>size of files read: 60.3 KiB<br>number of output rows: 1,104"];
2->0;
3->2;
4->3;
5->4;
}
6
CollectLimit 1500
Project [COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, COL_84669589_3EDF_4867_8128_B2F334719709#76927, COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953, str_join(array(COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953), ) AS COL_96752C46_5D61_4995_9B22_B6F3C38A6B04#76983]
Project [Portefeuille#76778 AS COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, Civilit%C3%A9#76779 AS COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, Nom#76780 AS COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, Id+Mandat#76781 AS COL_84669589_3EDF_4867_8128_B2F334719709#76927, N%C2%B0+Registre#76782 AS COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, Taux+Honoraire#76783 AS COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, str_if_with_rule(CASE WHEN isnull(Contains(Taux+Honoraire#76783, - 0)) THEN false ELSE Contains(Taux+Honoraire#76783, - 0) END, Absence Taux, ) AS COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, RANKING_RESULTS_CONNECTOR(STOP_IF_TRUE, null, array(RANKING_STRING(Civilit%C3%A9#76779, Madame, equal, [Madame], [], true, MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Monsieur, equal, [MONSIEUR], [], true, MR, , null), RANKING_STRING(Civilit%C3%A9#76779, M et Mme, equal, [M ET MME], [], true, M_ET_MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Succession, equal, [Succession], [], true, SUCCESSION, , null), RANKING_STRING(Civilit%C3%A9#76779, Ind., equal, [IND.], [], true, IND., , null), RANKING_STRING(Civilit%C3%A9#76779, Consorts, equal, [CONSORTS], [], true, CONSORT, , null), RANKING_STRING(Civilit%C3%A9#76779, SCI, equal, [SCI], [], true, SCI, , null), RANKING_STRING(Civilit%C3%A9#76779, SARL, equal, [SARL], [], true, SARL, , null), RANKING_STRING(Civilit%C3%A9#76779, Indivision, equal, [INDIVISION], [], true, INDIVISION, , null), RANKING_STRING(Civilit%C3%A9#76779, M ou Mme, equal, [M OU MME], [], true, M_OU_MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Messieurs, equal, [MESSIEURS], [], true, MM, , null))) AS COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, str_remove_space(str_remove_accent(str_transform_case(Nom#76780, UPPER)), ONLY_ONE) AS COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953]
ColumnarToRow
WholeStageCodegen (1)
FileScan parquet [Portefeuille#76778,Civilit%C3%A9#76779,Nom#76780,Id+Mandat#76781,N%C2%B0+Registre#76782,Taux+Honoraire#76783] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/excel/cache/1210D38A_30A1_417E_AC30_A633AB773A4..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<Portefeuille:string,Civilit%C3%A9:string,Nom:string,Id+Mandat:string,N%C2%B0+Registre:stri...
== Physical Plan ==
CollectLimit (5)
+- * Project (4)
+- * Project (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
(1) Scan parquet
Output [6]: [Portefeuille#76778, Civilit%C3%A9#76779, Nom#76780, Id+Mandat#76781, N%C2%B0+Registre#76782, Taux+Honoraire#76783]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/excel/cache/1210D38A_30A1_417E_AC30_A633AB773A43_79471ac0595e0f84c440113d58d8281c/PROPRIETAIRES_Laneco_Base.xls_afce3e2f319a0b3bd204c24dc83c5faa]
ReadSchema: struct<Portefeuille:string,Civilit%C3%A9:string,Nom:string,Id+Mandat:string,N%C2%B0+Registre:string,Taux+Honoraire:string>
(2) ColumnarToRow [codegen id : 1]
Input [6]: [Portefeuille#76778, Civilit%C3%A9#76779, Nom#76780, Id+Mandat#76781, N%C2%B0+Registre#76782, Taux+Honoraire#76783]
(3) Project [codegen id : 1]
Output [9]: [Portefeuille#76778 AS COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, Civilit%C3%A9#76779 AS COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, Nom#76780 AS COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, Id+Mandat#76781 AS COL_84669589_3EDF_4867_8128_B2F334719709#76927, N%C2%B0+Registre#76782 AS COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, Taux+Honoraire#76783 AS COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, str_if_with_rule(CASE WHEN isnull(Contains(Taux+Honoraire#76783, - 0)) THEN false ELSE Contains(Taux+Honoraire#76783, - 0) END, Absence Taux, ) AS COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, RANKING_RESULTS_CONNECTOR(STOP_IF_TRUE, null, array(RANKING_STRING(Civilit%C3%A9#76779, Madame, equal, [Madame], [], true, MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Monsieur, equal, [MONSIEUR], [], true, MR, , null), RANKING_STRING(Civilit%C3%A9#76779, M et Mme, equal, [M ET MME], [], true, M_ET_MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Succession, equal, [Succession], [], true, SUCCESSION, , null), RANKING_STRING(Civilit%C3%A9#76779, Ind., equal, [IND.], [], true, IND., , null), RANKING_STRING(Civilit%C3%A9#76779, Consorts, equal, [CONSORTS], [], true, CONSORT, , null), RANKING_STRING(Civilit%C3%A9#76779, SCI, equal, [SCI], [], true, SCI, , null), RANKING_STRING(Civilit%C3%A9#76779, SARL, equal, [SARL], [], true, SARL, , null), RANKING_STRING(Civilit%C3%A9#76779, Indivision, equal, [INDIVISION], [], true, INDIVISION, , null), RANKING_STRING(Civilit%C3%A9#76779, M ou Mme, equal, [M OU MME], [], true, M_OU_MME, , null), RANKING_STRING(Civilit%C3%A9#76779, Messieurs, equal, [MESSIEURS], [], true, MM, , null))) AS COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, str_remove_space(str_remove_accent(str_transform_case(Nom#76780, UPPER)), ONLY_ONE) AS COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953]
Input [6]: [Portefeuille#76778, Civilit%C3%A9#76779, Nom#76780, Id+Mandat#76781, N%C2%B0+Registre#76782, Taux+Honoraire#76783]
(4) Project [codegen id : 1]
Output [10]: [COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, COL_84669589_3EDF_4867_8128_B2F334719709#76927, COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953, str_join(array(COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953), ) AS COL_96752C46_5D61_4995_9B22_B6F3C38A6B04#76983]
Input [9]: [COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, COL_84669589_3EDF_4867_8128_B2F334719709#76927, COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953]
(5) CollectLimit
Input [10]: [COL_5CE62B0F_C8B6_403A_BC06_6D127FD5EFFF#76924, COL_B7606B94_B63C_4AC8_85DC_76BF33699940#76925, COL_8118CDA6_09D5_4FBE_9754_F3DCADC3F2CB#76926, COL_84669589_3EDF_4867_8128_B2F334719709#76927, COL_BB923AB9_180A_4698_AD19_3E6D6C901BD7#76928, COL_79B2AE2E_91DA_45D0_8FAD_B2A696E7D6AF#76929, COL_1BDC3498_C4CC_4B85_B455_EA2C1F8F15D7#76936, COL_17F69EDB_8ED1_41D8_B647_A4169C7B4BBA#76944, COL_31F3DB3A_17F8_4175_BE1B_49D5880B49DF#76953, COL_96752C46_5D61_4995_9B22_B6F3C38A6B04#76983]
Arguments: 1500