[發明專利]窗口拼接方法、裝置、設備以及存儲介質

在審

• 申請號: 202010700287.4
• 申請日: 2020-07-20
• 公開（公告）號: CN111831383A
• 公開（公告）日: 2020-10-27
• 發明（設計）人: 田永生;朱良昌;陳星月;汪婷
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: G06F9/451
• 分類號: G06F9/451
• 代理公司: 北京市鑄成律師事務所 11313
• 代理人: 楊瑾瑾;陳建民

1.一種窗口拼接方法，包括：

將多條流在同一窗口內的數據按照主鍵進行存儲；

在至少一個流的水位超出窗口的時長達到設定時長的情況下，掃描存儲的數據以得到所述窗口的拼接數據；

其中，所述流的水位是根據所述流的當前數據的時間戳確定的。

2.根據權利要求1所述的方法，其中，將多條流在同一窗口內的數據按照主鍵進行存儲，包括：

將主流與至少一個從流中在同一窗口內具有相同行鍵的數據，存儲到外存的同一行的不同列。

3.根據權利要求2所述的方法，其中，一個行鍵對應的行包括時間列，所述時間列中記錄所述行的數據更新時間。

4.根據權利要求2所述的方法，其中，所述行鍵包括時間戳和連接鍵。

5.根據權利要求1至4中任一項所述的方法，其中，在至少一個流的水位超出窗口的時長達到設定時長的情況下，掃描存儲的數據以得到所述窗口的拼接數據，包括：

在至少一個流的水位超出窗口的時長達到第一時長的情況下，掃描存儲的數據得到時間戳處于所述窗口內的第一版本的拼接數據；

其中，所述第一版本的拼接數據包括時間戳處于所述窗口內且數據更新時間處于第一時間范圍內的拼接數據。

6.根據權利要求5所述的方法，其中，在至少一個流的水位超出窗口的時長達到設定時長的情況下，掃描存儲的數據以得到所述窗口的拼接數據，還包括：

在至少一個流的水位超出窗口的時長達到第二時長的情況下，掃描存儲的數據得到時間戳處于所述窗口內的第二版本的拼接數據，所述第二時長大于所述第一時長；

其中，所述第二版本的拼接數據包括時間戳處于所述窗口內且數據更新時間處于第二時間范圍內的拼接數據，所述第二時間范圍的起始時間等于或晚于第一時間范圍的結束時間。

7.一種窗口拼接裝置，包括：

存儲模塊，用于將多條流在同一窗口內的數據按照主鍵進行存儲；

掃描模塊，用于在至少一個流的水位超出窗口的時長達到設定時長的情況下，掃描存儲的數據以得到所述窗口的拼接數據；

其中，所述流的水位是根據所述流的當前數據的時間戳確定的。

8.根據權利要求7所述的裝置，其中，所述存儲模塊具體用于將主流與至少一個從流中在同一窗口內具有相同行鍵的數據，存儲到外存的同一行的不同列。

9.根據權利要求8所述的裝置，其中，一個行鍵對應的行包括時間列，所述時間列中記錄所述行的數據更新時間。

10.根據權利要求8所述的裝置，其中，所述行鍵包括時間戳和連接鍵。

11.根據權利要求7至10中任一項所述的裝置，其中，所述掃描模塊包括：

第一版本掃描子模塊，用于在至少一個流的水位超出窗口的時長達到第一時長的情況下，掃描存儲的數據得到時間戳處于所述窗口內的第一版本的拼接數據；

其中，所述第一版本的拼接數據包括時間戳處于所述窗口內且數據更新時間處于第一時間范圍內的拼接數據。

12.根據權利要求11所述的裝置，其中，所述掃描模塊還包括：

第二版本掃描子模塊，用于在至少一個流的水位超出窗口的時長達到第二時長的情況下，掃描存儲的數據得到時間戳處于所述窗口內的第二版本的拼接數據，所述第二時長大于所述第一時長；

其中，所述第二版本的拼接數據包括時間戳處于所述窗口內且數據更新時間處于第二時間范圍內的拼接數據，所述第二時間范圍的起始時間等于或晚于第一時間范圍的結束時間。