[發明專利]保證分布式系統中多階段處理的事件次序

有效

• 申請號: 201680053838.4
• 申請日: 2016-10-20
• 公開（公告）號: CN108139948B
• 公開（公告）日: 2020-02-07
• 發明（設計）人: P·斯卡拉姆;S·比施諾伊;H·帕克;U·A·德什姆克
• 申請（專利權）人: 甲骨文國際公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/2455
• 代理公司: 11038 中國國際貿易促進委員會專利商標事務所
• 代理人: 李曉芳

1.一種方法，包括：

確定作為事件流的一部分被接收的事件序列中的第一事件；

用第一事件的時間戳初始化事件計數器的值；

處理所述事件流的附加事件；

識別所述事件流的被過濾的事件；

為所述被過濾的事件生成跳過節拍；

將所述跳過節拍插入到所述事件流中；

接收所述事件流的后續事件；

識別所述事件流的無序事件；以及

以與所述后續事件中的每個后續事件相關聯的時間戳的次序來處理后續事件，而與所述事件流中的下一個事件是實際事件還是跳過節拍無關。

2.如權利要求1所述的方法，其中第一事件通過以下操作確定：

啟動定時器；

接收事件序列中的事件集合，直到所述定時器到期；

按時間次序對所述事件集合進行重新排序；以及

將第一事件識別為重新排序的集合中的具有最高時間戳的事件。

3.如權利要求2所述的方法，其中在所述定時器到期之前所述附加事件被批處理。

4.如權利要求1所述的方法，其中所述被過濾的事件由上游階段濾除。

5.如權利要求1所述的方法，其中所述實際事件包括與所述事件流對應的事件數據。

6.一種存儲程序代碼的非暫態計算機可讀介質，所述程序代碼在由計算系統的處理器執行時使所述處理器執行操作，所述操作包括：

確定作為事件流的一部分被接收的事件序列中的第一事件；

用第一事件的時間戳初始化事件計數器的值；

處理所述事件流的附加事件；

識別所述事件流的被過濾的事件；

為所述被過濾的事件生成跳過節拍；

將所述跳過節拍插入到所述事件流中；

接收所述事件流的后續事件；

識別所述事件流的無序事件；以及

以與所述后續事件中的每個后續事件相關聯的時間戳的次序來處理后續事件，而與所述事件流中的下一個事件是實際事件還是跳過節拍無關。

7.如權利要求6所述的非暫態計算機可讀介質，其中第一事件通過以下操作確定：

啟動定時器；

接收事件序列中的事件集合，直到所述定時器到期；

按時間次序對所述事件集合進行重新排序；以及

將第一事件識別為重新排序的集合中的具有最高時間戳的事件。

8.如權利要求7所述的非暫態計算機可讀介質，其中在所述定時器到期之前所述附加事件被批處理。

9.如權利要求6所述的非暫態計算機可讀介質，其中所述被過濾的事件由上游階段濾除。

10.如權利要求9所述的非暫態計算機可讀介質，其中所述附加事件或所述被過濾的事件中的至少一個作為所述事件流的一部分被接收。

11.如權利要求6所述的非暫態計算機可讀介質，其中所述無序事件被丟棄。

12.一種系統，包括：

存儲器，被配置為存儲計算機可執行指令；以及

處理器，被配置為訪問所述存儲器以及執行所述計算機可執行指令，以至少：

確定作為事件流的一部分被接收的事件序列中的第一事件；

用第一事件的時間戳初始化事件計數器的值；

處理所述事件流的附加事件；

識別所述事件流的被過濾的事件；

為所述被過濾的事件生成跳過節拍；

將所述跳過節拍插入到所述事件流中；

接收所述事件流的后續事件；

識別所述事件流的無序事件；以及

以與所述后續事件中的每個后續事件相關聯的時間戳的次序來處理后續事件，而與所述事件流中的下一個事件是實際事件還是跳過節拍無關。