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 \"DOCUMENT_DATA_ID\", \"DOCUMENT_ID\", \"PATIENT_ID\", \"VISIT_ID\", \"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 [null AS COL_DOCUMENT_DATA_I_2853#2088, null AS COL_DOCUMENT_ID_2854#2089, null AS COL_PATIENT_ID_2855#2090, null AS COL_VISIT_ID_2856#2091, null AS COL_VISIT_UNIT_ID_2857#2092, cast(ID_ENTREPOT_STRUCTURE#1685 as int) AS COL_ID_ENTREPOT_STR_2858#2093, cast(ID_ENTREPOT#1686 as int) AS COL_ID_ENTREPOT_2859#2094, cast(ID_PAT#1687 as int) AS COL_ID_PAT_2860#2095, cast(ID_SEJ#1688 as int) AS COL_ID_SEJ_2861#2096, cast(ID_MVT#1689 as int) AS COL_ID_MVT_2862#2097, TERMINOLOGY_CODE#1690 AS COL_TERMINOLOGY_COD_2863#2098, CONCEPT_CODE#1691 AS COL_CONCEPT_CODE_2864#2099, cast(REFORMAT_FOR_DOUBLE(NB#1692) as double) AS COL_NB_2865#2100, START_AT#1693 AS COL_START_AT_2866#2101, TEXT#1694 AS COL_TEXT_2867#2102, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#1695) as double) AS COL_LOWER_BOUND_2868#2103, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#1696) as double) AS COL_HIGHER_BOUND_2869#2104, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#1697) as double) AS COL_CERTAINTY_2870#2105, CONTEXT#1698 AS COL_CONTEXT_2871#2106, QUALIFIER#1699 AS COL_QUALIFIER_2872#2107, END_AT#1700 AS COL_END_AT_2873#2108, UNIT_VAL#1701 AS COL_UNIT_VAL_2874#2109, TYPE_VAL#1702 AS COL_TYPE_VAL_2875#2110, INSTANCE_ID#1703 AS COL_INSTANCE_ID_2876#2111]
Scan JDBCRelation((SELECT "DOCUMENT_DATA_ID", "DOCUMENT_ID", "PATIENT_ID", "VISIT_ID", "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] [ID_ENTREPOT_STRUCTURE#1685,ID_ENTREPOT#1686,ID_PAT#1687,ID_SEJ#1688,ID_MVT#1689,TERMINOLOGY_CODE#1690,CONCEPT_CODE#1691,NB#1692,START_AT#1693,TEXT#1694,LOWER_BOUND#1695,HIGHER_BOUND#1696,CERTAINTY#1697,CONTEXT#1698,QUALIFIER#1699,END_AT#1700,UNIT_VAL#1701,TYPE_VAL#1702,INSTANCE_ID#1703] PushedFilters: [], ReadSchema: struct<ID_ENTREPOT_STRUCTURE:decimal(38,0),ID_ENTREPOT:decimal(38,0),ID_PAT:decimal(38,0),ID_SEJ:...
WholeStageCodegen (1)
== Physical Plan ==
CollectLimit (3)
+- * Project (2)
+- * Scan JDBCRelation((SELECT "DOCUMENT_DATA_ID", "DOCUMENT_ID", "PATIENT_ID", "VISIT_ID", "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 "DOCUMENT_DATA_ID", "DOCUMENT_ID", "PATIENT_ID", "VISIT_ID", "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 [19]: [ID_ENTREPOT_STRUCTURE#1685, ID_ENTREPOT#1686, ID_PAT#1687, ID_SEJ#1688, ID_MVT#1689, TERMINOLOGY_CODE#1690, CONCEPT_CODE#1691, NB#1692, START_AT#1693, TEXT#1694, LOWER_BOUND#1695, HIGHER_BOUND#1696, CERTAINTY#1697, CONTEXT#1698, QUALIFIER#1699, END_AT#1700, UNIT_VAL#1701, TYPE_VAL#1702, INSTANCE_ID#1703]
ReadSchema: struct<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]: [null AS COL_DOCUMENT_DATA_I_2853#2088, null AS COL_DOCUMENT_ID_2854#2089, null AS COL_PATIENT_ID_2855#2090, null AS COL_VISIT_ID_2856#2091, null AS COL_VISIT_UNIT_ID_2857#2092, cast(ID_ENTREPOT_STRUCTURE#1685 as int) AS COL_ID_ENTREPOT_STR_2858#2093, cast(ID_ENTREPOT#1686 as int) AS COL_ID_ENTREPOT_2859#2094, cast(ID_PAT#1687 as int) AS COL_ID_PAT_2860#2095, cast(ID_SEJ#1688 as int) AS COL_ID_SEJ_2861#2096, cast(ID_MVT#1689 as int) AS COL_ID_MVT_2862#2097, TERMINOLOGY_CODE#1690 AS COL_TERMINOLOGY_COD_2863#2098, CONCEPT_CODE#1691 AS COL_CONCEPT_CODE_2864#2099, cast(REFORMAT_FOR_DOUBLE(NB#1692) as double) AS COL_NB_2865#2100, START_AT#1693 AS COL_START_AT_2866#2101, TEXT#1694 AS COL_TEXT_2867#2102, cast(REFORMAT_FOR_DOUBLE(LOWER_BOUND#1695) as double) AS COL_LOWER_BOUND_2868#2103, cast(REFORMAT_FOR_DOUBLE(HIGHER_BOUND#1696) as double) AS COL_HIGHER_BOUND_2869#2104, cast(REFORMAT_FOR_DOUBLE(CERTAINTY#1697) as double) AS COL_CERTAINTY_2870#2105, CONTEXT#1698 AS COL_CONTEXT_2871#2106, QUALIFIER#1699 AS COL_QUALIFIER_2872#2107, END_AT#1700 AS COL_END_AT_2873#2108, UNIT_VAL#1701 AS COL_UNIT_VAL_2874#2109, TYPE_VAL#1702 AS COL_TYPE_VAL_2875#2110, INSTANCE_ID#1703 AS COL_INSTANCE_ID_2876#2111]
Input [19]: [ID_ENTREPOT_STRUCTURE#1685, ID_ENTREPOT#1686, ID_PAT#1687, ID_SEJ#1688, ID_MVT#1689, TERMINOLOGY_CODE#1690, CONCEPT_CODE#1691, NB#1692, START_AT#1693, TEXT#1694, LOWER_BOUND#1695, HIGHER_BOUND#1696, CERTAINTY#1697, CONTEXT#1698, QUALIFIER#1699, END_AT#1700, UNIT_VAL#1701, TYPE_VAL#1702, INSTANCE_ID#1703]
(3) CollectLimit
Input [24]: [COL_DOCUMENT_DATA_I_2853#2088, COL_DOCUMENT_ID_2854#2089, COL_PATIENT_ID_2855#2090, COL_VISIT_ID_2856#2091, COL_VISIT_UNIT_ID_2857#2092, COL_ID_ENTREPOT_STR_2858#2093, COL_ID_ENTREPOT_2859#2094, COL_ID_PAT_2860#2095, COL_ID_SEJ_2861#2096, COL_ID_MVT_2862#2097, COL_TERMINOLOGY_COD_2863#2098, COL_CONCEPT_CODE_2864#2099, COL_NB_2865#2100, COL_START_AT_2866#2101, COL_TEXT_2867#2102, COL_LOWER_BOUND_2868#2103, COL_HIGHER_BOUND_2869#2104, COL_CERTAINTY_2870#2105, COL_CONTEXT_2871#2106, COL_QUALIFIER_2872#2107, COL_END_AT_2873#2108, COL_UNIT_VAL_2874#2109, COL_TYPE_VAL_2875#2110, COL_INSTANCE_ID_2876#2111]
Arguments: 1500