UNION · k8s原理與實踐

[TOC] # UNION UNION 算子用于將兩個查詢的結果集進行并集運算。 OceanBase 數據庫支持的 UNION 算子包括 UNION ALL、 HASH UNION DISTINCT 和 MERGE UNION DISTINCT。 ## UNION ALL UNION ALL 用于直接對兩個查詢結果集進行合并輸出。如下示例中，Q1 對兩個查詢使用 UNION ALL 進行聯接，使用 UNION ALL 算子進行并集運算。算子執行時依次輸出左右子節點所有輸出結果。 ~~~ obclient>CREATE TABLE t1(c1 INT PRIMARY KEY, c2 INT); Query OK, 0 rows affected (0.12 sec) obclient>INSERT INTO t1 VALUES(1,1); Query OK, 1 rows affected (0.12 sec) obclient>INSERT INTO t1 VALUES(2,2); Query OK, 1 rows affected (0.12 sec) Q1: obclient>EXPLAIN SELECT c1 FROM t1 UNION ALL SELECT c2 FROM t1\G; *************************** 1. row *************************** Query Plan: ==================================== |ID|OPERATOR |NAME|EST. ROWS|COST| ------------------------------------ |0 |UNION ALL | |4 |74 | |1 | TABLE SCAN|T1 |2 |37 | |2 | TABLE SCAN|T1 |2 |37 | ==================================== Outputs & filters: ------------------------------------- 0 - output([UNION(T1.C1, T1.C2)]), filter(nil) 1 - output([T1.C1]), filter(nil), access([T1.C1]), partitions(p0) 2 - output([T1.C2]), filter(nil), access([T1.C2]), partitions(p0) ~~~ 上述示例中，執行計劃展示中的 outputs & filters 詳細列出了 UNION ALL 算子的輸出信息如下： <table data-tag="table" id="table-33a-t1s-284" class="table"><colgroup span="1" width="139" data-tag="col" id="col-454-p5l-esl" colwidth="1*" colnum="1" colname="col1" style="width:50%" class="col"></colgroup><colgroup span="1" width="609" data-tag="col" id="col-e77-y81-2qz" colwidth="1*" colnum="2" colname="col2" style="width:50%" class="col"></colgroup><thead id="thead-jy6-28n-fbj" class="thead"><tr id="tr-xji-2kt-m4g"><th id="td-4hb-7e6-1ey"><p id="p-h3q-7vg-osj"><b>信息名稱</b></p></th><th id="td-jsf-ljj-liz"><p id="p-zee-dts-gk5"><b>含義</b></p></th></tr></thead><tbody data-tag="tbody" id="tbody-tcu-dsz-2di" class="tbody"><tr data-tag="tr" id="tr-x6p-1bh-68a" class="tr"><td data-tag="td" id="td-o8f-4i7-jvn" class="td"><p id="p-rpa-0xl-f04">output</p></td><td data-tag="td" id="td-6m2-vhb-zy7" class="td"><p id="p-7fc-42p-4w8">該算子的輸出表達式。</p></td></tr><tr data-tag="tr" id="tr-l4x-d51-vih" class="tr"><td data-tag="td" id="td-v2v-7im-s36" class="td"><p id="p-prr-a56-e1l">filter</p></td><td data-tag="td" id="td-2kc-val-yzj" class="td"><p id="p-283-lci-ad2">該算子上的過濾條件。</p><p id="p-0yy-04c-scm">由于示例中 UNION ALL 算子沒有設置 filter，所以為 nil。</p></td></tr></tbody></table> ## MERGE UNION DISTINCT MERGE UNION DISTINCT 用于對結果集進行并集、去重后進行輸出。如下示例中，Q2 對兩個查詢使用 UNION DISTINCT 進行聯接， c1 有可用排序，0 號算子生成 MERGE UNION DISTINCT 進行取并集、去重。由于 c2 無可用排序，所以在 3 號算子上分配了 SORT 算子進行排序。算子執行時從左右子節點讀取有序輸入，進行合并得到有序輸出并去重。 ~~~ Q2: obclient>EXPLAIN SELECT c1 FROM t1 UNION SELECT c2 FROM t1\G; *************************** 1. row *************************** Query Plan: ============================================= |ID|OPERATOR |NAME|EST. ROWS|COST| --------------------------------------------- |0 |MERGE UNION DISTINCT| |4 |77 | |1 | TABLE SCAN |T1 |2 |37 | |2 | SORT | |2 |39 | |3 | TABLE SCAN |T1 |2 |37 | ============================================= Outputs & filters: ------------------------------------- 0 - output([UNION(T1.C1, T1.C2)]), filter(nil) 1 - output([T1.C1]), filter(nil), access([T1.C1]), partitions(p0) 2 - output([T1.C2]), filter(nil), sort_keys([T1.C2, ASC]) 3 - output([T1.C2]), filter(nil), access([T1.C2]), partitions(p0) ~~~ 上述示例的執行計劃展示中的 outputs & filters 詳細列出了 MERGE UNION DISTINCT 算子的輸出信息，字段的含義與 UNION ALL 算子相同。 ## HASH UNION DISTINCT HASH UNION DISTINCT 用于對結果集進行并集、去重后進行輸出。如下示例中，Q3 對兩個查詢使用 UNION DISTINCT 進行聯接，無可利用排序，0 號算子使用 HASH UNION DISTINCT 進行并集、去重。算子執行時讀取左右子節點輸出，建立哈希表進行去重，最終輸出去重后結果。 ~~~ Q3: obclient>EXPLAIN SELECT c2 FROM t1 UNION SELECT c2 FROM t1\G; *************************** 1. row *************************** Query Plan: ============================================ |ID|OPERATOR |NAME|EST. ROWS|COST| -------------------------------------------- |0 |HASH UNION DISTINCT| |4 |77 | |1 | TABLE SCAN |T1 |2 |37 | |2 | TABLE SCAN |T1 |2 |37 | ============================================ Outputs & filters: ------------------------------------- 0 - output([UNION(T1.C2, T1.C2)]), filter(nil) 1 - output([T1.C2]), filter(nil), access([T1.C2]), partitions(p0) 2 - output([T1.C2]), filter(nil), access([T1.C2]), partitions(p0) ~~~ 上述示例的執行計劃展示中的 outputs & filters 詳細列出了 HASH UNION DISTINCT 算子的輸出信息，字段的含義與 UNION ALL 算子相同。