[發明專利]數據流的連續查詢

有效

• 申請號: 201080070687.6
• 申請日: 2010-10-14
• 公開（公告）號: CN103250147A
• 公開（公告）日: 2013-08-14
• 發明（設計）人: Q.陳;M.蘇
• 申請（專利權）人: 惠普發展公司;有限責任合伙企業
• 主分類號: G06F17/20
• 分類號: G06F17/20;G06F17/00
• 代理公司: 中國專利代理(香港)有限公司 72001
• 代理人: 馬紅梅;王洪斌

1.一種制品，包括計算機可使用介質，所述計算機可使用介質具有體現在其中的用于數據流的連續查詢的計算機可讀程序代碼，包括能夠執行以下操作的計算機可讀程序代碼：

在查詢引擎上初始化（310）包括查詢周期的查詢，以針對期望信息查詢所述數據流；

將所述數據流處理（320）為段，其中，所述段的大小基于所定義的參數；

將所述查詢周期與所述數據流的段進行同步（330）；

通過使用處理器對第一計算機存儲器中的第一段執行所述查詢來分析（340）所述第一段，以獲得第一結果；

存留（350）所述查詢的查詢狀態，并倒回查詢操作，以開始新查詢周期；以及

通過使用所述處理器對第二計算機存儲器中的第二段執行所述查詢并基于所述第一結果來在所述新查詢周期中分析（360）所述第二段。

2.根據權利要求1所述的制品，其中，所述計算機可讀程序代碼進一步能夠提供段的接收的基本上實時的通知。

3.根據權利要求1所述的制品，其中，所述計算機可讀程序代碼進一步能夠接收第二段，以及其中，分析所述第一段是在接收到所述第二段時執行的。

4.根據權利要求1所述的制品，其中，基于所述第一結果來分析所述第二段包括執行歷史敏感連續分析法。

5.根據權利要求1所述的制品，其中，所述計算機可讀程序代碼進一步能夠跨越查詢周期維持緩沖器以提供滑動查詢窗口。

6.根據權利要求1所述的制品，其中，所述計算機可讀程序代碼進一步能夠在不存留從一個段至下一段的合計函數的上下文的情況下，針對每個段計算結構化查詢語言（SQL）合計函數。

7.根據權利要求1所述的制品，其中，所述第一計算機存儲器和所述第二計算機存儲器分別包括第一表和第二表，所述方法進一步包括：

在分析所述第二段之后截斷所述第一表；以及

分析所述第一表中的第三段。

8.根據權利要求1所述的制品，其中，所述第一計算機存儲器和所述第二計算機存儲器分別包括第一表和第二表，所述第一表包括寫入表，并且所述第二表包括讀取表，以及其中，所述計算機可讀程序代碼進一步能夠：

使用數據字典操控來交換所述第一表和所述第二表的名稱，所述交換包括：

?????將所述寫入表重命名為讀取表；以及

?????將所述讀取表重命名為寫入表。

9.根據權利要求8所述的制品，其中，交換包括：在不拷貝或移動所述第一表和第二表的內容的情況下交換名稱。

10.一種用于數據流的連續查詢的系統（100），包括：

查詢引擎（170），用于針對期望信息分析連續數據流；

分析服務器（120），用于以數據段將所述連續數據流遞送至所述查詢引擎；

查詢（180），在與所述連續數據流的數據段同步的周期中在所述查詢引擎上執行；

第一緩沖器（140），用于接收第一數據段；

第二緩沖器（150），用于接收第二數據段；以及

緩沖池管理模塊（130），用于管理從所述第一緩沖器和所述第二緩沖器的交替讀取和寫入。

11.根據權利要求10所述的系統，其中，所述第一緩沖器包括寫入緩沖器，并且所述第二緩沖器包括讀取緩沖器，并且所述緩沖池管理模塊通過將所述第一緩沖器重命名為讀取緩沖器并將所述第二緩沖器重命名為寫入緩沖器，使用數據字典操控，來交換所述第一緩沖器和所述第二緩沖器的名稱。

12.根據權利要求11所述的系統，其中，所述緩沖池管理模塊在不拷貝或移動所述第一緩沖器和所述第二緩沖器的內容的情況下交換所述第一緩沖器和所述第二緩沖器的名稱。

13.根據權利要求10所述的系統，其中，所述查詢包括自引用、歷史敏感查詢，以及其中，所述查詢引擎連續地且交替地查詢所述第一緩沖器和所述第二緩沖器，使得在所述第二緩沖器接收到所述第二數據段時分析所述第一緩沖器，并且在所述第一緩沖器接收到第三數據段時分析所述第二緩沖器。

14.根據權利要求10所述的系統，進一步包括通知模塊（160），所述通知模塊（160）用于將段的接收的基本上實時的通知提供給所述查詢引擎，以開始對所述段執行查詢。

15.一種用于數據流的連續查詢的方法（400），包括：

從數據源接收（410）數據流；

對所述數據流的段執行（420）基于周期的連續查詢；

交替地、逐周期地將來自基于周期的連續查詢的執行的分析法結果遞送（430）至兩個目的地表；

通過在所述兩個目的地表中的一個處產生結果、同時在所述兩個目的地表中的另一個處使用分析法結果，來同時產生和使用（440）所述分析法結果；以及

跨越段存留（450）基于周期的連續查詢的查詢狀態，并倒回查詢操作，以在相同的基于周期的連續查詢的情況下開始新查詢周期。