数据库中的聚合算子,例如sum, avg, group by, sort等等,会耗费大量的CPU和IO资源进行计算和读写,通过并行执行的方式,将对应的算子下压到各个计算节点上,充分利用集群的计算资源,提升执行效率。
总的来看,聚合算子的下压可以分为两种计划
Partition-Wise Aggregation
- explain select sum(c2) from t2 group by c1\G
- *************************** 1. row ***************************
- Query Plan:
- ============================================
- |ID|OPERATOR |NAME|EST. ROWS|COST|
- --------------------------------------------
- |0 |EXCHANGE IN DISTR | |1000 |2834|
- |1 | EXCHANGE OUT DISTR| |1000 |2740|
- |2 | HASH GROUP BY | |1000 |2740|
- |3 | TABLE SCAN |t2 |4000 |499 |
- ============================================
-
- Outputs & filters:
- -------------------------------------
- 0 - output([T_FUN_SUM(t2.c2)]), filter(nil)
- 1 - output([T_FUN_SUM(t2.c2)]), filter(nil)
- 2 - output([T_FUN_SUM(t2.c2)]), filter(nil),
- group([t2.c1]), agg_func([T_FUN_SUM(t2.c2)])
- 3 - output([t2.c1], [t2.c2]), filter(nil),
- access([t2.c1], [t2.c2]), partitions(p[0-3])
如果聚合查询的语意是按照分区键去做分组且在分组内做聚合,那么这样的聚合操作称为partition-wise aggregation。所有的操作都被下压到分区内并行的执行。需要注意的是,partition-wise aggregation不一定是最优的执行,因为并行度会受限于分区的数量。在OceanBase 1.x版本中,对于这样的情况,暂时没有做别的替代计划的实现。
下压加两阶段聚合
- explain select sum(c1) from t2 group by c2\G
- *************************** 1. row ***************************
- Query Plan:
- =============================================
- |ID|OPERATOR |NAME|EST. ROWS|COST|
- ---------------------------------------------
- |0 |HASH GROUP BY | |1000 |3395|
- |1 | EXCHANGE IN DISTR | |1000 |2834|
- |2 | EXCHANGE OUT DISTR| |1000 |2740|
- |3 | HASH GROUP BY | |1000 |2740|
- |4 | TABLE SCAN |t2 |4000 |499 |
- =============================================
-
- Outputs & filters:
- -------------------------------------
- 0 - output([T_FUN_SUM(T_FUN_SUM(t2.c1))]), filter(nil),
- group([t2.c2]), agg_func([T_FUN_SUM(T_FUN_SUM(t2.c1))])
- 1 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil)
- 2 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil)
- 3 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil),
- group([t2.c2]), agg_func([T_FUN_SUM(t2.c1)])
- 4 - output([t2.c1], [t2.c2]), filter(nil),
- access([t2.c1], [t2.c2]), partitions(p[0-3])
在更一般的情况下,aggregation操作可能不是按照分区键作为分组来做的,在这样的情况下,OceanBase会采用如例2所示的两阶段聚合的方式,将aggregation操作下压,获得部分的聚合结果,再进行汇总的方式获得最终结果。需要指出的是,在目前,两阶段聚合的第二阶段不是并行执行的。
本文由 姬長信 创作,文章地址:https://blog.isoyu.com/archives/oceanbasefenbushijuhexiaya.html
采用知识共享署名4.0 国际许可协议进行许可。除注明转载/出处外,均为本站原创或翻译,转载前请务必署名。最后编辑时间为:9月 16, 2018 at 04:34 下午
文章不错非常喜欢
文章不错非常喜欢
大佬早
我就当天书看了,下压是个什么概念?