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 算子的输出信息如下:
信息名称 |
含义 |
---|---|
SUBPLAN FILTER 算子驱动非相关子查询计算的一般执行流程如下:
SUBPLAN FILTER 在启动时会执行 onetime_exprs_。
从参数中拿到右边非相关子查询的结果,下推 filter 到左边计划,执行左边的查询。
输出左边查询的行。
示例 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 算子的输出信息如下:
信息名称 |
含义 |
---|---|
SUBPLAN FILTER 算子驱动相关子查询计算的一般执行流程如下:
SUBPLAN FILTER 在启动时会执行 onetime_exprs_
。
执行左边的查询,输出一行后,计算相关参数,下推到右边,执行右边的子查询。
执行 filter,输出符合条件的数据行。
当前标题:创新互联OceanBase教程:OceanBase SUBPLAN FILTER
标题来源:http://www.shufengxianlan.com/qtweb/news22/432472.html
网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联