digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 98 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT \"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 500
Project [VISIT_UNIT_ID#55183, RAWTOHEX(VISIT_ID)#55184, RAWTOHEX(PATIENT_ID)#55185, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#55186, 20, true, false, true) AS ID_MVT#55193, ID_SEJ#55187, ID_PAT#55188, UNIT#55189, ACTIVITY#55190, IN_DATE#55191, OUT_DATE#55192]
Scan JDBCRelation((SELECT "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] [VISIT_UNIT_ID#55183,RAWTOHEX(VISIT_ID)#55184,RAWTOHEX(PATIENT_ID)#55185,ID_MVT#55186,ID_SEJ#55187,ID_PAT#55188,UNIT#55189,ACTIVITY#55190,IN_DATE#55191,OUT_DATE#55192] PushedFilters: [], ReadSchema: struct<VISIT_UNIT_ID:binary,RAWTOHEX(VISIT_ID):string,RAWTOHEX(PATIENT_ID):string,ID_MVT:string,I...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT "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 "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]: [VISIT_UNIT_ID#55183, RAWTOHEX(VISIT_ID)#55184, RAWTOHEX(PATIENT_ID)#55185, ID_MVT#55186, ID_SEJ#55187, ID_PAT#55188, UNIT#55189, ACTIVITY#55190, IN_DATE#55191, OUT_DATE#55192]
ReadSchema: struct<VISIT_UNIT_ID:binary,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]: [VISIT_UNIT_ID#55183, RAWTOHEX(VISIT_ID)#55184, RAWTOHEX(PATIENT_ID)#55185, staticinvoke(class org.apache.spark.sql.catalyst.util.CharVarcharCodegenUtils, StringType, readSidePadding, ID_MVT#55186, 20, true, false, true) AS ID_MVT#55193, ID_SEJ#55187, ID_PAT#55188, UNIT#55189, ACTIVITY#55190, IN_DATE#55191, OUT_DATE#55192]
Input [10]: [VISIT_UNIT_ID#55183, RAWTOHEX(VISIT_ID)#55184, RAWTOHEX(PATIENT_ID)#55185, ID_MVT#55186, ID_SEJ#55187, ID_PAT#55188, UNIT#55189, ACTIVITY#55190, IN_DATE#55191, OUT_DATE#55192]
(3) CollectLimit
Input [10]: [VISIT_UNIT_ID#55183, RAWTOHEX(VISIT_ID)#55184, RAWTOHEX(PATIENT_ID)#55185, ID_MVT#55193, ID_SEJ#55187, ID_PAT#55188, UNIT#55189, ACTIVITY#55190, IN_DATE#55191, OUT_DATE#55192]
Arguments: 500