digraph G {
0 [labelType="html" label="<br><b>CollectLimit</b><br><br>"];
subgraph cluster1 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
2 [labelType="html" label="<br><b>Project</b><br><br>"];
3 [labelType="html" label="<b>Scan JDBCRelation((SELECT RAWTOHEX(DOCUMENT_DATA_ID), RAWTOHEX(DOCUMENT_ID), RAWTOHEX(PATIENT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(VISIT_UNIT_ID), \"ID_ENTREPOT_STRUCTURE\", \"ID_ENTREPOT\", \"ID_PAT\", \"ID_SEJ\", \"ID_MVT\", \"TERMINOLOGY_CODE\", \"CONCEPT_CODE\", \"NB\", \"START_AT\", \"TEXT\", \"LOWER_BOUND\", \"HIGHER_BOUND\", \"CERTAINTY\", \"CONTEXT\", \"QUALIFIER\", \"END_AT\", \"UNIT_VAL\", \"TYPE_VAL\", \"INSTANCE_ID\" FROM \"DTM_261\".\"DOCUMENT_DATA\") x) [numPartitions=1] </b><br><br>number of output rows: 1,500"];
}
2->0;
3->2;
}
4
CollectLimit 1500
Project [RAWTOHEX(DOCUMENT_DATA_ID)#58338 AS COL_DOCUMENT_DATA_I_2853#58746, RAWTOHEX(DOCUMENT_ID)#58339 AS COL_DOCUMENT_ID_2854#58747, RAWTOHEX(PATIENT_ID)#58340 AS COL_PATIENT_ID_2855#58748, RAWTOHEX(VISIT_ID)#58341 AS COL_VISIT_ID_2856#58749, RAWTOHEX(VISIT_UNIT_ID)#58342 AS COL_VISIT_UNIT_ID_2857#58750, cast(ID_ENTREPOT_STRUCTURE#58343 as int) AS COL_ID_ENTREPOT_STR_2858#58751, cast(ID_ENTREPOT#58344 as int) AS COL_ID_ENTREPOT_2859#58752, cast(ID_PAT#58345 as int) AS COL_ID_PAT_2860#58753, cast(ID_SEJ#58346 as int) AS COL_ID_SEJ_2861#58754, cast(ID_MVT#58347 as int) AS COL_ID_MVT_2862#58755, TERMINOLOGY_CODE#58348 AS COL_TERMINOLOGY_COD_2863#58756, CONCEPT_CODE#58349 AS COL_CONCEPT_CODE_2864#58757, cast(REFORMAT_FOR_DOUBLE(NB#58350) as double) AS COL_NB_2865#58758, START_AT#58351 AS COL_START_AT_2866#58759, TEXT#58352 AS COL_TEXT_2867#58760, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#58353) as double) AS COL_LOWER_BOUND_2868#58761, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#58354) as double) AS COL_HIGHER_BOUND_2869#58762, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#58355) as double) AS COL_CERTAINTY_2870#58763, CONTEXT#58356 AS COL_CONTEXT_2871#58764, QUALIFIER#58357 AS COL_QUALIFIER_2872#58765, END_AT#58358 AS COL_END_AT_2873#58766, UNIT_VAL#58359 AS COL_UNIT_VAL_2874#58767, TYPE_VAL#58360 AS COL_TYPE_VAL_2875#58768, INSTANCE_ID#58361 AS COL_INSTANCE_ID_2876#58769]
Scan JDBCRelation((SELECT RAWTOHEX(DOCUMENT_DATA_ID), RAWTOHEX(DOCUMENT_ID), RAWTOHEX(PATIENT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(VISIT_UNIT_ID), "ID_ENTREPOT_STRUCTURE", "ID_ENTREPOT", "ID_PAT", "ID_SEJ", "ID_MVT", "TERMINOLOGY_CODE", "CONCEPT_CODE", "NB", "START_AT", "TEXT", "LOWER_BOUND", "HIGHER_BOUND", "CERTAINTY", "CONTEXT", "QUALIFIER", "END_AT", "UNIT_VAL", "TYPE_VAL", "INSTANCE_ID" FROM "DTM_261"."DOCUMENT_DATA") x) [numPartitions=1] [RAWTOHEX(DOCUMENT_DATA_ID)#58338,RAWTOHEX(DOCUMENT_ID)#58339,RAWTOHEX(PATIENT_ID)#58340,RAWTOHEX(VISIT_ID)#58341,RAWTOHEX(VISIT_UNIT_ID)#58342,ID_ENTREPOT_STRUCTURE#58343,ID_ENTREPOT#58344,ID_PAT#58345,ID_SEJ#58346,ID_MVT#58347,TERMINOLOGY_CODE#58348,CONCEPT_CODE#58349,NB#58350,START_AT#58351,TEXT#58352,LOWER_BOUND#58353,HIGHER_BOUND#58354,CERTAINTY#58355,CONTEXT#58356,QUALIFIER#58357,END_AT#58358,UNIT_VAL#58359,TYPE_VAL#58360,INSTANCE_ID#58361] PushedFilters: [], ReadSchema: struct<RAWTOHEX(DOCUMENT_DATA_ID):string,RAWTOHEX(DOCUMENT_ID):string,RAWTOHEX(PATIENT_ID):string...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT RAWTOHEX(DOCUMENT_DATA_ID), RAWTOHEX(DOCUMENT_ID), RAWTOHEX(PATIENT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(VISIT_UNIT_ID), "ID_ENTREPOT_STRUCTURE", "ID_ENTREPOT", "ID_PAT", "ID_SEJ", "ID_MVT", "TERMINOLOGY_CODE", "CONCEPT_CODE", "NB", "START_AT", "TEXT", "LOWER_BOUND", "HIGHER_BOUND", "CERTAINTY", "CONTEXT", "QUALIFIER", "END_AT", "UNIT_VAL", "TYPE_VAL", "INSTANCE_ID" FROM "DTM_261"."DOCUMENT_DATA") x) [numPartitions=1] (1)
(1) Scan JDBCRelation((SELECT RAWTOHEX(DOCUMENT_DATA_ID), RAWTOHEX(DOCUMENT_ID), RAWTOHEX(PATIENT_ID), RAWTOHEX(VISIT_ID), RAWTOHEX(VISIT_UNIT_ID), "ID_ENTREPOT_STRUCTURE", "ID_ENTREPOT", "ID_PAT", "ID_SEJ", "ID_MVT", "TERMINOLOGY_CODE", "CONCEPT_CODE", "NB", "START_AT", "TEXT", "LOWER_BOUND", "HIGHER_BOUND", "CERTAINTY", "CONTEXT", "QUALIFIER", "END_AT", "UNIT_VAL", "TYPE_VAL", "INSTANCE_ID" FROM "DTM_261"."DOCUMENT_DATA") x) [numPartitions=1] [codegen id : 1]
Output [24]: [RAWTOHEX(DOCUMENT_DATA_ID)#58338, RAWTOHEX(DOCUMENT_ID)#58339, RAWTOHEX(PATIENT_ID)#58340, RAWTOHEX(VISIT_ID)#58341, RAWTOHEX(VISIT_UNIT_ID)#58342, ID_ENTREPOT_STRUCTURE#58343, ID_ENTREPOT#58344, ID_PAT#58345, ID_SEJ#58346, ID_MVT#58347, TERMINOLOGY_CODE#58348, CONCEPT_CODE#58349, NB#58350, START_AT#58351, TEXT#58352, LOWER_BOUND#58353, HIGHER_BOUND#58354, CERTAINTY#58355, CONTEXT#58356, QUALIFIER#58357, END_AT#58358, UNIT_VAL#58359, TYPE_VAL#58360, INSTANCE_ID#58361]
ReadSchema: struct<RAWTOHEX(DOCUMENT_DATA_ID):string,RAWTOHEX(DOCUMENT_ID):string,RAWTOHEX(PATIENT_ID):string,RAWTOHEX(VISIT_ID):string,RAWTOHEX(VISIT_UNIT_ID):string,ID_ENTREPOT_STRUCTURE:decimal(38,0),ID_ENTREPOT:decimal(38,0),ID_PAT:decimal(38,0),ID_SEJ:decimal(38,0),ID_MVT:decimal(38,0),TERMINOLOGY_CODE:string,CONCEPT_CODE:string,NB:decimal(38,10),START_AT:timestamp,TEXT:string,LOWER_BOUND:decimal(38,10),HIGHER_BOUND:decimal(38,10),CERTAINTY:decimal(38,10),CONTEXT:string,QUALIFIER:string,END_AT:timestamp,UNIT_VAL:string,TYPE_VAL:string,INSTANCE_ID:string>
(2) Project [codegen id : 1]
Output [24]: [RAWTOHEX(DOCUMENT_DATA_ID)#58338 AS COL_DOCUMENT_DATA_I_2853#58746, RAWTOHEX(DOCUMENT_ID)#58339 AS COL_DOCUMENT_ID_2854#58747, RAWTOHEX(PATIENT_ID)#58340 AS COL_PATIENT_ID_2855#58748, RAWTOHEX(VISIT_ID)#58341 AS COL_VISIT_ID_2856#58749, RAWTOHEX(VISIT_UNIT_ID)#58342 AS COL_VISIT_UNIT_ID_2857#58750, cast(ID_ENTREPOT_STRUCTURE#58343 as int) AS COL_ID_ENTREPOT_STR_2858#58751, cast(ID_ENTREPOT#58344 as int) AS COL_ID_ENTREPOT_2859#58752, cast(ID_PAT#58345 as int) AS COL_ID_PAT_2860#58753, cast(ID_SEJ#58346 as int) AS COL_ID_SEJ_2861#58754, cast(ID_MVT#58347 as int) AS COL_ID_MVT_2862#58755, TERMINOLOGY_CODE#58348 AS COL_TERMINOLOGY_COD_2863#58756, CONCEPT_CODE#58349 AS COL_CONCEPT_CODE_2864#58757, cast(REFORMAT_FOR_DOUBLE(NB#58350) as double) AS COL_NB_2865#58758, START_AT#58351 AS COL_START_AT_2866#58759, TEXT#58352 AS COL_TEXT_2867#58760, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#58353) as double) AS COL_LOWER_BOUND_2868#58761, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#58354) as double) AS COL_HIGHER_BOUND_2869#58762, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#58355) as double) AS COL_CERTAINTY_2870#58763, CONTEXT#58356 AS COL_CONTEXT_2871#58764, QUALIFIER#58357 AS COL_QUALIFIER_2872#58765, END_AT#58358 AS COL_END_AT_2873#58766, UNIT_VAL#58359 AS COL_UNIT_VAL_2874#58767, TYPE_VAL#58360 AS COL_TYPE_VAL_2875#58768, INSTANCE_ID#58361 AS COL_INSTANCE_ID_2876#58769]
Input [24]: [RAWTOHEX(DOCUMENT_DATA_ID)#58338, RAWTOHEX(DOCUMENT_ID)#58339, RAWTOHEX(PATIENT_ID)#58340, RAWTOHEX(VISIT_ID)#58341, RAWTOHEX(VISIT_UNIT_ID)#58342, ID_ENTREPOT_STRUCTURE#58343, ID_ENTREPOT#58344, ID_PAT#58345, ID_SEJ#58346, ID_MVT#58347, TERMINOLOGY_CODE#58348, CONCEPT_CODE#58349, NB#58350, START_AT#58351, TEXT#58352, LOWER_BOUND#58353, HIGHER_BOUND#58354, CERTAINTY#58355, CONTEXT#58356, QUALIFIER#58357, END_AT#58358, UNIT_VAL#58359, TYPE_VAL#58360, INSTANCE_ID#58361]
(3) CollectLimit
Input [24]: [COL_DOCUMENT_DATA_I_2853#58746, COL_DOCUMENT_ID_2854#58747, COL_PATIENT_ID_2855#58748, COL_VISIT_ID_2856#58749, COL_VISIT_UNIT_ID_2857#58750, COL_ID_ENTREPOT_STR_2858#58751, COL_ID_ENTREPOT_2859#58752, COL_ID_PAT_2860#58753, COL_ID_SEJ_2861#58754, COL_ID_MVT_2862#58755, COL_TERMINOLOGY_COD_2863#58756, COL_CONCEPT_CODE_2864#58757, COL_NB_2865#58758, COL_START_AT_2866#58759, COL_TEXT_2867#58760, COL_LOWER_BOUND_2868#58761, COL_HIGHER_BOUND_2869#58762, COL_CERTAINTY_2870#58763, COL_CONTEXT_2871#58764, COL_QUALIFIER_2872#58765, COL_END_AT_2873#58766, COL_UNIT_VAL_2874#58767, COL_TYPE_VAL_2875#58768, COL_INSTANCE_ID_2876#58769]
Arguments: 1500