digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 103 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), \"BIRTH_DATE\", \"GENDER\", \"PSEUDO\", \"INHOSPITAL_DEATH_DATE\", \"INHOSPITAL_DEATH_CODE\", \"DEATH_DATE\", \"EXTERNAL_DEATH_PROCESS_ID\" FROM \"DTM_622\".\"PATIENT\") x) [numPartitions=1] </b><br><br>number of output rows: 189"];
}
2->0;
3->2;
}
4
CollectLimit 1500
Project [RAWTOHEX(PATIENT_ID)#62912 AS COL_PATIENT_ID_3333#63048, BIRTH_DATE#62913 AS COL_BIRTH_DATE_3334#63049, GENDER#62914 AS COL_GENDER_3335#63050, PSEUDO#62915 AS COL_PSEUDO_3336#63051, INHOSPITAL_DEATH_DATE#62916 AS COL_INHOSPITAL_DEAT_3337#63052, INHOSPITAL_DEATH_CODE#62917 AS COL_INHOSPITAL_DEAT_3338#63053, DEATH_DATE#62918 AS COL_DEATH_DATE_3339#63054, cast(EXTERNAL_DEATH_PROCESS_ID#62919 as int) AS COL_EXTERNAL_DEATH__3340#63055]
Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] [RAWTOHEX(PATIENT_ID)#62912,BIRTH_DATE#62913,GENDER#62914,PSEUDO#62915,INHOSPITAL_DEATH_DATE#62916,INHOSPITAL_DEATH_CODE#62917,DEATH_DATE#62918,EXTERNAL_DEATH_PROCESS_ID#62919] PushedFilters: [], ReadSchema: struct<RAWTOHEX(PATIENT_ID):string,BIRTH_DATE:timestamp,GENDER:string,PSEUDO:string,INHOSPITAL_DE...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(PATIENT_ID), "BIRTH_DATE", "GENDER", "PSEUDO", "INHOSPITAL_DEATH_DATE", "INHOSPITAL_DEATH_CODE", "DEATH_DATE", "EXTERNAL_DEATH_PROCESS_ID" FROM "DTM_622"."PATIENT") x) [numPartitions=1] [codegen id : 1]
Output [8]: [RAWTOHEX(PATIENT_ID)#62912, BIRTH_DATE#62913, GENDER#62914, PSEUDO#62915, INHOSPITAL_DEATH_DATE#62916, INHOSPITAL_DEATH_CODE#62917, DEATH_DATE#62918, EXTERNAL_DEATH_PROCESS_ID#62919]
ReadSchema: struct<RAWTOHEX(PATIENT_ID):string,BIRTH_DATE:timestamp,GENDER:string,PSEUDO:string,INHOSPITAL_DEATH_DATE:timestamp,INHOSPITAL_DEATH_CODE:string,DEATH_DATE:timestamp,EXTERNAL_DEATH_PROCESS_ID:decimal(38,0)>
(2) Project [codegen id : 1]
Output [8]: [RAWTOHEX(PATIENT_ID)#62912 AS COL_PATIENT_ID_3333#63048, BIRTH_DATE#62913 AS COL_BIRTH_DATE_3334#63049, GENDER#62914 AS COL_GENDER_3335#63050, PSEUDO#62915 AS COL_PSEUDO_3336#63051, INHOSPITAL_DEATH_DATE#62916 AS COL_INHOSPITAL_DEAT_3337#63052, INHOSPITAL_DEATH_CODE#62917 AS COL_INHOSPITAL_DEAT_3338#63053, DEATH_DATE#62918 AS COL_DEATH_DATE_3339#63054, cast(EXTERNAL_DEATH_PROCESS_ID#62919 as int) AS COL_EXTERNAL_DEATH__3340#63055]
Input [8]: [RAWTOHEX(PATIENT_ID)#62912, BIRTH_DATE#62913, GENDER#62914, PSEUDO#62915, INHOSPITAL_DEATH_DATE#62916, INHOSPITAL_DEATH_CODE#62917, DEATH_DATE#62918, EXTERNAL_DEATH_PROCESS_ID#62919]
(3) CollectLimit
Input [8]: [COL_PATIENT_ID_3333#63048, COL_BIRTH_DATE_3334#63049, COL_GENDER_3335#63050, COL_PSEUDO_3336#63051, COL_INHOSPITAL_DEAT_3337#63052, COL_INHOSPITAL_DEAT_3338#63053, COL_DEATH_DATE_3339#63054, COL_EXTERNAL_DEATH__3340#63055]
Arguments: 1500