新聞中心
SUBPLAN FILTER 算子用于驅(qū)動(dòng)表達(dá)式中的子查詢執(zhí)行。

OceanBase 數(shù)據(jù)庫以 NESTED-LOOP 算法執(zhí)行 SUBPLAN FILTER 算子,執(zhí)行時(shí)左邊取一行數(shù)據(jù),然后執(zhí)行右邊的子計(jì)劃。SUBPLAN FILTER 算子可以驅(qū)動(dòng)相關(guān)子查詢和非相關(guān)子查詢計(jì)算,并且兩種執(zhí)行方式不同。
驅(qū)動(dòng)非相關(guān)子查詢計(jì)算
示例 1:SUBPLAN FILTER 算子驅(qū)動(dòng)非相關(guān)子查詢計(jì)算
obclient>CREATE TABLE t1(c1 INT, c2 INT);
Query OK, 0 rows affected (0.09 sec)
obclient>CREATE TABLE t2(c1 INT, c2 INT);
Query OK, 0 rows affected (0.09 sec)
obclient>EXPLAIN SELECT /*+NO_REWRITE*/c1 FROM t1 WHERE
c2 > (SELECT MAX(c2) FROM t2)\G;
*************************** 1. row ***************************
Query Plan:
| ===========================================
|ID|OPERATOR |NAME|EST. ROWS|COST |
-------------------------------------------
|0 |SUBPLAN FILTER | |33334 |167652|
|1 | TABLE SCAN |T1 |100000 |68478 |
|2 | SCALAR GROUP BY| |1 |85373 |
|3 | TABLE SCAN |T2 |100000 |66272 |
===========================================
Outputs & filters:
-------------------------------------
0 - output([T1.C1]), filter(nil),
exec_params_(nil), onetime_exprs_([subquery(1)]), init_plan_idxs_(nil)
1 - output([T1.C1]), filter([T1.C2 > ?]),
access([T1.C2], [T1.C1]), partitions(p0)
2 - output([T_FUN_MAX(T2.C2)]), filter(nil),
group(nil), agg_func([T_FUN_MAX(T2.C2)])
3 - output([T2.C2]), filter(nil),
access([T2.C2]), partitions(p0)上述示例中,執(zhí)行計(jì)劃展示中 0 號(hào)算子 SUBPLAN FILTER 驅(qū)動(dòng)右邊 SCALAR GROUP BY 子計(jì)劃執(zhí)行,outputs & filters 詳細(xì)列出了 SUBPLAN FILTER 算子的輸出信息如下:
|
信息名稱 |
含義 |
|---|---|
SUBPLAN FILTER 算子驅(qū)動(dòng)非相關(guān)子查詢計(jì)算的一般執(zhí)行流程如下:
SUBPLAN FILTER 在啟動(dòng)時(shí)會(huì)執(zhí)行 onetime_exprs_。
從參數(shù)中拿到右邊非相關(guān)子查詢的結(jié)果,下推 filter 到左邊計(jì)劃,執(zhí)行左邊的查詢。
輸出左邊查詢的行。
驅(qū)動(dòng)相關(guān)子查詢計(jì)算
示例 2:SUBPLAN FILTER 算子驅(qū)動(dòng)相關(guān)子查詢計(jì)算
obclient>EXPLAIN SELECT /*+NO_REWRITE*/c1 FROM t1 WHERE c2 > (SELECT
MAX(c2) FROM t2 WHERE t1.c1=t2.c1)\G;
*************************** 1. row ***************************
Query Plan:
| ===============================================
|ID|OPERATOR |NAME|EST. ROWS|COST |
-----------------------------------------------
|0 |SUBPLAN FILTER | |33334 |8541203533|
|1 | TABLE SCAN |T1 |100000 |68478 |
|2 | SCALAR GROUP BY| |1 |85412 |
|3 | TABLE SCAN |T2 |990 |85222 |
===============================================
Outputs & filters:
-------------------------------------
0 - output([T1.C1]), filter([T1.C2 > subquery(1)]),
exec_params_([T1.C1]), onetime_exprs_(nil), init_plan_idxs_(nil)
1 - output([T1.C1], [T1.C2]), filter(nil),
access([T1.C1], [T1.C2]), partitions(p0)
2 - output([T_FUN_MAX(T2.C2)]), filter(nil),
group(nil), agg_func([T_FUN_MAX(T2.C2)])
3 - output([T2.C2]), filter([? = T2.C1]),
access([T2.C1], [T2.C2]), partitions(p0)上述示例中,執(zhí)行計(jì)劃展示中 0 號(hào)算子 SUBPLAN FILTER 驅(qū)動(dòng)右邊 SCALAR GROUP BY 子計(jì)劃執(zhí)行,outputs & filters 詳細(xì)列出了 SUBPLAN FILTER 算子的輸出信息如下:
|
信息名稱 |
含義 |
|---|---|
SUBPLAN FILTER 算子驅(qū)動(dòng)相關(guān)子查詢計(jì)算的一般執(zhí)行流程如下:
SUBPLAN FILTER 在啟動(dòng)時(shí)會(huì)執(zhí)行
onetime_exprs_。執(zhí)行左邊的查詢,輸出一行后,計(jì)算相關(guān)參數(shù),下推到右邊,執(zhí)行右邊的子查詢。
執(zhí)行 filter,輸出符合條件的數(shù)據(jù)行。
名稱欄目:創(chuàng)新互聯(lián)OceanBase教程:OceanBase SUBPLAN FILTER
本文來源:http://www.dlmjj.cn/article/cdejcde.html


咨詢
建站咨詢
