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>Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), \"PATIENT_ID\", \"IN_DATE\", \"OUT_DATE\", \"IN_MODE\", \"OUT_MODE\", \"IN_UNIT\", \"OUT_UNIT\", \"VISIT_TYPE\", \"CHAMP_PMSI\", \"UNIT_PATH\", \"EMERGENCY\", \"CANCELED\" FROM \"DTM_622\".\"VISIT\") x) [numPartitions=1] </b><br><br>number of output rows: 500"];
}
2->0;
3->2;
}
4
CollectLimit 500
Project [RAWTOHEX(VISIT_ID)#51908, PATIENT_ID#51909, IN_DATE#51910, OUT_DATE#51911, IN_MODE#51912, OUT_MODE#51913, IN_UNIT#51914, OUT_UNIT#51915, VISIT_TYPE#51916, CHAMP_PMSI#51917, UNIT_PATH#51918, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#51919, 1, true, false, true) AS EMERGENCY#51921, CANCELED#51920]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), "PATIENT_ID", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] [RAWTOHEX(VISIT_ID)#51908,PATIENT_ID#51909,IN_DATE#51910,OUT_DATE#51911,IN_MODE#51912,OUT_MODE#51913,IN_UNIT#51914,OUT_UNIT#51915,VISIT_TYPE#51916,CHAMP_PMSI#51917,UNIT_PATH#51918,EMERGENCY#51919,CANCELED#51920] PushedFilters: [], ReadSchema: struct<RAWTOHEX(VISIT_ID):string,PATIENT_ID:binary,IN_DATE:timestamp,OUT_DATE:timestamp,IN_MODE:s...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), "PATIENT_ID", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), "PATIENT_ID", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_622"."VISIT") x) [numPartitions=1] [codegen id : 1]
Output [13]: [RAWTOHEX(VISIT_ID)#51908, PATIENT_ID#51909, IN_DATE#51910, OUT_DATE#51911, IN_MODE#51912, OUT_MODE#51913, IN_UNIT#51914, OUT_UNIT#51915, VISIT_TYPE#51916, CHAMP_PMSI#51917, UNIT_PATH#51918, EMERGENCY#51919, CANCELED#51920]
ReadSchema: struct<RAWTOHEX(VISIT_ID):string,PATIENT_ID:binary,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 [13]: [RAWTOHEX(VISIT_ID)#51908, PATIENT_ID#51909, IN_DATE#51910, OUT_DATE#51911, IN_MODE#51912, OUT_MODE#51913, IN_UNIT#51914, OUT_UNIT#51915, VISIT_TYPE#51916, CHAMP_PMSI#51917, UNIT_PATH#51918, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#51919, 1, true, false, true) AS EMERGENCY#51921, CANCELED#51920]
Input [13]: [RAWTOHEX(VISIT_ID)#51908, PATIENT_ID#51909, IN_DATE#51910, OUT_DATE#51911, IN_MODE#51912, OUT_MODE#51913, IN_UNIT#51914, OUT_UNIT#51915, VISIT_TYPE#51916, CHAMP_PMSI#51917, UNIT_PATH#51918, EMERGENCY#51919, CANCELED#51920]
(3) CollectLimit
Input [13]: [RAWTOHEX(VISIT_ID)#51908, PATIENT_ID#51909, IN_DATE#51910, OUT_DATE#51911, IN_MODE#51912, OUT_MODE#51913, IN_UNIT#51914, OUT_UNIT#51915, VISIT_TYPE#51916, CHAMP_PMSI#51917, UNIT_PATH#51918, EMERGENCY#51921, CANCELED#51920]
Arguments: 500