(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211088190.8 (22)申请日 2022.09.07 (71)申请人 上海达梦数据库有限公司 地址 201203 上海市浦东 新区博霞路5 0号 403室 (72)发明人 朱仲颖　万伟　韩朱忠　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 王风茹 (51)Int.Cl. G06F 16/2453(2019.01) G06F 16/242(2019.01) G06F 16/248(2019.01) G06F 16/27(2019.01) (54)发明名称 数据排序方法、 装置、 电子设备及存 储介质 (57)摘要 本发明公开了一种数据排序方法、 装置、 电 子设备及存储介质。 该方法包括： 在当前环境为 分布式环境且计划树中存在发送计划节点下方 是排序计划节 点时， 确定发送方式是否是按列发 送， 且发送和排序的列相同； 若是， 合并发送操作 符和排序 操作符， 并将发送操作符的标识位设置 为设定数值； 在执行阶段， 若发送操作符的标识 位为设定 数值， 则分配N路排序所需的排序空间， 并将每行数据放入所对应 路的排序空间中； 在数 据获取完成后， 将N路排序空间的数据进行排序 并发送排序后的N路数据。 该方法在发送方式是 按列发送， 且发送和排序的列相同时， 将发送操 作符和排序操作符合并， 在N路排序空间完成排 序后再发送数据， 提高了数据排序处理时资源分 配的合理性。 权利要求书2页 说明书14页 附图3页 CN 115455043 A 2022.12.09 CN 115455043 A 1.一种数据排序方法， 其特 征在于， 包括： 在当前环境为分布式环境且计划树中存在发送计划节点下方是排序计划节点 时， 确定 发送方式是否是按列发送， 且发送和排序的列相同， 或者发送的列是排序的列的前导列； 若是， 合并发送操作符和排序操作符， 并将所述发送操作符的标识位设置为设定数值； 在执行阶段， 若发送操作符的标识位为设定数值， 则分配N路排序所需的排序空间， 并 将每行数据放入所对应路的排序空间中； 在数据获取完成后， 将N路排序空间的数据进行排序并发送排序后的N路数据。 2.根据权利要求1所述的方法， 其特征在于， 所述确定发送方式是否是按列发送， 且发 送和排序的列相同， 包括： 确定发送方式是否是按键值发送， 若是， 则确定发送方式是按列发送； 确定发送操作符的键值与排序操作符的键值是否一致， 若是， 则确定发送和排序的列 相同。 3.根据权利要求1所述的方法， 其特 征在于， 所述 合并发送操作符和排序操作符， 包括： 将所述计划子树中发送操作符下 方的排序操作符移除； 将排序操作符的功能放入发送操作符内， 以在发送操作符内完成排序功能。 4.根据权利要求1所述的方法， 其特征在于， 所述将每行数据放入所对应路的排序空间 中， 包括： 按照发送操作符所对应键值和N将每行 数据放入所对应路的排序空间中。 5.根据权利要求1所述的方法， 其特 征在于， 所述发送排序后的N路数据， 包括： 从各排序空间中选取一个排序空间， 确定所述 排序空间内的数据是否发送完毕； 若否， 向所述 排序空间所对应 计算节点发送请求信息； 接收所述计算节点基于所述请求信 息响应的响应信 息， 所述响应信 息包括可接收数据 的第一指示信息或不可接收数据的第二指示信息； 在获取到包括第一指示信 息的响应信 息后， 从所述排序空间中获取数据并发送至所述 计算节点， 并返回继续确定所述 排序空间内的数据是否发送完毕。 6.根据权利要求5所述的方法， 其特 征在于， 还 包括： 若所述排序空间内的数据发送完毕， 则返回继续从各排序空间中选取 下一排序空间； 若所选取排序空间所对应路数小于或等于N， 则继续执 行选取排序空间后的后续操作； 若所选取排序空间所对应路数大于N， 则确定N路排序空间的数据 是否发送完毕， 若否， 则继续从各排序空间中选取一个排序空间， 并执 行后续操作。 7.根据权利要求5所述的方法， 其特 征在于， 还 包括： 在获取到包括第二指示信 息的响应信 息后， 返回继续从各排序空间中选取下一排序空 间； 若所选取排序空间所对应路数小于或等于N， 则继续执 行选取排序空间后的后续操作； 若所选取排序空间所对应路数大于N， 则确定N路排序空间的数据 是否发送完毕， 若否， 则继续从各排序空间中选取一个排序空间， 并执 行后续操作。 8.一种数据排序装置， 其特 征在于， 包括： 确定模块， 用于在 当前环境为分布式环境且计划树中存在发送计划 节点下方是排序计 划节点时， 确定发送方式是否是按列发送， 且发送和排序的列相同， 或者 发送的列是排序的权　利　要　求　书 1/2 页 2 CN 115455043 A 2列的前导列； 合并模块， 用于若发送方式是按列发送， 且发送和排序的列相同， 或者发送的列是排序 的列的前导列， 合并发送操作符和 排序操作符， 并将所述发送操作符的标识位设置为设定 数值； 分配模块， 用于在执行阶段， 若发送操作符的标识位为设定数值， 则分配N路排序所需 的排序空间， 并将每行 数据放入所对应路的排序空间中； 发送模块， 用于在数据获取完成后， 将N路排序空间的数据进行排序并发送排序后的N 路数据。 9.一种电子设备， 其特 征在于， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程序被所 述至少一个处理器执行， 以使所述至少一个处理器能够执行如权利要求1 ‑7中任一所述的 方法。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 该程序被处理器 执行时实现如权利要求1 ‑7中任一所述的方法。权　利　要　求　书 2/2 页 3 CN 115455043 A 3