digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 91 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT * FROM \"DTM_261\".\"VISIT\") x) [numPartitions=1] </b><br><br>number of output rows: 82"];
}
2->0;
3->2;
}
4
CollectLimit 500
Project [VISIT_ID#46892, PATIENT_ID#46893, ID_SEJ#46894, ID_PAT#46895, IN_DATE#46896, OUT_DATE#46897, IN_MODE#46898, OUT_MODE#46899, IN_UNIT#46900, OUT_UNIT#46901, VISIT_TYPE#46902, CHAMP_PMSI#46903, UNIT_PATH#46904, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#46905, 1, true, false, true) AS EMERGENCY#46907, CANCELED#46906]
Scan JDBCRelation((SELECT * FROM "DTM_261"."VISIT") x) [numPartitions=1] [VISIT_ID#46892,PATIENT_ID#46893,ID_SEJ#46894,ID_PAT#46895,IN_DATE#46896,OUT_DATE#46897,IN_MODE#46898,OUT_MODE#46899,IN_UNIT#46900,OUT_UNIT#46901,VISIT_TYPE#46902,CHAMP_PMSI#46903,UNIT_PATH#46904,EMERGENCY#46905,CANCELED#46906] PushedFilters: [], ReadSchema: struct<VISIT_ID:binary,PATIENT_ID:binary,ID_SEJ:decimal(38,0),ID_PAT:decimal(38,0),IN_DATE:timest...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT * FROM "DTM_261"."VISIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT * FROM "DTM_261"."VISIT") x) [numPartitions=1] [codegen id : 1]
Output [15]: [VISIT_ID#46892, PATIENT_ID#46893, ID_SEJ#46894, ID_PAT#46895, IN_DATE#46896, OUT_DATE#46897, IN_MODE#46898, OUT_MODE#46899, IN_UNIT#46900, OUT_UNIT#46901, VISIT_TYPE#46902, CHAMP_PMSI#46903, UNIT_PATH#46904, EMERGENCY#46905, CANCELED#46906]
ReadSchema: struct<VISIT_ID:binary,PATIENT_ID:binary,ID_SEJ:decimal(38,0),ID_PAT:decimal(38,0),IN_DATE:timestamp,OUT_DATE:timestamp,IN_MODE:string,OUT_MODE:string,IN_UNIT:string,OUT_UNIT:string,VISIT_TYPE:string,CHAMP_PMSI:string,UNIT_PATH:string,EMERGENCY:string,CANCELED:decimal(1,0)>
(2) Project [codegen id : 1]
Output [15]: [VISIT_ID#46892, PATIENT_ID#46893, ID_SEJ#46894, ID_PAT#46895, IN_DATE#46896, OUT_DATE#46897, IN_MODE#46898, OUT_MODE#46899, IN_UNIT#46900, OUT_UNIT#46901, VISIT_TYPE#46902, CHAMP_PMSI#46903, UNIT_PATH#46904, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#46905, 1, true, false, true) AS EMERGENCY#46907, CANCELED#46906]
Input [15]: [VISIT_ID#46892, PATIENT_ID#46893, ID_SEJ#46894, ID_PAT#46895, IN_DATE#46896, OUT_DATE#46897, IN_MODE#46898, OUT_MODE#46899, IN_UNIT#46900, OUT_UNIT#46901, VISIT_TYPE#46902, CHAMP_PMSI#46903, UNIT_PATH#46904, EMERGENCY#46905, CANCELED#46906]
(3) CollectLimit
Input [15]: [VISIT_ID#46892, PATIENT_ID#46893, ID_SEJ#46894, ID_PAT#46895, IN_DATE#46896, OUT_DATE#46897, IN_MODE#46898, OUT_MODE#46899, IN_UNIT#46900, OUT_UNIT#46901, VISIT_TYPE#46902, CHAMP_PMSI#46903, UNIT_PATH#46904, EMERGENCY#46907, CANCELED#46906]
Arguments: 500