[發(fā)明專利]用于檢測(cè)處理元素內(nèi)的不允許的數(shù)據(jù)組合的方法和系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201110235347.0
• 申請(qǐng)日: 2011-08-16
• 公開（公告）號(hào): CN102375875A
• 公開（公告）日: 2012-03-14
• 發(fā)明（設(shè)計(jì)）人: M·J·布蘭松;J·M·桑多索索
• 申請(qǐng)（專利權(quán)）人: 國(guó)際商業(yè)機(jī)器公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30
• 代理公司: 北京市中咨律師事務(wù)所 11247
• 代理人: 于靜;楊曉光

背景技術(shù)

當(dāng)計(jì)算機(jī)數(shù)據(jù)庫(kù)變得極其復(fù)雜時(shí)，對(duì)數(shù)據(jù)庫(kù)系統(tǒng)的計(jì)算要求也快速增加。數(shù)據(jù)庫(kù)系統(tǒng)通常被配置為將存儲(chǔ)數(shù)據(jù)的過(guò)程與訪問(wèn)、操縱或使用數(shù)據(jù)庫(kù)中存儲(chǔ)的數(shù)據(jù)進(jìn)行分離。更具體地說(shuō)，數(shù)據(jù)庫(kù)使用這樣的模型：其中數(shù)據(jù)首先被存儲(chǔ)，然后被索引，然后被查詢。但是，此模型無(wú)法滿足某些實(shí)時(shí)應(yīng)用的性能要求。例如，數(shù)據(jù)庫(kù)系統(tǒng)接收和存儲(chǔ)入站數(shù)據(jù)的速率會(huì)限制可以處理或以其他方式計(jì)算多少數(shù)據(jù)。這又會(huì)限制數(shù)據(jù)庫(kù)應(yīng)用實(shí)時(shí)處理大量數(shù)據(jù)的能力。

發(fā)明內(nèi)容

本發(fā)明的實(shí)施例提供了一種用于檢測(cè)第一處理元素內(nèi)的不允許的數(shù)據(jù)組合的方法和系統(tǒng)。所述方法和系統(tǒng)包括接收要處理的數(shù)據(jù)。所述方法和系統(tǒng)還包括確定描述所述第一處理元素內(nèi)的預(yù)定數(shù)據(jù)組合的一個(gè)或多個(gè)規(guī)則。此外，所述方法和系統(tǒng)包括確定所述第一處理元素的當(dāng)前工作狀態(tài)，其中所述當(dāng)前工作狀態(tài)包括正在所述第一處理元素上處理的其他數(shù)據(jù)和可由所述第一處理元素訪問(wèn)的其他數(shù)據(jù)。所述方法和系統(tǒng)還包括通過(guò)一個(gè)或多個(gè)計(jì)算機(jī)處理器的運(yùn)算，判定所接收的數(shù)據(jù)和所確定的當(dāng)前工作狀態(tài)是否違反所述一個(gè)或多個(gè)規(guī)則中的任何規(guī)則。

本發(fā)明的第二實(shí)施例提供了一種用于檢測(cè)第一處理元素內(nèi)的不允許的數(shù)據(jù)組合的計(jì)算機(jī)程序產(chǎn)品。所述計(jì)算機(jī)程序產(chǎn)品包括接收要處理的數(shù)據(jù)。所述計(jì)算機(jī)程序產(chǎn)品還包括確定描述所述第一處理元素內(nèi)的預(yù)定數(shù)據(jù)組合的一個(gè)或多個(gè)規(guī)則。此外，所述計(jì)算機(jī)程序產(chǎn)品包括確定所述第一處理元素的當(dāng)前工作狀態(tài)，其中所述當(dāng)前工作狀態(tài)包括正在所述第一處理元素上處理的其他數(shù)據(jù)和可由所述第一處理元素訪問(wèn)的其他數(shù)據(jù)。所述計(jì)算機(jī)程序產(chǎn)品還包括通過(guò)一個(gè)或多個(gè)計(jì)算機(jī)處理器的運(yùn)算，判定所接收的數(shù)據(jù)和所確定的當(dāng)前工作狀態(tài)是否違反所述一個(gè)或多個(gè)規(guī)則中的任何規(guī)則。此外，所述計(jì)算機(jī)程序產(chǎn)品包括在判定所接收的數(shù)據(jù)和所確定的當(dāng)前工作狀態(tài)不違反所述一個(gè)或多個(gè)規(guī)則中的任何規(guī)則時(shí)，在所述第一處理元素上處理所接收的數(shù)據(jù)。

附圖說(shuō)明

