[發明專利]并行地執行連續事件處理(CEP)查詢

有效

• 申請號: 201480009223.2
• 申請日: 2014-02-19
• 公開（公告）號: CN105074698B
• 公開（公告）日: 2019-04-09
• 發明（設計）人: A·德卡斯托阿爾維;A·斯里尼瓦桑
• 申請（專利權）人: 甲骨文國際公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458;G06F16/2453
• 代理公司: 中國國際貿易促進委員會專利商標事務所 11038
• 代理人: 李曉芳

1.一種存儲用于使得處理器執行操作的多個指令的計算機可讀存儲器，所述多個指令包括：

使得該處理器確定能夠并行地執行與事件流中的事件有關的連續事件處理CEP查詢的多個部分的指令，所述指令包括：

使得該處理器將該CEP查詢分解成為多個單獨操作符的指令；

使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令；以及

使得該處理器至少部分地基于針對所述多個單獨操作符內的每個操作符的單獨約束來確定是否能夠以并行方式執行該CEP查詢的至少一部分；

使得該處理器響應于確定能夠以并行方式執行該CEP查詢的至少一部分來產生針對通過該事件流接收的第一事件并行地處理該CEP查詢的所述多個部分的多個執行線程的指令；以及

使得該處理器響應于確定第一操作符和第二操作符都執行特定類型的操作將該第一操作符和該第二操作符合并成為單個共享操作符的指令，該第一操作符由至少處理該事件流中的該第一事件的第一CEP查詢使用，該第二操作符由也至少處理該事件流中的該第一事件的第二CEP查詢使用。

2.如權利要求1所述的計算機可讀存儲器，其中所述多個指令包括使得該處理器至少部分地基于與該事件流相關聯的約束來確定針對該CEP查詢的約束的指令。

3.如權利要求1或2所述的計算機可讀存儲器，其中使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令包括使得該處理器至少部分地基于該特定操作符從中接收輸入的一個或多個其它操作符的一個或多個約束來確定針對該特定操作符的約束的指令。

4.如權利要求1或2所述的計算機可讀存儲器，其中使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令包括使得該處理器至少部分地基于該特定操作符的操作類型是否是過濾操作類型來確定針對該特定操作符的約束的指令。

5.如權利要求1或2所述的計算機可讀存儲器，其中使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令包括使得該處理器通過確定一組約束內的最受限的約束來確定針對該特定操作符的約束的指令，該組約束包括該特定操作符從中接收輸入的所有其它操作符的約束和與該特定操作符的操作類型相關聯的約束。

6.如權利要求1或2所述的計算機可讀存儲器，

其中使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令包括使得該處理器至少部分地基于該單個共享操作符的約束來確定針對從該單個共享操作符接收輸入的第三操作符的約束的指令；

其中使得該處理器確定針對所述多個單獨操作符內的每個特定操作符的單獨約束的指令包括使得該處理器至少部分地基于該單個共享操作符的約束來確定針對從該單個共享操作符接收輸入的第四操作符的約束的指令；

其中該第三操作符由該第一CEP查詢使用并且不由該第二CEP查詢使用；以及

其中該第四操作符由該第二CEP查詢使用并且不由該第一CEP查詢使用。

7.一種用于處理事件的數據流的系統，所述系統包括：

存儲多個指令的存儲器；和

耦接到該存儲器的處理器，該處理器被配置為執行所述多個指令以：

確定能夠并行地執行與事件流中的事件有關的連續事件處理CEP查詢的多個部分，所述確定包括；

將該CEP查詢分解成為多個單獨操作符；

確定針對所述多個單獨操作符內的每個特定操作符的單獨約束；以及

至少部分地基于針對所述多個單獨操作符內的每個操作符的單獨約束來確定是否能夠以并行方式執行該CEP查詢的至少一部分；

響應于確定能夠以并行方式執行該CEP查詢的至少一部分來產生針對通過該事件流接收的第一事件并行地處理該CEP查詢的所述多個部分的多個執行線程；以及

響應于確定第一操作符和第二操作符都執行特定類型的操作，將該第一操作符和該第二操作符合并成為單個共享操作符，該第一操作符由至少處理該事件流中的該第一事件的第一CEP查詢使用，該第二操作符由也至少處理該事件流中的該第一事件的第二CEP查詢使用。