digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 101 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), \"ID_MVT\", \"ID_SEJ\", \"ID_PAT\", \"UNIT\", \"ACTIVITY\", \"IN_DATE\", \"OUT_DATE\" FROM \"DTM_261\".\"VISIT_UNIT\") x) [numPartitions=1] </b><br><br>number of output rows: 155"];
}
2->0;
3->2;
}
4
CollectLimit 1500
Project [RAWTOHEX(VISIT_UNIT_ID)#56405 AS COL_VISIT_UNIT_ID_2959#56576, RAWTOHEX(VISIT_ID)#56406 AS COL_VISIT_ID_2960#56577, RAWTOHEX(PATIENT_ID)#56407 AS COL_PATIENT_ID_2961#56578, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#56408, 20, true, false, true) AS COL_ID_MVT_2962#56579, cast(ID_SEJ#56409 as int) AS COL_ID_SEJ_2963#56580, cast(ID_PAT#56410 as int) AS COL_ID_PAT_2964#56581, UNIT#56411 AS COL_UNIT_2965#56582, ACTIVITY#56412 AS COL_ACTIVITY_2966#56583, IN_DATE#56413 AS COL_IN_DATE_2967#56584, OUT_DATE#56414 AS COL_OUT_DATE_2968#56585]
Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] [RAWTOHEX(VISIT_UNIT_ID)#56405,RAWTOHEX(VISIT_ID)#56406,RAWTOHEX(PATIENT_ID)#56407,ID_MVT#56408,ID_SEJ#56409,ID_PAT#56410,UNIT#56411,ACTIVITY#56412,IN_DATE#56413,OUT_DATE#56414] PushedFilters: [], ReadSchema: struct<RAWTOHEX(VISIT_UNIT_ID):string,RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,ID_MV...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(VISIT_UNIT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(PATIENT_ID), "ID_MVT", "ID_SEJ", "ID_PAT", "UNIT", "ACTIVITY", "IN_DATE", "OUT_DATE" FROM "DTM_261"."VISIT_UNIT") x) [numPartitions=1] [codegen id : 1]
Output [10]: [RAWTOHEX(VISIT_UNIT_ID)#56405, RAWTOHEX(VISIT_ID)#56406, RAWTOHEX(PATIENT_ID)#56407, ID_MVT#56408, ID_SEJ#56409, ID_PAT#56410, UNIT#56411, ACTIVITY#56412, IN_DATE#56413, OUT_DATE#56414]
ReadSchema: struct<RAWTOHEX(VISIT_UNIT_ID):string,RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,ID_MVT:string,ID_SEJ:decimal(38,0),ID_PAT:decimal(38,0),UNIT:string,ACTIVITY:string,IN_DATE:timestamp,OUT_DATE:timestamp>
(2) Project [codegen id : 1]
Output [10]: [RAWTOHEX(VISIT_UNIT_ID)#56405 AS COL_VISIT_UNIT_ID_2959#56576, RAWTOHEX(VISIT_ID)#56406 AS COL_VISIT_ID_2960#56577, RAWTOHEX(PATIENT_ID)#56407 AS COL_PATIENT_ID_2961#56578, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#56408, 20, true, false, true) AS COL_ID_MVT_2962#56579, cast(ID_SEJ#56409 as int) AS COL_ID_SEJ_2963#56580, cast(ID_PAT#56410 as int) AS COL_ID_PAT_2964#56581, UNIT#56411 AS COL_UNIT_2965#56582, ACTIVITY#56412 AS COL_ACTIVITY_2966#56583, IN_DATE#56413 AS COL_IN_DATE_2967#56584, OUT_DATE#56414 AS COL_OUT_DATE_2968#56585]
Input [10]: [RAWTOHEX(VISIT_UNIT_ID)#56405, RAWTOHEX(VISIT_ID)#56406, RAWTOHEX(PATIENT_ID)#56407, ID_MVT#56408, ID_SEJ#56409, ID_PAT#56410, UNIT#56411, ACTIVITY#56412, IN_DATE#56413, OUT_DATE#56414]
(3) CollectLimit
Input [10]: [COL_VISIT_UNIT_ID_2959#56576, COL_VISIT_ID_2960#56577, COL_PATIENT_ID_2961#56578, COL_ID_MVT_2962#56579, COL_ID_SEJ_2963#56580, COL_ID_PAT_2964#56581, COL_UNIT_2965#56582, COL_ACTIVITY_2966#56583, COL_IN_DATE_2967#56584, COL_OUT_DATE_2968#56585]
Arguments: 1500