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)#59617 AS COL_DOCUMENT_DATA_I_2853#60025, RAWTOHEX(DOCUMENT_ID)#59618 AS COL_DOCUMENT_ID_2854#60026, RAWTOHEX(PATIENT_ID)#59619 AS COL_PATIENT_ID_2855#60027, RAWTOHEX(VISIT_ID)#59620 AS COL_VISIT_ID_2856#60028, RAWTOHEX(VISIT_UNIT_ID)#59621 AS COL_VISIT_UNIT_ID_2857#60029, cast(ID_ENTREPOT_STRUCTURE#59622 as int) AS COL_ID_ENTREPOT_STR_2858#60030, cast(ID_ENTREPOT#59623 as int) AS COL_ID_ENTREPOT_2859#60031, cast(ID_PAT#59624 as int) AS COL_ID_PAT_2860#60032, cast(ID_SEJ#59625 as int) AS COL_ID_SEJ_2861#60033, cast(ID_MVT#59626 as int) AS COL_ID_MVT_2862#60034, TERMINOLOGY_CODE#59627 AS COL_TERMINOLOGY_COD_2863#60035, CONCEPT_CODE#59628 AS COL_CONCEPT_CODE_2864#60036, cast(REFORMAT_FOR_DOUBLE(NB#59629) as double) AS COL_NB_2865#60037, START_AT#59630 AS COL_START_AT_2866#60038, TEXT#59631 AS COL_TEXT_2867#60039, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#59632) as double) AS COL_LOWER_BOUND_2868#60040, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#59633) as double) AS COL_HIGHER_BOUND_2869#60041, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#59634) as double) AS COL_CERTAINTY_2870#60042, CONTEXT#59635 AS COL_CONTEXT_2871#60043, QUALIFIER#59636 AS COL_QUALIFIER_2872#60044, END_AT#59637 AS COL_END_AT_2873#60045, UNIT_VAL#59638 AS COL_UNIT_VAL_2874#60046, TYPE_VAL#59639 AS COL_TYPE_VAL_2875#60047, INSTANCE_ID#59640 AS COL_INSTANCE_ID_2876#60048]
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)#59617,RAWTOHEX(DOCUMENT_ID)#59618,RAWTOHEX(PATIENT_ID)#59619,RAWTOHEX(VISIT_ID)#59620,RAWTOHEX(VISIT_UNIT_ID)#59621,ID_ENTREPOT_STRUCTURE#59622,ID_ENTREPOT#59623,ID_PAT#59624,ID_SEJ#59625,ID_MVT#59626,TERMINOLOGY_CODE#59627,CONCEPT_CODE#59628,NB#59629,START_AT#59630,TEXT#59631,LOWER_BOUND#59632,HIGHER_BOUND#59633,CERTAINTY#59634,CONTEXT#59635,QUALIFIER#59636,END_AT#59637,UNIT_VAL#59638,TYPE_VAL#59639,INSTANCE_ID#59640] 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)#59617, RAWTOHEX(DOCUMENT_ID)#59618, RAWTOHEX(PATIENT_ID)#59619, RAWTOHEX(VISIT_ID)#59620, RAWTOHEX(VISIT_UNIT_ID)#59621, ID_ENTREPOT_STRUCTURE#59622, ID_ENTREPOT#59623, ID_PAT#59624, ID_SEJ#59625, ID_MVT#59626, TERMINOLOGY_CODE#59627, CONCEPT_CODE#59628, NB#59629, START_AT#59630, TEXT#59631, LOWER_BOUND#59632, HIGHER_BOUND#59633, CERTAINTY#59634, CONTEXT#59635, QUALIFIER#59636, END_AT#59637, UNIT_VAL#59638, TYPE_VAL#59639, INSTANCE_ID#59640]
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)#59617 AS COL_DOCUMENT_DATA_I_2853#60025, RAWTOHEX(DOCUMENT_ID)#59618 AS COL_DOCUMENT_ID_2854#60026, RAWTOHEX(PATIENT_ID)#59619 AS COL_PATIENT_ID_2855#60027, RAWTOHEX(VISIT_ID)#59620 AS COL_VISIT_ID_2856#60028, RAWTOHEX(VISIT_UNIT_ID)#59621 AS COL_VISIT_UNIT_ID_2857#60029, cast(ID_ENTREPOT_STRUCTURE#59622 as int) AS COL_ID_ENTREPOT_STR_2858#60030, cast(ID_ENTREPOT#59623 as int) AS COL_ID_ENTREPOT_2859#60031, cast(ID_PAT#59624 as int) AS COL_ID_PAT_2860#60032, cast(ID_SEJ#59625 as int) AS COL_ID_SEJ_2861#60033, cast(ID_MVT#59626 as int) AS COL_ID_MVT_2862#60034, TERMINOLOGY_CODE#59627 AS COL_TERMINOLOGY_COD_2863#60035, CONCEPT_CODE#59628 AS COL_CONCEPT_CODE_2864#60036, cast(REFORMAT_FOR_DOUBLE(NB#59629) as double) AS COL_NB_2865#60037, START_AT#59630 AS COL_START_AT_2866#60038, TEXT#59631 AS COL_TEXT_2867#60039, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#59632) as double) AS COL_LOWER_BOUND_2868#60040, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#59633) as double) AS COL_HIGHER_BOUND_2869#60041, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#59634) as double) AS COL_CERTAINTY_2870#60042, CONTEXT#59635 AS COL_CONTEXT_2871#60043, QUALIFIER#59636 AS COL_QUALIFIER_2872#60044, END_AT#59637 AS COL_END_AT_2873#60045, UNIT_VAL#59638 AS COL_UNIT_VAL_2874#60046, TYPE_VAL#59639 AS COL_TYPE_VAL_2875#60047, INSTANCE_ID#59640 AS COL_INSTANCE_ID_2876#60048]
Input [24]: [RAWTOHEX(DOCUMENT_DATA_ID)#59617, RAWTOHEX(DOCUMENT_ID)#59618, RAWTOHEX(PATIENT_ID)#59619, RAWTOHEX(VISIT_ID)#59620, RAWTOHEX(VISIT_UNIT_ID)#59621, ID_ENTREPOT_STRUCTURE#59622, ID_ENTREPOT#59623, ID_PAT#59624, ID_SEJ#59625, ID_MVT#59626, TERMINOLOGY_CODE#59627, CONCEPT_CODE#59628, NB#59629, START_AT#59630, TEXT#59631, LOWER_BOUND#59632, HIGHER_BOUND#59633, CERTAINTY#59634, CONTEXT#59635, QUALIFIER#59636, END_AT#59637, UNIT_VAL#59638, TYPE_VAL#59639, INSTANCE_ID#59640]
(3) CollectLimit
Input [24]: [COL_DOCUMENT_DATA_I_2853#60025, COL_DOCUMENT_ID_2854#60026, COL_PATIENT_ID_2855#60027, COL_VISIT_ID_2856#60028, COL_VISIT_UNIT_ID_2857#60029, COL_ID_ENTREPOT_STR_2858#60030, COL_ID_ENTREPOT_2859#60031, COL_ID_PAT_2860#60032, COL_ID_SEJ_2861#60033, COL_ID_MVT_2862#60034, COL_TERMINOLOGY_COD_2863#60035, COL_CONCEPT_CODE_2864#60036, COL_NB_2865#60037, COL_START_AT_2866#60038, COL_TEXT_2867#60039, COL_LOWER_BOUND_2868#60040, COL_HIGHER_BOUND_2869#60041, COL_CERTAINTY_2870#60042, COL_CONTEXT_2871#60043, COL_QUALIFIER_2872#60044, COL_END_AT_2873#60045, COL_UNIT_VAL_2874#60046, COL_TYPE_VAL_2875#60047, COL_INSTANCE_ID_2876#60048]
Arguments: 1500