[發(fā)明專利]動(dòng)態(tài)組合數(shù)據(jù)流處理應(yīng)用程序

有效

• 申請(qǐng)?zhí)枺?/td>: 201080011985.8
• 申請(qǐng)日: 2010-05-13
• 公開（公告）號(hào): CN102349056A
• 公開（公告）日: 2012-02-08
• 發(fā)明（設(shè)計(jì)）人: L·阿米尼;H·安德拉德;B·葛迪克;N·哈利姆;S·帕薩薩拉斯
• 申請(qǐng)（專利權(quán)）人: 國際商業(yè)機(jī)器公司
• 主分類號(hào): G06F13/00
• 分類號(hào): G06F13/00
• 代理公司: 中國國際貿(mào)易促進(jìn)委員會(huì)專利商標(biāo)事務(wù)所 11038
• 代理人: 金曉

1.一種用于在基于組件的數(shù)據(jù)流處理應(yīng)用程序中動(dòng)態(tài)修改多個(gè)組件之間互聯(lián)的系統(tǒng)，包括：

處理器；

耦合至處理器的存儲(chǔ)器；

儲(chǔ)存在存儲(chǔ)器上的檔案管理器模塊，針對(duì)要在一個(gè)或多個(gè)處理器上執(zhí)行的軟件應(yīng)用程序內(nèi)的多個(gè)輸出端口中的每一個(gè)輸出端口接收數(shù)據(jù)生產(chǎn)者檔案，其中應(yīng)用程序包括多個(gè)組件，每一個(gè)組件都包括生成數(shù)據(jù)流的輸出端口和使用數(shù)據(jù)流的輸入端口，并且其中每一份數(shù)據(jù)生產(chǎn)者檔案都描述了由對(duì)應(yīng)輸出端口生成的數(shù)據(jù)的特征；

儲(chǔ)存在存儲(chǔ)器上的訂閱表達(dá)式管理器模塊，針對(duì)應(yīng)用程序的多個(gè)組件的一個(gè)或多個(gè)輸入端口中的每一個(gè)輸入端口接收數(shù)據(jù)訂閱檔案，其中每一份數(shù)據(jù)訂閱檔案都描述了由對(duì)應(yīng)輸入端口使用的數(shù)據(jù)的特征；

儲(chǔ)存在存儲(chǔ)器上的數(shù)據(jù)流模塊，根據(jù)每一份數(shù)據(jù)生產(chǎn)者檔案和每一份數(shù)據(jù)訂閱檔案的比較，在應(yīng)用程序內(nèi)的多個(gè)組件的輸出端口和輸入端口之間建立一個(gè)或多個(gè)連接。

2.如權(quán)利要求1所述的系統(tǒng)，其中處理器操作用于執(zhí)行數(shù)據(jù)流處理應(yīng)用程序以處理一個(gè)或多個(gè)數(shù)據(jù)流，檔案管理器模塊進(jìn)一步操作用于在執(zhí)行數(shù)據(jù)流處理應(yīng)用程序期間接收新的數(shù)據(jù)生產(chǎn)者檔案，并且數(shù)據(jù)流模塊進(jìn)一步操作用于根據(jù)接收的包括新數(shù)據(jù)生產(chǎn)者檔案的數(shù)據(jù)檔案的修正比較，在輸出端口和輸入端口之間建立至少一個(gè)新連接。

3.如權(quán)利要求1所述的系統(tǒng)，其中處理器操作用于執(zhí)行數(shù)據(jù)流處理應(yīng)用程序以處理一個(gè)或多個(gè)數(shù)據(jù)流，訂閱表達(dá)式管理器模塊進(jìn)一步操作用于在執(zhí)行數(shù)據(jù)流處理應(yīng)用程序期間接收新的數(shù)據(jù)訂閱檔案，并且數(shù)據(jù)流模塊進(jìn)一步操作用于根據(jù)接收的包括新數(shù)據(jù)訂閱檔案的數(shù)據(jù)檔案的修正比較，在輸出端口和輸入端口之間建立至少一個(gè)新連接。

4.如權(quán)利要求1所述的系統(tǒng)，其中耦合至存儲(chǔ)器的、操作用于在輸出端口和輸入端口之間建立至少一個(gè)新連接的至少一個(gè)處理器進(jìn)一步操作用于：將應(yīng)用程序內(nèi)的一個(gè)或多個(gè)輸出端口以及一個(gè)或多個(gè)外部數(shù)據(jù)源動(dòng)態(tài)地互聯(lián)至由一個(gè)或多個(gè)數(shù)據(jù)生產(chǎn)者檔案特征以及一個(gè)或多個(gè)數(shù)據(jù)訂閱檔案特征之間的一個(gè)或多個(gè)匹配確定的應(yīng)用程序內(nèi)的一個(gè)或多個(gè)輸入端口。

