[發明專利]數據分發方法、裝置、設備以及存儲介質

在審

• 申請號: 202011063982.0
• 申請日: 2020-09-30
• 公開（公告）號: CN112202692A
• 公開（公告）日: 2021-01-08
• 發明（設計）人: 田永生;汪婷
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: H04L12/953
• 分類號: H04L12/953;H04L12/801
• 代理公司: 北京市鑄成律師事務所 11313
• 代理人: 鄧海鴻;楊瑾瑾

1.一種數據分發方法，包括：

查詢下游處理單元中的數據分片的排序信息，所述排序信息是對所述下游處理單元的數據分片按照待處理數據量進行排序得到的；

基于所述數據分片的排序信息，向所述下游處理單元中的數據分片進行數據分發。

2.根據權利要求1所述的方法，其中，基于所述數據分片的排序信息，向所述下游處理單元中的數據分片進行數據分發，包括：

基于所述數據分片的排序信息，得到在所述下游處理單元的所有數據分片中待處理數據量最小的數據分片；

將待分發數據分發給所述待處理數據量最小的數據分片。

3.根據權利要求2所述的方法，所述方法還包括：將所述下游處理單元中的各個數據分片中的待處理數據量的大小作為結點的值創建小頂堆；

基于所述數據分片的排序信息，得到在所述下游處理單元的所有數據分片中待處理數據量最小的數據分片，包括：將所述小頂堆的堆頂結點對應的數據分片確定為所述待處理數據量最小的數據分片。

4.根據權利要求1至3中任一項所述的方法，其中，基于所述數據分片的排序信息，向所述下游處理單元中的數據分片進行數據分發之后，還包括：

將所述待分發數據的數據量累計到所述下游處理單元中對應的數據分片的待處理數據量中；

根據累計之后的所述下游處理單元中的各個數據分片中的待處理數據量，對所述小頂堆進行調整。

5.根據權利要求4所述的方法，其中，根據累計之后的所述下游處理單元中的各個數據分片中的待處理數據量，對所述小頂堆進行調整，還包括：

在分發的數據量達到預設閾值的情況下，按照各個數據分片中的待處理數據量對所述小頂堆進行調整。

6.根據權利要求1至3中任一項所述的方法，所述方法還包括：

響應接收到所述下游處理單元發送的數據分片處理完成的數據量信息，在所述小頂堆中更新與所述處理完成的數據量信息對應的結點的值；

根據更新后的結點的值，對所述小頂堆進行調整。

7.一種數據分發裝置，包括：

查詢單元，用于查詢下游處理單元中的數據分片的排序信息，所述排序信息是對所述下游處理單元的數據分片按照待處理數據量進行排序得到的；

分發單元，用于基于所述數據分片的排序信息，向所述下游處理單元中的數據分片進行數據分發。

8.根據權利要求7所述的裝置，其中，所述分發單元包括：

排序子單元，用于基于所述數據分片的排序信息，得到在所述下游處理單元的所有數據分片中待處理數據量最小的數據分片；

分發子單元，用于將待分發數據分發給所述待處理數據量最小的數據分片。

9.根據權利要求8所述的裝置，所述裝置還包括創建單元，所述創建單元用于：將所述下游處理單元中的各個數據分片中的待處理數據量的大小作為結點的值創建小頂堆；

所述排序子單元用于：將所述小頂堆的堆頂結點對應的數據分片確定為所述待處理數據量最小的數據分片。

10.根據權利要求7至9中任一項所述的裝置，所述裝置還包括調整單元，所述調整單元包括：

累計子單元，用于將所述待分發數據的數據量累計到所述下游處理單元中對應的數據分片的待處理數據量中；

調整子單元，用于根據累計之后的所述下游處理單元中的各個數據分片中的待處理數據量，對所述小頂堆進行調整。

11.根據權利要求10所述的裝置，其中，所述調整子單元還用于：

在分發的數據量達到預設閾值的情況下，按照各個數據分片中的待處理數據量對所述小頂堆進行調整。