[發明專利]多應用時間線上的流數據處理

有效

• 申請號: 201780084279.8
• 申請日: 2017-12-22
• 公開（公告）號: CN110214318B
• 公開（公告）日: 2023-01-10
• 發明（設計）人: B·錢德拉莫利;J·戈爾茨坦;M·巴奈特;J·F·特威利格
• 申請（專利權）人: 微軟技術許可有限責任公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455
• 代理公司: 北京市金杜律師事務所 11256
• 代理人: 王茂華;羅利娜

1.一種計算系統，包括：

一個或多個處理器；

一種或多種計算機可讀介質，其上具有計算機可執行指令，所述計算機可執行指令被構造為使得在由一個或多個處理器執行時引起所述計算系統執行用于對流數據執行查詢處理的步驟，所述步驟包括：

接收針對多個鍵中的每個鍵的多個數據項的數據流；

產生包括所有接收到的所述多個數據項的可處理數據流，其中產生所述可處理數據流包括：

對于來自針對所述多個鍵中的每個鍵的所述數據流的所述數據項中的每一個，確保針對所述多個鍵中的每個鍵的所述數據項在時間上是有序的；以及

對于所述可處理數據流中的所述數據項中的每一個，確保所述數據項在所述可處理數據流中在時間上滯后不超過給定容限。

2.根據權利要求1所述的計算系統，其中確保所述數據項在時間上滯后不超過給定容限包括以下：對于接收到的所述數據流中被確定為在時間上滯后大于所述給定容限的至少一個數據項中的每一個：

丟棄對應的所述數據項，使得對應的所述數據項不被包括在所述可處理數據流內。

3.根據權利要求1所述的計算系統，其中確保所述數據項在時間上滯后不超過給定容限包括以下：對于接收到的所述數據流中被確定為在時間上滯后大于所述給定容限的至少一個數據項中的每一個：

快速轉發對應的所述數據項的時間戳。

4.根據權利要求1所述的計算系統，其中確保所述數據項在時間上滯后不超過給定容限包括以下：對于接收到的所述數據流中被確定為在時間上滯后大于所述給定容限的至少一個數據項中的每一個：

按順序將對應的時間戳放置在所述可處理數據流中。

5.根據權利要求4所述的計算系統，所述步驟還包括：

對所述可處理數據流執行一個或多個查詢操作。

6.根據權利要求5所述的計算系統，所述查詢操作包括每鍵查詢操作。

7.根據權利要求5所述的計算系統，所述查詢操作包括每鍵聚合操作。

8.根據權利要求5所述的計算系統，所述查詢操作包括跨鍵操作。

9.根據權利要求5所述的計算系統，所述多個鍵是第一多個鍵，所述可處理數據流是第一可處理數據流，所述一個或多個查詢操作是第一一個或多個查詢操作，所述步驟還包括：

對于來自所述第一可處理數據流的數據項，確保在產生第二可處理數據流時，針對第二多個鍵中的對應鍵的所述數據項在時間上是有序的；以及

對所述第二可處理數據流執行一個或多個查詢操作。

10.根據權利要求5所述的計算系統，所述多個鍵是第一多個鍵，所述可處理數據流是第一可處理數據流，所述一個或多個查詢操作是第一一個或多個查詢操作，所述步驟還包括：

對于來自所述第一可處理數據流的數據項，在時間上排序所述第一可處理數據流義生成第二可處理數據流；以及

對所述第二可處理數據流執行一個或多個查詢操作。

11.一種用于對流數據執行查詢處理的方法，所述方法包括：

接收針對多個鍵中的每個鍵的多個數據項的數據流；

產生包括所有接收到的所述多個數據項的可處理數據流，其中產生所述可處理數據流包括：

對于來自針對所述多個鍵中的每個鍵的所述數據流的所述數據項中的每一個，確保針對所述多個鍵中的每個鍵的所述數據項在時間上是有序的；以及

對于所述可處理數據流中的所述數據項中的每一個，確保所述數據項在所述可處理數據流中在時間上滯后不超過給定容限。

12.根據權利要求11所述的方法，其中確保所述數據項在時間上滯后不超過給定容限包括以下：對于接收到的所述數據流中被確定為在時間上滯后大于所述給定容限的至少一個數據項中的每一個：

丟棄對應的所述數據項，使得對應的所述數據項不被包括在所述可處理數據流內。