5.如權(quán)利要求1所述的系統(tǒng)，其中耦合至存儲(chǔ)器的至少一個(gè)處理器進(jìn)一步操作用于建立和修改由數(shù)據(jù)使用者采用的評(píng)價(jià)標(biāo)準(zhǔn)，用于約束將被連接至使用者的一個(gè)或多個(gè)數(shù)據(jù)源的集合。

6.一種用于在基于組件的數(shù)據(jù)流處理應(yīng)用程序中動(dòng)態(tài)修改多個(gè)組件之間互聯(lián)的方法，所述方法包括：

針對(duì)要在一個(gè)或多個(gè)處理器上執(zhí)行的軟件應(yīng)用程序內(nèi)的多個(gè)輸出端口中的每一個(gè)輸出端口接收數(shù)據(jù)生產(chǎn)者檔案，其中應(yīng)用程序包括多個(gè)組件，每一個(gè)組件都包括生成數(shù)據(jù)流的輸出端口和使用數(shù)據(jù)流的輸入端口，并且其中每一份數(shù)據(jù)生產(chǎn)者檔案都描述了由對(duì)應(yīng)輸出端口生成的數(shù)據(jù)的特征；

針對(duì)應(yīng)用程序的多個(gè)組件的一個(gè)或多個(gè)輸入端口中的每一個(gè)輸入端口接收數(shù)據(jù)訂閱檔案，其中每一份數(shù)據(jù)訂閱檔案都描述了由輸入端口使用的數(shù)據(jù)的特征；

根據(jù)接收的數(shù)據(jù)生產(chǎn)者檔案和接收的數(shù)據(jù)訂閱檔案的比較，在應(yīng)用程序內(nèi)的多個(gè)組件的輸出端口和輸入端口之間建立一個(gè)或多個(gè)連接；

在一個(gè)或多個(gè)處理器上執(zhí)行數(shù)據(jù)流處理應(yīng)用程序以處理一個(gè)或多個(gè)數(shù)據(jù)流；

在執(zhí)行應(yīng)用程序期間接收新的數(shù)據(jù)生產(chǎn)者檔案或新的數(shù)據(jù)訂閱檔案之一或兩者都接收；以及

根據(jù)接收的包括一個(gè)或多個(gè)新數(shù)據(jù)檔案的數(shù)據(jù)檔案的修正比較，在輸出端口和輸入端口之間建立至少一個(gè)新連接。

7.如權(quán)利要求6所述的方法，進(jìn)一步包括在執(zhí)行應(yīng)用程序期間接收對(duì)現(xiàn)有數(shù)據(jù)檔案和現(xiàn)有訂閱表達(dá)式中的至少一種進(jìn)行的一個(gè)或多個(gè)修改。

8.如權(quán)利要求6所述的方法，其中針對(duì)軟件應(yīng)用程序內(nèi)的多個(gè)輸出端口中的每一個(gè)輸出端口接收數(shù)據(jù)生產(chǎn)者檔案包括在應(yīng)用程序開發(fā)期間的數(shù)據(jù)檔案的規(guī)范以及由應(yīng)用程序在執(zhí)行期間通過一個(gè)或多個(gè)運(yùn)行時(shí)應(yīng)用程序編程接口使用的數(shù)據(jù)檔案的編程規(guī)范中的至少一種。

9.如權(quán)利要求6所述的方法，其中針對(duì)應(yīng)用程序的多個(gè)組件的一個(gè)或多個(gè)輸入端口中的每一個(gè)輸入端口接收數(shù)據(jù)訂閱檔案包括在應(yīng)用程序開發(fā)期間的訂閱的規(guī)范以及由應(yīng)用程序在執(zhí)行期間通過一個(gè)或多個(gè)運(yùn)行時(shí)應(yīng)用程序編程接口使用的訂閱的編程規(guī)范中的至少一種。

10.如權(quán)利要求6所述的方法，其中處理一個(gè)或多個(gè)數(shù)據(jù)流包括在系統(tǒng)的一個(gè)或多個(gè)處理節(jié)點(diǎn)上配置一個(gè)或多個(gè)處理單元并且運(yùn)行一個(gè)或多個(gè)處理單元。