SUBPLAN FILTER · k8s原理與實踐

[TOC] # SUBPLAN FILTER SUBPLAN FILTER 算子用于驅動表達式中的子查詢執行。 OceanBase 數據庫以 NESTED-LOOP 算法執行 SUBPLAN FILTER 算子，執行時左邊取一行數據，然后執行右邊的子計劃。SUBPLAN FILTER 算子可以驅動相關子查詢和非相關子查詢計算，并且兩種執行方式不同。 ## 驅動非相關子查詢計算示例 1：SUBPLAN FILTER 算子驅動非相關子查詢計算 ~~~ 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) ~~~ 上述示例中，執行計劃展示中 0 號算子 SUBPLAN FILTER 驅動右邊 SCALAR GROUP BY 子計劃執行，outputs & filters 詳細列出了 SUBPLAN FILTER 算子的輸出信息如下： <table data-tag="table" id="table-2x0-tto-ywc" class="table"><colgroup span="1" width="139" data-tag="col" id="col-2pa-ef6-tad" colwidth="1*" colnum="1" colname="col1" style="width:50%" class="col"></colgroup><colgroup span="1" width="609" data-tag="col" id="col-and-9y1-7v2" colwidth="1*" colnum="2" colname="col2" style="width:50%" class="col"></colgroup><thead id="thead-tzr-i88-tbe" class="thead"><tr id="tr-nzn-bge-atb"><th id="td-x65-n14-u82">信息名稱</th><th id="td-m7o-fg3-c3x">含義</th></tr></thead><tbody data-tag="tbody" id="tbody-80a-495-03b" class="tbody"><tr data-tag="tr" id="tr-fdl-eo3-2an" class="tr"><td data-tag="td" id="td-ol0-hid-aq8" class="td">output</td><td data-tag="td" id="td-1j7-o24-aqc" class="td">該算子輸出的列。</td></tr><tr data-tag="tr" id="tr-y0j-862-9ju" class="tr"><td data-tag="td" id="td-diw-fhy-knx" class="td">filter</td><td data-tag="td" id="td-4th-3t4-6zs" class="td">該算子上的過濾條件。由于示例中的 SUBPLAN FILTER 算子沒有設置 filter，所以為 nil。</td></tr><tr data-tag="tr" id="tr-8ss-3qx-na9" class="tr"><td data-tag="td" id="td-g89-cle-a2n" class="td">exec_params_</td><td data-tag="td" id="td-osy-g29-fy4" class="td">右子計劃依賴左子計劃的參數，執行期由SUBPLAN FILTER 從左子計劃中獲取，傳遞給右子計劃執行。由于示例中 SUBPLAN FILTER 算子驅動非相關子查詢沒有涉及該參數，所以為 nil。</td></tr><tr data-tag="tr" id="tr-fzg-dyd-9jx" class="tr"><td data-tag="td" id="td-hku-wy7-b4u" class="td">onetime_exprs_</td><td data-tag="td" id="td-etw-pvx-2nn" class="td">計劃中只計算一次的表達式，如果右子計劃是非相關子查詢，每次重復執行的結果都是一樣的，所以執行一次后保存在參數集合中。每次執行 SUBPLAN FILTER 時，可以直接從參數集獲取右子計劃的執行結果。參數 subquery(1) 表示 SUBPLAN FILTER 右邊第一個子計劃是 onetime expr。</td></tr><tr data-tag="tr" id="tr-z09-m8v-ylw" class="tr"><td id="td-f09-knz-q4j">init_plan_ids_</td><td id="td-74k-b2n-kk6">該算子中只需要執行一次的子計劃。它與 onetime_exprs_ 的區別是，init_plan_返回多行多列，onetime_expr_ 返回單行單列。由于示例中的 SQL 查詢未設置此項，所以為 nil。</td></tr></tbody></table> SUBPLAN FILTER 算子驅動非相關子查詢計算的一般執行流程如下： 1. SUBPLAN FILTER 在啟動時會執行 onetime\_exprs\_。 2. 從參數中拿到右邊非相關子查詢的結果，下推 filter 到左邊計劃，執行左邊的查詢。 3. 輸出左邊查詢的行。 ## 驅動相關子查詢計算示例 2：SUBPLAN FILTER 算子驅動相關子查詢計算 ~~~ 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) ~~~ 上述示例中，執行計劃展示中 0 號算子 SUBPLAN FILTER 驅動右邊 SCALAR GROUP BY 子計劃執行，outputs & filters 詳細列出了 SUBPLAN FILTER 算子的輸出信息如下： <table data-tag="table" id="table-m3j-rrx-csb" class="table"><colgroup span="1" width="139" data-tag="col" id="col-6gt-dgp-f7c" colwidth="1*" colnum="1" colname="col1" style="width:50%" class="col"></colgroup><colgroup span="1" width="609" data-tag="col" id="col-er4-cln-q2g" colwidth="1*" colnum="2" colname="col2" style="width:50%" class="col"></colgroup><thead id="thead-vhv-cw4-de7" class="thead"><tr id="tr-552-0wl-etc"><th id="td-ss3-yek-rdc">信息名稱</th><th id="td-avf-698-q06">含義</th></tr></thead><tbody data-tag="tbody" id="tbody-otp-wp5-kq7" class="tbody"><tr data-tag="tr" id="tr-grc-899-1si" class="tr"><td data-tag="td" id="td-cto-0ca-9js" class="td">output</td><td data-tag="td" id="td-lnv-3vl-xx6" class="td">該算子輸出的列。</td></tr><tr data-tag="tr" id="tr-v4f-91r-caf" class="tr"><td data-tag="td" id="td-qna-j55-if5" class="td">filter</td><td data-tag="td" id="td-m0d-rjf-vd6" class="td">該算子上的過濾條件。例如，示例 2 中的 SQL 查詢過濾條件為 <code data-tag="code" class="code">t1.c2 > subquery(1)</code>。</td></tr><tr data-tag="tr" id="tr-0z0-0z1-1nr" class="tr"><td data-tag="td" id="td-xmf-kgo-8kq" class="td">exec_params_</td><td data-tag="td" id="td-2eo-isg-ft8" class="td">右子計劃依賴左子計劃的參數，執行期由SUBPLAN FILTER 從左子計劃中獲取，傳遞給右子計劃執行。左邊輸出一行數據后需要下推的參數，在非相關子查詢中一般沒有下推的參數。</td></tr><tr data-tag="tr" id="tr-6wu-fv9-uh6" class="tr"><td data-tag="td" id="td-zjf-ixk-2lc" class="td">onetime_exprs_</td><td data-tag="td" id="td-bpf-9xc-mw1" class="td">計劃中只計算一次的表達式，如果右子計劃是非相關子查詢，每次重復執行的結果都是一樣的，所以執行一次后保存在參數集合中。每次執行 SUBPLAN FILTER 時，可以直接從參數集獲取右子計劃的執行結果。參數 subquery(1) 表示 SUBPLAN FILTER 右邊第一個子計劃是 onetime expr。由于示例中的 SQL 查詢未設置此項，所以為 nil。</td></tr><tr data-tag="tr" id="tr-lrl-12n-dfu" class="tr"><td id="td-7tl-s6q-dkp">init_plan_idxs_</td><td id="td-prz-tyh-n41">該算子中只需要執行一次的子計劃。與 onetime_exprs_ 的區別是，init_plan_返回多行多列，onetime_expr_ 返回單行單列。由于示例中的 SQL 查詢未設置此項，所以為 nil。</td></tr></tbody></table> SUBPLAN FILTER 算子驅動相關子查詢計算的一般執行流程如下： 1. SUBPLAN FILTER 在啟動時會執行`onetime_exprs_`。 2. 執行左邊的查詢，輸出一行后，計算相關參數，下推到右邊，執行右邊的子查詢。 3. 執行 filter，輸出符合條件的數據行。