為了詳細(xì)理解可實(shí)現(xiàn)上述方面的方式，可以通過(guò)參考附圖做出上面簡(jiǎn)要概述的本發(fā)明的實(shí)施例的具體描述。

但是要指出，附圖僅示出了本發(fā)明的典型實(shí)施例，因此并不被視為限制本發(fā)明的范圍，因?yàn)楸景l(fā)明可允許其他同樣有效的實(shí)施例：

圖1A-1B示出了根據(jù)本發(fā)明的一個(gè)實(shí)施例的被配置為執(zhí)行流應(yīng)用的計(jì)算基礎(chǔ)設(shè)施100；

圖2是根據(jù)本發(fā)明的一個(gè)實(shí)施例的圖1A-1B的計(jì)算節(jié)點(diǎn)130的更詳細(xì)的視圖；

圖3是根據(jù)本發(fā)明的一個(gè)實(shí)施例的圖1的服務(wù)器計(jì)算系統(tǒng)105的更詳細(xì)的視圖；

圖4示出了根據(jù)本發(fā)明的一個(gè)實(shí)施例的流應(yīng)用中的計(jì)算節(jié)點(diǎn)的一個(gè)實(shí)例；

圖5是示出根據(jù)本發(fā)明的一個(gè)實(shí)施例的防止處理元素上的不允許數(shù)據(jù)組合的方法的流程圖；

圖6是示出根據(jù)本發(fā)明的一個(gè)實(shí)施例的防止處理元素上的不允許數(shù)據(jù)組合的方法的流程圖；以及

圖7是示出根據(jù)本發(fā)明的一個(gè)實(shí)施例的防止處理元素上的不允許數(shù)據(jù)組合的方法的流程圖。

具體實(shí)施方式

基于流的計(jì)算和基于流的數(shù)據(jù)庫(kù)計(jì)算作為數(shù)據(jù)庫(kù)系統(tǒng)的正在發(fā)展技術(shù)出現(xiàn)。提供的產(chǎn)品允許用戶創(chuàng)建可在流數(shù)據(jù)到達(dá)數(shù)據(jù)庫(kù)文件之前對(duì)流數(shù)據(jù)進(jìn)行處理和查詢的應(yīng)用。通過(guò)這種新興技術(shù)，用戶可以指定處理邏輯以便在入站數(shù)據(jù)記錄“執(zhí)行(in?flight)”時(shí)應(yīng)用于這些記錄，并且在非常短的時(shí)間內(nèi)(通常在幾毫秒內(nèi))提供結(jié)果。使用此類處理構(gòu)造應(yīng)用開創(chuàng)了新的編程范例，這將允許開發(fā)各種創(chuàng)新性的應(yīng)用、系統(tǒng)和過(guò)程，同時(shí)對(duì)應(yīng)用編程人員和數(shù)據(jù)庫(kù)開發(fā)人員提出新的挑戰(zhàn)。

在流應(yīng)用中，運(yùn)算符相互連接以便數(shù)據(jù)從一個(gè)處理元素流向下一個(gè)處理元素(例如通過(guò)TCP/IP套接字)。通過(guò)跨節(jié)點(diǎn)分布應(yīng)用(通過(guò)創(chuàng)建許多小的可執(zhí)行代碼段(運(yùn)算符))以及在多個(gè)節(jié)點(diǎn)上復(fù)制處理元素并在處理元素之間進(jìn)行負(fù)載平衡來(lái)獲得可伸縮性。流應(yīng)用中的處理元素(和運(yùn)算符)可以融合在一起以形成較大的處理元素。這樣做可允許處理元素共享公共進(jìn)程空間，從而導(dǎo)致運(yùn)算符之間的通信遠(yuǎn)快于使用進(jìn)程間通信技術(shù)(例如，使用TCP/IP套接字)獲得的通信。此外，處理元素可以被動(dòng)態(tài)地插入表示通過(guò)流應(yīng)用的數(shù)據(jù)流的運(yùn)算符圖或被從運(yùn)算符圖動(dòng)態(tài)地刪除，以及在運(yùn)行時(shí)與流應(yīng)用融合或取消融合。

流應(yīng)用的一個(gè)優(yōu)點(diǎn)是它們?cè)试S用戶以粒度方式控制通過(guò)應(yīng)用的數(shù)據(jù)過(guò)程流。換言之，用戶可以針對(duì)每個(gè)處理元素指定對(duì)入站數(shù)據(jù)執(zhí)行各種操作的特定運(yùn)算符，并且可以通過(guò)修改運(yùn)算符及其執(zhí)行順序而動(dòng)態(tài)改變流應(yīng)用。此外，流應(yīng)用能夠處理大量數(shù)據(jù)，同時(shí)限制處理中的任何“瓶頸”。