[發(fā)明專利]對于事件流數(shù)據(jù)管理的統(tǒng)一的窗口支持

有效

• 申請?zhí)枺?/td>: 201010227958.6
• 申請日: 2010-07-16
• 公開（公告）號: CN101957832A
• 公開（公告）日: 2011-01-26
• 發(fā)明（設計）人: 張錦;閆鶯;單名謙
• 申請（專利權）人: SAP股份公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京市柳沈律師事務所 11105
• 代理人: 邵亞麗

技術領域

本說明書涉及事件流數(shù)據(jù)管理。

背景技術

在傳統(tǒng)的數(shù)據(jù)庫和數(shù)據(jù)管理系統(tǒng)中，數(shù)據(jù)以基本上靜態(tài)的形式存儲在一個或多個計算機存儲器內。也就是說，數(shù)據(jù)一般在期望時可以改變，但是在任何給定的時刻，所存儲的數(shù)據(jù)代表離散的、靜態(tài)的、有限的、永久的、可以對其例如發(fā)出查詢的數(shù)據(jù)集。

但是，在許多設置中，可能不能以這種方式來有效地或有益地管理數(shù)據(jù)。具體來說，可能發(fā)生數(shù)據(jù)基本上連續(xù)地到達，像與例如真實世界的事件對應的數(shù)據(jù)點流那樣。因此，已經(jīng)開發(fā)了數(shù)據(jù)流管理系統(tǒng)(DSMS)以有效地利用這樣的數(shù)據(jù)。

例如，代表特定股票的價格的數(shù)據(jù)一般會隨著一天的過程而波動，并且數(shù)據(jù)流管理系統(tǒng)可以例如在相等的時間間隔或隨著價格變化而連續(xù)地接收更新后的股票價格。這樣的數(shù)據(jù)流的其它示例包括由傳感器收集的溫度或其它環(huán)境數(shù)據(jù)、計算機網(wǎng)絡分析、在醫(yī)院收集的病人健康數(shù)據(jù)、或描述制造過程或其它商業(yè)過程的數(shù)據(jù)。

因為這樣的數(shù)據(jù)流可能以快速和/或不可預測的方式或許從分布的不同種類的源接收到，并且可能是隨時間變化的和基本上無界限的，所以它們提出了對包含的數(shù)據(jù)的有效使用和處理的挑戰(zhàn)。這樣的挑戰(zhàn)可能由現(xiàn)有數(shù)據(jù)流管理系統(tǒng)的語法、語義及其它數(shù)據(jù)處理方面的不一致而加劇。

發(fā)明內容

根據(jù)一個一般方面，一種包括記錄在計算機可讀介質上的指令的計算機系統(tǒng)可以包括查詢處理器，該查詢處理器被配置為從流應用接收要對包括代表事件的多個元組(tuple)的數(shù)據(jù)流應用的查詢。所述系統(tǒng)可以包括：流窗口管理器，被配置為以定義包括元組的子集的窗口的規(guī)范(specification)來表達所述查詢，該規(guī)范將所述窗口的內容定義為具有通過其來指定所述內容的范圍屬性的元組的范圍，使用指定窗口隨時間相對于所述內容的移動的同步屬性來定義何時更新所述窗口，并且使用指定何時執(zhí)行對所述窗口的內容的評估的評估屬性來定義所述評估。所述系統(tǒng)可以包括：查詢翻譯器，被配置為翻譯查詢，包括將范圍屬性、同步屬性和評估屬性映射為數(shù)據(jù)流管理系統(tǒng)(DSMS)的流處理語言，從而獲得翻譯后的查詢；和DSMS中介體(mediator)，被配置為將翻譯后的查詢提供給DSMS以用于對其進行處理。

實施方式可以具有以下特征中的一個或多個。例如，所述系統(tǒng)可以包括結果管理器，被配置為從DSMS接收查詢結果并且將該結果提供給所述流應用。所述范圍屬性可以包括元組的數(shù)目的規(guī)范、時間的規(guī)范、數(shù)據(jù)流的一個或多個字段的規(guī)范、和/或檢測到的與所述元組相關聯(lián)的模式的規(guī)范。所述同步屬性可以包括元組的數(shù)目的規(guī)范、更新所述窗口的時間的規(guī)范、和/或檢測到的與所述元組相關聯(lián)的模式的規(guī)范。所述評估屬性可以包括所述元組中的一個或多個的規(guī)范、評估所述窗口的時間的規(guī)范、和/或檢測到的與用于觸發(fā)所述窗口的評估的元組相關聯(lián)的模式的規(guī)范。

所述查詢翻譯器可以包括編譯器，被配置為解析所述查詢，并且還可以被配置為選擇與DSMS相關聯(lián)的查詢語言相關聯(lián)的映射表并且利用該映射表執(zhí)行經(jīng)解析的查詢的映射，以提供所述查詢的語法翻譯、語義翻譯和行為翻譯以獲得翻譯后的查詢。數(shù)據(jù)流可以包括被表達為關系數(shù)據(jù)流或XML數(shù)據(jù)流或者它們的組合的一個或多個數(shù)據(jù)流。

根據(jù)另一個一般方面，一種計算機實現(xiàn)的方法可以包括：從流應用接收要對包括代表事件的多個元組的數(shù)據(jù)流應用的查詢，以及以定義包括所述元組的子集的窗口的規(guī)范來表達所述查詢，該規(guī)范將所述窗口的內容定義為具有通過其來指定所述內容的范圍屬性的元組的范圍，使用指定窗口隨時間相對于所述內容的移動的同步屬性來定義何時更新所述窗口，并且使用指定何時執(zhí)行對所述窗口的內容的評估的評估屬性來定義所述評估。所述方法可以包括：翻譯所述查詢，包括將所述范圍屬性、同步屬性和評估屬性映射為數(shù)據(jù)流管理系統(tǒng)的流處理語言，從而獲得翻譯后的查詢；以及將翻譯后的查詢提供給所述數(shù)據(jù)流管理系統(tǒng)以用于對其進行處理。

實施方式可以包括以下特征中的一個或多個。例如，所述方法可以包括從DSMS接收查詢結果并且將該結果提供給所述流應用。所述翻譯查詢可以包括：解析所述查詢，選擇與DSMS相關聯(lián)的查詢語言相關聯(lián)的映射表，并且利用該映射表執(zhí)行解析的查詢的映射，以提供所述查詢的語法翻譯、語義翻譯和行為翻譯以獲得翻譯后的查詢。