digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 104 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(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: 717"];
}
2->0;
3->2;
}
4
CollectLimit 1500
Project [RAWTOHEX(VISIT_ID)#106692 AS COL_VISIT_ID_3343#106923, RAWTOHEX(PATIENT_ID)#106693 AS COL_PATIENT_ID_3344#106924, IN_DATE#106694 AS COL_IN_DATE_3345#106925, OUT_DATE#106695 AS COL_OUT_DATE_3346#106926, IN_MODE#106696 AS COL_IN_MODE_3347#106927, OUT_MODE#106697 AS COL_OUT_MODE_3348#106928, IN_UNIT#106698 AS COL_IN_UNIT_3349#106929, OUT_UNIT#106699 AS COL_OUT_UNIT_3350#106930, VISIT_TYPE#106700 AS COL_VISIT_TYPE_3351#106931, CHAMP_PMSI#106701 AS COL_CHAMP_PMSI_3352#106932, UNIT_PATH#106702 AS COL_UNIT_PATH_3353#106933, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#106703, 1, true, false, true) AS COL_EMERGENCY_3354#106934, cast(CANCELED#106704 as int) AS COL_CANCELED_3355#106935, str_encrypt(RAWTOHEX(VISIT_ID)#106692) AS COL_ENCRYPT_3536#106936]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(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)#106692,RAWTOHEX(PATIENT_ID)#106693,IN_DATE#106694,OUT_DATE#106695,IN_MODE#106696,OUT_MODE#106697,IN_UNIT#106698,OUT_UNIT#106699,VISIT_TYPE#106700,CHAMP_PMSI#106701,UNIT_PATH#106702,EMERGENCY#106703,CANCELED#106704] PushedFilters: [], ReadSchema: struct<RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,IN_DATE:timestamp,OUT_DATE:timestamp...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(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), RAWTOHEX(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)#106692, RAWTOHEX(PATIENT_ID)#106693, IN_DATE#106694, OUT_DATE#106695, IN_MODE#106696, OUT_MODE#106697, IN_UNIT#106698, OUT_UNIT#106699, VISIT_TYPE#106700, CHAMP_PMSI#106701, UNIT_PATH#106702, EMERGENCY#106703, CANCELED#106704]
ReadSchema: struct<RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,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 [14]: [RAWTOHEX(VISIT_ID)#106692 AS COL_VISIT_ID_3343#106923, RAWTOHEX(PATIENT_ID)#106693 AS COL_PATIENT_ID_3344#106924, IN_DATE#106694 AS COL_IN_DATE_3345#106925, OUT_DATE#106695 AS COL_OUT_DATE_3346#106926, IN_MODE#106696 AS COL_IN_MODE_3347#106927, OUT_MODE#106697 AS COL_OUT_MODE_3348#106928, IN_UNIT#106698 AS COL_IN_UNIT_3349#106929, OUT_UNIT#106699 AS COL_OUT_UNIT_3350#106930, VISIT_TYPE#106700 AS COL_VISIT_TYPE_3351#106931, CHAMP_PMSI#106701 AS COL_CHAMP_PMSI_3352#106932, UNIT_PATH#106702 AS COL_UNIT_PATH_3353#106933, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#106703, 1, true, false, true) AS COL_EMERGENCY_3354#106934, cast(CANCELED#106704 as int) AS COL_CANCELED_3355#106935, str_encrypt(RAWTOHEX(VISIT_ID)#106692) AS COL_ENCRYPT_3536#106936]
Input [13]: [RAWTOHEX(VISIT_ID)#106692, RAWTOHEX(PATIENT_ID)#106693, IN_DATE#106694, OUT_DATE#106695, IN_MODE#106696, OUT_MODE#106697, IN_UNIT#106698, OUT_UNIT#106699, VISIT_TYPE#106700, CHAMP_PMSI#106701, UNIT_PATH#106702, EMERGENCY#106703, CANCELED#106704]
(3) CollectLimit
Input [14]: [COL_VISIT_ID_3343#106923, COL_PATIENT_ID_3344#106924, COL_IN_DATE_3345#106925, COL_OUT_DATE_3346#106926, COL_IN_MODE_3347#106927, COL_OUT_MODE_3348#106928, COL_IN_UNIT_3349#106929, COL_OUT_UNIT_3350#106930, COL_VISIT_TYPE_3351#106931, COL_CHAMP_PMSI_3352#106932, COL_UNIT_PATH_3353#106933, COL_EMERGENCY_3354#106934, COL_CANCELED_3355#106935, COL_ENCRYPT_3536#106936]
Arguments: 1500