digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 97 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), \"ID_SEJ\", \"ID_PAT\", \"IN_DATE\", \"OUT_DATE\", \"IN_MODE\", \"OUT_MODE\", \"IN_UNIT\", \"OUT_UNIT\", \"VISIT_TYPE\", \"CHAMP_PMSI\", \"UNIT_PATH\", \"EMERGENCY\", \"CANCELED\" FROM \"DTM_261\".\"VISIT\") x) [numPartitions=1] </b><br><br>number of output rows: 82"];
}
2->0;
3->2;
}
4
CollectLimit 1500
Project [RAWTOHEX(VISIT_ID)#55700 AS COL_VISIT_ID_2942#55956, RAWTOHEX(PATIENT_ID)#55701 AS COL_PATIENT_ID_2943#55957, cast(ID_SEJ#55702 as int) AS COL_ID_SEJ_2944#55958, cast(ID_PAT#55703 as int) AS COL_ID_PAT_2945#55959, IN_DATE#55704 AS COL_IN_DATE_2946#55960, OUT_DATE#55705 AS COL_OUT_DATE_2947#55961, IN_MODE#55706 AS COL_IN_MODE_2948#55962, OUT_MODE#55707 AS COL_OUT_MODE_2949#55963, IN_UNIT#55708 AS COL_IN_UNIT_2950#55964, OUT_UNIT#55709 AS COL_OUT_UNIT_2951#55965, VISIT_TYPE#55710 AS COL_VISIT_TYPE_2952#55966, CHAMP_PMSI#55711 AS COL_CHAMP_PMSI_2953#55967, UNIT_PATH#55712 AS COL_UNIT_PATH_2954#55968, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#55713, 1, true, false, true) AS COL_EMERGENCY_2955#55969, cast(CANCELED#55714 as int) AS COL_CANCELED_2956#55970]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_SEJ", "ID_PAT", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_261"."VISIT") x) [numPartitions=1] [RAWTOHEX(VISIT_ID)#55700,RAWTOHEX(PATIENT_ID)#55701,ID_SEJ#55702,ID_PAT#55703,IN_DATE#55704,OUT_DATE#55705,IN_MODE#55706,OUT_MODE#55707,IN_UNIT#55708,OUT_UNIT#55709,VISIT_TYPE#55710,CHAMP_PMSI#55711,UNIT_PATH#55712,EMERGENCY#55713,CANCELED#55714] PushedFilters: [], ReadSchema: struct<RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,ID_SEJ:decimal(38,0),ID_PAT:decimal(...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_SEJ", "ID_PAT", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_261"."VISIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_SEJ", "ID_PAT", "IN_DATE", "OUT_DATE", "IN_MODE", "OUT_MODE", "IN_UNIT", "OUT_UNIT", "VISIT_TYPE", "CHAMP_PMSI", "UNIT_PATH", "EMERGENCY", "CANCELED" FROM "DTM_261"."VISIT") x) [numPartitions=1] [codegen id : 1]
Output [15]: [RAWTOHEX(VISIT_ID)#55700, RAWTOHEX(PATIENT_ID)#55701, ID_SEJ#55702, ID_PAT#55703, IN_DATE#55704, OUT_DATE#55705, IN_MODE#55706, OUT_MODE#55707, IN_UNIT#55708, OUT_UNIT#55709, VISIT_TYPE#55710, CHAMP_PMSI#55711, UNIT_PATH#55712, EMERGENCY#55713, CANCELED#55714]
ReadSchema: struct<RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,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]: [RAWTOHEX(VISIT_ID)#55700 AS COL_VISIT_ID_2942#55956, RAWTOHEX(PATIENT_ID)#55701 AS COL_PATIENT_ID_2943#55957, cast(ID_SEJ#55702 as int) AS COL_ID_SEJ_2944#55958, cast(ID_PAT#55703 as int) AS COL_ID_PAT_2945#55959, IN_DATE#55704 AS COL_IN_DATE_2946#55960, OUT_DATE#55705 AS COL_OUT_DATE_2947#55961, IN_MODE#55706 AS COL_IN_MODE_2948#55962, OUT_MODE#55707 AS COL_OUT_MODE_2949#55963, IN_UNIT#55708 AS COL_IN_UNIT_2950#55964, OUT_UNIT#55709 AS COL_OUT_UNIT_2951#55965, VISIT_TYPE#55710 AS COL_VISIT_TYPE_2952#55966, CHAMP_PMSI#55711 AS COL_CHAMP_PMSI_2953#55967, UNIT_PATH#55712 AS COL_UNIT_PATH_2954#55968, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, EMERGENCY#55713, 1, true, false, true) AS COL_EMERGENCY_2955#55969, cast(CANCELED#55714 as int) AS COL_CANCELED_2956#55970]
Input [15]: [RAWTOHEX(VISIT_ID)#55700, RAWTOHEX(PATIENT_ID)#55701, ID_SEJ#55702, ID_PAT#55703, IN_DATE#55704, OUT_DATE#55705, IN_MODE#55706, OUT_MODE#55707, IN_UNIT#55708, OUT_UNIT#55709, VISIT_TYPE#55710, CHAMP_PMSI#55711, UNIT_PATH#55712, EMERGENCY#55713, CANCELED#55714]
(3) CollectLimit
Input [15]: [COL_VISIT_ID_2942#55956, COL_PATIENT_ID_2943#55957, COL_ID_SEJ_2944#55958, COL_ID_PAT_2945#55959, COL_IN_DATE_2946#55960, COL_OUT_DATE_2947#55961, COL_IN_MODE_2948#55962, COL_OUT_MODE_2949#55963, COL_IN_UNIT_2950#55964, COL_OUT_UNIT_2951#55965, COL_VISIT_TYPE_2952#55966, COL_CHAMP_PMSI_2953#55967, COL_UNIT_PATH_2954#55968, COL_EMERGENCY_2955#55969, COL_CANCELED_2956#55970]
Arguments: 1500