OceanBase INTERSECT

2021-06-29 18:07 更新

INTERSECT 算子用于對左右孩子算子輸出進行交集運算，并進行去重。

OceanBase 數(shù)據(jù)庫支持的 INTERSECT 算子包括 MERGE INTERSECT DISTINCT 和 HASH INTERSECT DISTINCT。

MERGE INTERSECT DISTINCT

如下示例中，Q1 對兩個查詢使用 INTERSECT 聯(lián)接，c1 有可用排序，0 號算子生成了 MERGE INTERSECT DISTINCT 進行求取交集、去重。由于 c2 無可用排序，所以在 3 號算子上分配了 SORT 算子進行排序。算子執(zhí)行時從左右子節(jié)點讀取有序輸入，利用有序輸入進行 MERGE，實現(xiàn)去重并得到交集結(jié)果。

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 INTERSECT SELECT c2 FROM t1\G;
*************************** 1. row ***************************
Query Plan:
=================================================
|ID|OPERATOR                |NAME|EST. ROWS|COST|
-------------------------------------------------
|0 |MERGE INTERSECT DISTINCT|    |2        |77  |
|1 | TABLE SCAN             |T1  |2        |37  |
|2 | SORT                   |    |2        |39  |
|3 |  TABLE SCAN            |T1  |2        |37  |
=================================================
Outputs & filters: 
-------------------------------------
  0 - output([INTERSECT(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)

上述示例中，執(zhí)行計劃展示中的 outputs & filters 詳細列出了所有 INTERSECT 算子的輸出信息如下：

信息名稱

含義

output

該算子的輸出表達式。

使用 INTERSECT 聯(lián)接的兩個子算子對應輸出，即表示交集運算輸出結(jié)果中的一列，括號內(nèi)部為左右子節(jié)點對應此列的輸出列。

filter

該算子上的過濾條件。

由于示例中 INTERSECT 算子沒有設置 filter，所以為 nil。

HASH INTERSECT DISTINCT

如下例所示，Q2 對兩個查詢使用 INTERSECT 進行聯(lián)接，不可利用排序，0 號算子使用 HASH INTERSECT DISTINCT 進行求取交集、去重。算子執(zhí)行時先讀取一側(cè)子節(jié)點輸出建立哈希表并去重，再讀取另一側(cè)子節(jié)點利用哈希表求取交集并去重。

Q2: 
obclient>EXPLAIN SELECT c2 FROM t1 INTERSECT SELECT c2 FROM t1\G;
*************************** 1. row ***************************
Query Plan:
================================================
|ID|OPERATOR               |NAME|EST. ROWS|COST|
------------------------------------------------
|0 |HASH INTERSECT DISTINCT|    |2        |77  |
|1 | TABLE SCAN            |T1  |2        |37  |
|2 | TABLE SCAN            |T1  |2        |37  |
================================================

Outputs & filters: 
-------------------------------------
  0 - output([INTERSECT(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)

上述示例的執(zhí)行計劃展示中的 outputs & filters 詳細列出了 HASH INTERSECT DISTINCT 算子的輸出信息，字段的含義與 MERGE INTERSECT DISTINCT 算子相同。

以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號