数据仓库服务 GAUSSDB(DWS)-SMP适用场景与限制:适用场景
适用场景
- 支持并行的算子
- Scan:支持行存普通表和行存分区表顺序扫描、列存普通表和列存分区表顺序扫描、HDFS内外表顺序扫描;支持GDS数据导入的外表扫描并行。以上均不支持复制表。
- Join:HashJoin、NestLoop
- Agg:HashAgg、SortAgg、PlainAgg、WindowAgg(只支持partition by,不支持order by)
- Stream:Redistribute、Broadcast
- 其他:Result、Subqueryscan、Unique、Material、Setop、Append、VectoRow、RowToVec
- SMP特有算子
为了实现并行,新增了并行线程间的数据交换Stream算子供SMP特性使用。以下新增的算子可以看做Stream算子的子类:
- Local Gather:实现DN内部并行线程的数据汇总
- Local Redistribute:在DN内部各线程之间,按照分布键进行数据重分布
- Local Broadcast:将数据广播到DN内部的每个线程
- Local RoundRobin:在DN内部各线程之间实现数据轮询分发
- Split Redistribute:在集群跨DN的并行线程之间实现数据重分布
- Split Broadcast:将数据广播到集群所有DN的并行线程
上述新增算子可以分为Local与非Local两类,Local类算子实现了DN内部并行线程间的数据交换,而非Local类算子实现了跨DN的并行线程间的数据交换。
- 示例说明
在这个计划中,实现了Hdfs Scan以及HashAgg算子的并行,并且新增了Local Gather和Split Redistribute数据交换算子。
其中6号算子为Split Redistribute算子,上面标有的“dop: 4/4”表明Split Redistribute的发送端和接收端线程的并行度均为4。4号算子为Local Gather,上面标有“dop: 1/4”,该算子的发送端线程并行度为4,而接收端线程并行度为1,即下层的5号Hash Aggregate算子按照4并行度执行,而上层的1~3号算子按照串行执行,4号算子实现了DN内并行线程的数据汇总。
通过计划Stream算子上标明的dop信息即可看出各个算子的并行情况。
- 数据仓库服务GaussDB(DWS)_SQL on Anywhere
- VPC是什么_VPC的作用是什么_VPC适用场景
- DWS产品介绍_DWS产品优势_DWS功能_DWS使用场景_DWS是什么
- DWS安全_数据仓库服务安全_DWS数据安全管理_DWS安全保障_DWS安全策略
- 调用GaussDB(DWS) API接口_数据仓库服务调用API_如何调用API_在DWS中调用API
- GAUSS(DWS)工具_gsql工具_DataStudio工具_DSC工具
- GaussDB(DWS)服务_什么是IoT数仓_如何使用IoT数仓
- 如何进行日志采集和转储_日志平台_日志接入_日志转储
- DWS资源管理_GaussDB(DWS)资源管理作用_DWS资源管控
- 数据库监控DMS_数据库智能运维_了解Auto Pilot_DMS_DWS节点监控