(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210554683.X (22)申请日 2022.05.19 (71)申请人 北京奥星贝斯科技有限公司 地址 100102 北京市朝阳区望京东园四区 13号楼-4至 33层101内23层201室 (72)发明人 唐铭豆　潘毅　朱涛　余璜　 (74)专利代理 机构 北京永新同创知识产权代理 有限公司 1 1376 专利代理师 林锦辉　刘景峰 (51)Int.Cl. G06F 16/2453(2019.01) G06F 16/2455(2019.01) G06F 16/27(2019.01) (54)发明名称 分布式数据库的计划执 行方法、 装置和系统 (57)摘要 本说明书的实施例提供分布式数据库的计 划执行方法、 装置及系统。 所提供的计划执行方 法由计划执行节点处的第一执行线程执行。 与被 调度来执行当前逻辑子计划的至少一个第二执 行线程一起， 并行接收当前逻辑子计划的子逻辑 子计划返回的回吐数据。 判断所述当前逻辑子计 划是否包含 涉及行号生成操作的执行算子。 响应 于包含涉及行号生成操作的执行算子， 缓存所接 收的数据并向调度节点发送行号起始值获取请 求。 随后， 根据所接收的行号起始值来为所缓存 的数据生成数据行号。 然后， 与第二执行线程一 起， 利用各自接收的生成有数据行号的数据并行 执行当前逻辑子计划， 并且与个第二执行线程一 起， 将当前逻辑子计划的执行结果作为回吐数据 并行发送给被调度来执行当前逻辑子计划的父 逻辑子计划的执 行线程。 权利要求书3页 说明书12页 附图9页 CN 114996299 A 2022.09.02 CN 114996299 A 1.一种用于执行分布式数据库的逻辑子计划的方法， 所述方法由计划执行节点处的第 一执行线程执 行， 所述方法包括： 与被调度来执行当前逻辑子计划的至少一个第 二执行线程一起， 并行接收所述当前逻 辑子计划的子 逻辑子计划返回的回吐数据； 判断所述当前逻辑子计划是否包 含涉及行号 生成操作的执 行算子； 响应于所述当前逻辑子计划包 含涉及行号 生成操作的执 行算子， 缓存所接收的数据并向调度节点发送行号起始值获取请求， 所述行号起始值获取请求 包括所缓存的数据行 数， 根据从所述调度节点接收的行号起始值来为所缓存的数据生成数据行号， 所述行号起 始值由所述调度节点响应于所述行号 起始值获取请求而为所述第一执 行线程分配， 与所述第二执行线程一起， 利用各自接收的生成有数据 行号的数据并行执行所述当前 逻辑子计划； 以及 与所述第二执行线程一起， 将所述当前逻辑子计划的执行结果作为 回吐数据并行发送 给被调度来执 行所述当前逻辑子计划的父逻辑子计划的执 行线程。 2.如权利要求1所述的方法， 还 包括： 响应于所述当前逻辑子计划不包含涉及行号生成操作的执行算子， 与 所述第二执行线 程一起， 利用各自接收的数据并行 执行所述当前逻辑子计划。 3.如权利要求1所述的方法， 其中， 判断所述当前逻辑子计划是否包含涉及行号生成操 作的执行算子包括： 遍历所述当前逻辑子计划中的执行算子来判断所述当前逻辑子计划是否包含涉及行 号生成操作的执 行算子。 4.如权利要求1所述的方法， 其中， 所述调度节点根据从所述第 一执行线程和所述第 二 执行线程接收的行号起始值 获取请求中的缓存 数据行数， 为所述第一执行线程和各个第二 执行线程分配连续 递增的行号 起始值。 5.如权利要求1所述的方法， 其中， 所述第 二执行线程包括与 所述第一执行线程位于同 一计划执行节点的执行线程和/或与所述第一执行线程位于不同计划执行节点的执行线 程。 6.如权利要求5所述的方法， 其中， 各个计划执行节点处的执行线程的数目根据 该计划 执行节点所存储数据与所述当前逻辑子计划之间的数据关联性以及该计划执行节点处的 空闲线程资源确定 。 7.一种用于在分布式数据库进行 数据查询的方法， 包括： 接收用户提供的数据查询语句； 根据所接收的数据查询语句生成分布式执 行计划； 对分布式执行计划进行逻辑转化得到多个分布式逻辑子计划， 所述多个分布式逻辑子 计划被形成为 树状结构； 将所述多个分布式逻辑子计划根据调度顺序依次调度到对应的分布式数据存储节点 来按照如权利要求1到 6中任一所述的方法并行 执行； 以及 将最顶层分布式逻辑子计划的执 行结果作为数据查询结果 提供给用户。 8.如权利要求7所述的方法， 其中， 所述分布式逻辑子计划的调度顺序根据所述分布式权　利　要　求　书 1/3 页 2 CN 114996299 A 2逻辑子计划的树状结构确定 。 9.一种用于执行分布式数据库的逻辑子计划的装置， 所述分布式数据库包括多个分布 式存储节点， 所述装置应用于充当计划执 行节点的第一分布式存 储节点， 所述装置包括： 数据接收单元， 经由所述第一分布式存储节点处的第一执行线程， 与被调度来执行当 前逻辑子计划的至少一个第二执行线程一起并行接 收所述当前逻辑子计划的子逻辑子计 划返回的回吐数据； 计划判断单元， 经由所述第一执行线程， 判断所述当前逻辑子计划是否包含涉及行号 生成操作的执 行算子； 计划执行单元， 响应于所述当前逻辑子计划包含涉及行号生成操作的执行算子， 经由 所述第一执行线程， 缓存所接 收的数据并向调度节点发送行号起始值获取请求， 所述行号 起始值获取请求包括所缓存的数据行数， 根据从所述调 度节点接收的行号起始 值来为所缓 存的数据生成数据行号， 所述行号起始 值由所述调 度节点响应于所述行号起始 值获取请求 而为所述第一执行线程分配， 与所述第二执行线程一起， 利用各自接 收的生成有数据行号 的数据并行 执行所述当前逻辑子计划； 以及 数据发送单元， 经由所述第 一执行线程， 与所述第 二执行线程一起， 将所述当前逻辑子 计划的执行结果作为回吐数据并行发送给被调度来执行所述当前逻辑子计划的父逻辑子 计划的执 行线程。 10.如权利要求9所述的装置， 其中， 响应于所述当前逻辑子计划不包含涉及行号生成 操作的执行算子， 所述计划执行单元经 由所述第一执行线程与所述第二执行线程一起， 利 用各自接收的数据并行 执行所述当前逻辑子计划。 11.如权利要求9所述的装置， 其中， 所述计划执 行单元包括： 数据缓存模块， 响应于所述当前逻辑子计划包含涉及行号生成操作的执行算子， 经由 所述第一执 行线程缓存所接收的数据； 请求发送模块， 经由所述第一执 行线程向调度节点发送行号 起始值获取请求； 行号起始值接收模块， 经由所述第一执 行线程从所述调度节点接收行号 起始值； 行号生成模块， 经由所述第 一执行线程根据从所接收的行号起始值来为所缓存的数据 生成数据行号； 以及 计划执行模块， 经由所述第一执行线程与所述至第二执行线程一起， 利用各自接收的 生成有数据行号的数据并行 执行所述当前逻辑子计划。 12.如权利要求9所述的装置， 其中， 所述计划判断单元遍历所述当前逻辑子计划中的 执行算子来判断所述当前逻辑子计划是否包 含涉及行号 生成操作的执 行算子。 13.如权利要求9所述的装置， 其中， 所述第一执行线程和各个第二执行线程处的数据 所对应的行号起始值由所述调度节点根据从所述第一执行线程和所述第二执行线程接 收 的行号起始 值获取请求中的缓存数据行数分配， 并且所述第一执行线程和各个第二执行线 程所接收的行号 起始值连续 递增。 14.一种用于在分布式数据库进行数据查询的数据查询引 擎， 所述分布式数据库包括 多个分布式数据存储节点， 每个分布式数据存储节点包括数据查询引擎和数据存储引擎， 所述数据查询引擎包括： 查询语句接收装置， 接收用户提供的数据查询语句；权　利　要　求　书 2/3 页 3 CN 114996299 A 3