== Physical Plan ==
CollectLimit (4)
+- * Project (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
(1) Scan parquet
Output [5]: [colonne#292875, type_infere#292877, all_pct_null_nan#292880, source#292942, id_source#292944]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/parquet/execution/ALL_ANALYSE_API_REF/current/pydc_hd8616ql.parquet]
ReadSchema: struct<colonne:string,type_infere:string,all_pct_null_nan:double,source:string,id_source:string>
(2) ColumnarToRow [codegen id : 1]
Input [5]: [colonne#292875, type_infere#292877, all_pct_null_nan#292880, source#292942, id_source#292944]
(3) Project [codegen id : 1]
Output [4]: [colonne#292875 AS COL_A8CEFC79_279F_4481_89A8_6518EDC9E59A#296611, all_pct_null_nan#292880 AS COL_5C0273B8_BCA8_462A_A3BA_5C34A6B95257#296612, str_concat(array(source#292942, (, id_source#292944, ))) AS COL_20CD8109_ACD4_4213_A022_EF37B7ED5F35#296613, type_infere#292877 AS COL_9346FA13_252D_4E74_9BEF_70A93E8D1240#296614]
Input [5]: [colonne#292875, type_infere#292877, all_pct_null_nan#292880, source#292942, id_source#292944]
(4) CollectLimit
Input [4]: [COL_A8CEFC79_279F_4481_89A8_6518EDC9E59A#296611, COL_5C0273B8_BCA8_462A_A3BA_5C34A6B95257#296612, COL_20CD8109_ACD4_4213_A022_EF37B7ED5F35#296613, COL_9346FA13_252D_4E74_9BEF_70A93E8D1240#296614]
Arguments: 500000