digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>ColumnarToRow</b><br><br>number of output rows: 4,096<br>number of input batches: 1"];
}
4 [labelType="html" label="<b>Scan parquet </b><br><br>number of files read: 1<br>scan time: 6 ms<br>metadata time: 0 ms<br>size of files read: 256.4 KiB<br>number of output rows: 4,096"];
2->0;
3->2;
4->3;
}
5
CollectLimit 500
Project [IPP+#428908 AS IPP #428932, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE+ETAB#428918 AS CODE ETAB#429063, NOM+ETAB#428919 AS NOM ETAB#429076]
ColumnarToRow
WholeStageCodegen (1)
FileScan parquet [IPP+#428908,NOM_FAM#428909,PRENOM#428910,NOM_NAISSANCE#428911,NATIONALITE#428912,SEXE#428913,CIVILITE#428914,DATE_NAIS#428915,FINESS_ETAB#428916,INSC#428917,CODE+ETAB#428918,NOM+ETAB#428919] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/data/input/depot/csv/execution/A04A40C4_E816_454D_A2EF_8C6C991C4..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<IPP+:string,NOM_FAM:string,PRENOM:string,NOM_NAISSANCE:string,NATIONALITE:string,SEXE:stri...
== Physical Plan ==
CollectLimit (4)
+- * Project (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
(1) Scan parquet
Output [12]: [IPP+#428908, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE+ETAB#428918, NOM+ETAB#428919]
Batched: true
Location: InMemoryFileIndex [file:/data/input/depot/csv/execution/A04A40C4_E816_454D_A2EF_8C6C991C44BC/extraction/date_8dc824f6eb35312b8bcc10f4361cce8f=2026-08-31 13%3A49%3A11.992063/part-00000-acdf0190-054c-45fb-8945-56b8c90ac356.c000.snappy.parquet]
ReadSchema: struct<IPP+:string,NOM_FAM:string,PRENOM:string,NOM_NAISSANCE:string,NATIONALITE:string,SEXE:string,CIVILITE:string,DATE_NAIS:string,FINESS_ETAB:string,INSC:string,CODE+ETAB:string,NOM+ETAB:string>
(2) ColumnarToRow [codegen id : 1]
Input [12]: [IPP+#428908, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE+ETAB#428918, NOM+ETAB#428919]
(3) Project [codegen id : 1]
Output [12]: [IPP+#428908 AS IPP #428932, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE+ETAB#428918 AS CODE ETAB#429063, NOM+ETAB#428919 AS NOM ETAB#429076]
Input [12]: [IPP+#428908, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE+ETAB#428918, NOM+ETAB#428919]
(4) CollectLimit
Input [12]: [IPP #428932, NOM_FAM#428909, PRENOM#428910, NOM_NAISSANCE#428911, NATIONALITE#428912, SEXE#428913, CIVILITE#428914, DATE_NAIS#428915, FINESS_ETAB#428916, INSC#428917, CODE ETAB#429063, NOM ETAB#429076]
Arguments: 500