1 .一种分区表的分组聚集查询方法,其特征在于,应用于主节点,所述方法包括:
确定分区表的分组聚集查询符合预设条件时,将所述分组聚集操作下推至所述分区表
的各个分区中,生成对应的分组聚集执行计划;
将所述分组聚集执行计划发送至所有的计算节点,以使各计算节点在各分区上并行执
行所述分组聚集执行计划,得到对应的执行结果,并将所述执行结果发送至所述主节点;
将收到的所有执行结果进行汇总,并将汇总后得到的总执行结果返回至对应的客户
端。
2.根据权利要求1所述的方法,其特征在于,所述确定分区表的分组聚集查询符合预设
条件时,将所述分组聚集操作下推至所述分区表的各个分区中,生成对应的分组聚集执行
计划之前,还包括:
获取所述分组聚集查询对应的分组条件;
根据所述分组条件确定所述分组聚集查询符合预设条件。
3 .根据权利要求1所述的方法,其特征在于,所述分组聚集查询,通过以下方式得到:
接收客户端发送的查询请求,对所述查询请求进行解析,生成对应的语法树;
若所述语法树中包含的目标命令为数据操纵语言命令,则对所述语法树进行语义分析
和查询重写,得到对应的查询树;
对所述查询树进行提取,得到所述分组聚集查询。
4 .根据权利要求3所述的方法,其特征在于,还包括:
若所述语法树中包含的目标命令不是数据操纵语言命令,则通过本地命令程序将所述
目标命令下发至所有的计算节点,以使各计算节点分别执行所述目标命令,得到对应的执
行结果,并将所述执行结果发送至所述主节点。
5 .一种分区表的分组聚集查询方法,其特征在于,应用于各计算节点,所述方法包括:
接收主节点发送的分组聚集执行计划,其中,所述分组聚集执行计划由所述主节点确
定分区表的分组聚集查询符合预设条件时,将所述分组聚集操作下推至所述分区表的各个
分区中之后生成;
在各分区上并行执行所述分组聚集执行计划,得到对应的执行结果,并将所述执行结
果发送至所述主节点,以使所述主节点将收到的所有执行结果进行汇总,并将汇总后得到
的总执行结果返回至对应的客户端。
6 .根据权利要求5所述的方法,其特征在于,所述在各分区上并行执行所述分组聚集执
行计划,得到对应的执行结果,包括:
根据所述分组聚集执行计划,获取各分区分别对应的待聚集的原始分区数据;
对所述原始分区数据进行部分聚集操作,得到第一聚集结果;
对所述第一聚集结果进行数据重分布操作,得到第二聚集结果;
对所述第二聚集结果进行最终聚集操作,得到第三聚集结果;
对所有第三聚集结果进行追加操作,得到对应的执行结果。
7 .一种分区表的分组聚集查询装置,其特征在于,应用于主节点,所述装置包括:
生成模块,用于确定分区表的分组聚集查询符合预设条件时,将所述分组聚集操作下
推至所述分区表的各个分区中,生成对应的分组聚集执行计划;
发送模块,用于将所述分组聚集执行计划发送至所有的计算节点,以使各计算节点在
权 利 要 求 书
1/2 页
2
相关文档
评论