【手続補正書】
【提出日】平成25年8月5日(2013.8.5)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
コンポーネント・ベースのデータ・ストリーム処理アプリケーションにおいて、複数のコンポーネント間の相互接続を動的に変更する方法であって、コンピュータが、
データ・ストリームを生成する出力ポートと、データ・ストリームを消費する入力ポートとを各々が含む複数のコンポーネントを含むアプリケーション内の複数の出力ポートの各々について、対応する前記出力ポートによって生成されるデータの特性を記述するデータ・プロデューサ・プロファイルを受け取るステップと、
前記アプリケーションの複数のコンポーネントの入力ポートの各々について、前記入力ポートによって消費されるデータの特性を記述するデータ・サブスクリプション・プロファイルを受け取るステップと、
前記受け取ったデータ・プロデューサ・プロファイルと前記受け取ったデータ・サブスクリプション・プロファイルとの比較に基づいて、前記アプリケーション内の前記複数のコンポーネントの出力ポートと入力ポートとの間に接続を確立するステップと、
プロセッサ上で前記データ・ストリーム処理アプリケーションを実行して、データのストリームを処理するステップと、
前記アプリケーションの前記実行中に、新たなデータ・プロデューサ・プロファイルまたは新たなデータ・サブスクリプション・プロファイルの一方または両方を受け取るステップと、
前記新たなデータ・プロファイルを含む前記受け取ったデータ・プロファイルの比較に基づいて、出力ポートと入力ポートとの間に少なくとも１つの新たな接続を確立するステップと
を実行することを含む、前記方法。
【請求項２】
前記コンピュータが、
前記アプリケーションの実行中に、既存のデータ・プロファイルおよび既存のサブスクリプション表現のうちの少なくとも１つに対する変更を受け取るステップ
をさらに実行することを含む、請求項１に記載の方法。
【請求項３】
データ・プロデューサ・プロファイルを受け取るステップが、アプリケーション開発中の前記データ・プロファイルの指定、および、実行時アプリケーション・プログラミング・インターフェースを通じた実行中の前記アプリケーションによる前記データ・プロファイルのプログラム的指定のうちの少なくとも１つを含む、請求項１に記載の方法。
【請求項４】
データ・サブスクリプション・プロファイルを受け取るステップが、アプリケーション開発中の前記サブスクリプションの指定、および、複数の実行時アプリケーション・プログラミング・インターフェースを通じた実行中の前記アプリケーションによる前記サブスクリプションのプログラム的指定のうちの少なくとも１つを含む、請求項１に記載の方法。
【請求項５】
前記コンピュータが、
データのストリームを処理するステップが、処理要素をシステムの処理ノード上に配置し、前記処理要素を実行するステップ
をさらに実行することを含む、請求項１に記載の方法。
【請求項６】
新たな接続を確立するステップが、アプリケーション配置時および実行時に、プログラミング言語構造および実行時アプリケーション・プログラミング・インターフェースをそれぞれ用いて、各プロデューサとコンシューマとの間に動的なデータ接続を確立するステップを含む、請求項１に記載の方法。
【請求項７】
新たな接続を確立するステップが、データ・プロデューサ・プロファイル特性とデータ・サブスクリプション・プロファイル特性との間の合致の判定に従って、前記アプリケーションおよび外部データ・ソース内の出力ポートを、前記アプリケーション内の入力ポートに動的に相互接続するステップをさらに含む、請求項１に記載の方法。
【請求項８】
前記コンピュータが、
実行時に前記データ・プロデューサ・プロファイルおよび前記データ・サブスクリプション・プロファイルを操作するステップ
をさらに実行することを含む、請求項７に記載の方法。
【請求項９】
前記データ・プロデューサ・プロファイルを操作するステップが、
データ・プロデューサ・プロファイル・プロパティを、前記各出力ポートによって生成される各データ項目の値の関数として動的に操作するステップと、
データ・プロデューサ・プロファイル・プロパティを、前記各出力ポートによって生成される各データ項目のボリュームの関数として動的に操作するステップと、
プロファイル・マネージャに照会するステップと
を含む、請求項８に記載の方法。
【請求項１０】
前記データ・サブスクリプション・プロファイルを操作するステップが、
ストリーム・サブスクリプション表現を変更するステップと、
サブスクリプション関数を修正するステップと
を含む、請求項８に記載の方法。
【請求項１１】
前記接続を確立するステップが、
計算されたルートをデータ・フロー・モジュール内に格納するステップと、
データ・プロファイルおよびデータ・サブスクリプションのうちの少なくとも１つに変化が生じたことに応じて、前記データ・フロー・モジュール内に格納された情報を更新するステップと
をさらに含む、請求項１に記載の方法。
【請求項１２】
出力ポートによって生成される前記データの特性が、前記データのソースが搬送する全てのデータに適用されるプロファイルの形式で表された特性を含む、請求項１に記載の方法。
【請求項１３】
入力ポートによって消費されるデータの特性が、宣言型サブスクリプション表現、手続型サブスクリプション技法、およびデータ・ソース・プロファイル・プロパティ上で定義された論理述語のうちの少なくとも１つを含む、請求項１に記載の方法。
【請求項１４】
前記コンピュータが、
コンシューマ・サブスクリプションを動的に変更するステップ
をさらに実行することを含む、請求項１に記載の方法。
【請求項１５】
前記コンピュータが、
出力ポートによって生成されたエクスポートされたデータの特性のエクスポートされた記述を動的に変更するステップ
をさらに実行することを含む、請求項１に記載の方法。
【請求項１６】
前記コンピュータが、
データ・コンシューマに接続されるデータ源の集合に制約を課すために該コンシューマによって利用される順位付け基準を、作成および修正するステップ
をさらに実行することを含む、請求項１に記載の方法。
【請求項１７】
前記コンピュータが、
トリガ機構を用いてストリームの合致を動的に計算するステップ
をさらに実行することを含み、
前記ストリームの合致を計算するステップは、
各サブスクリプション表現および各サブスクリプション関数を登録するステップと、
新たに登録されたストリーム上の各サブスクリプション表現および各サブスクリプション関数のうちの少なくとも１つに基づき、トリガ条件を評価するステップと、
ストリーム・プロパティにおける変化に基づき、トリガ条件を評価するステップと、
サブスクリプション表現およびサブスクリプション関数のうちの少なくとも１つにおける変化に応じて、トリガ条件を評価するステップと
を含む、請求項１に記載の方法。
【請求項１８】
コンポーネント・ベースのデータ・ストリーム処理アプリケーションにおいて、複数のコンポーネント間の相互接続を動的に変更するコンピュータ・プログラムであって、コンピュータに、請求項１〜１７のいずれか一項に記載の方法の各ステップをコンピュータに実行させる、前記コンピュータ・プログラム。
【請求項１９】
コンポーネント・ベースのデータ・ストリーム処理アプリケーションにおいて、複数のコンポーネント間の相互接続を動的に変更するシステムであって、請求項１〜１７のいずれか一項に記載の方法の各ステップを実行する手段を備えている、前記システム。
【請求項２０】
コンポーネント・ベースのデータ・ストリーム処理アプリケーションにおいて、複数のコンポーネント間の相互接続を動的に変更するためのプログラムであって、コンピュータに、
データ・ストリームを生成する出力ポートと、データ・ストリームを消費する入力ポートとを各々が含む複数のコンポーネントを含むアプリケーション内の複数の出力ポートの各々について、対応する前記出力ポートによって生成されるデータの特性を記述するデータ・プロデューサ・プロファイルを受け取るステップと、
前記アプリケーションの複数のコンポーネントの入力ポートの各々について、前記入力ポートによって消費されるデータの特性を記述するデータ・サブスクリプション・プロファイルを受け取るステップと、
前記受け取ったデータ・プロデューサ・プロファイルと前記受け取ったデータ・サブスクリプション・プロファイルとの比較に基づいて、前記アプリケーション内の前記複数のコンポーネントの出力ポートと入力ポートとの間に接続を確立するステップと、
プロセッサ上で前記データ・ストリーム処理アプリケーションを実行して、データのストリームを処理するステップと、
前記アプリケーションの前記実行中に、新たなデータ・プロデューサ・プロファイルまたは新たなデータ・サブスクリプション・プロファイルの一方または両方を受け取るステップと、
前記新たなデータ・プロファイルを含む前記受け取ったデータ・プロファイルの比較に基づいて、出力ポートと入力ポートとの間に少なくとも１つの新たな接続を確立するステップと
を実行させる、前記プログラム。
【請求項２１】
コンポーネント・ベースのデータ・ストリーム処理アプリケーションにおいて、複数のコンポーネント間の相互接続を動的に変更するシステムであって、
プロセッサと、
前記プロセッサに結合されたメモリと、
データ・ストリームを生成する出力ポートと、データ・ストリームを消費する入力ポートとを各々が含む複数のコンポーネントを含むアプリケーション内の複数の出力ポートの各々について、対応する前記出力ポートによって生成されるデータの特性を記述するデータ・プロデューサ・プロファイルを受け取るプロファイル・マネージャと、
前記アプリケーションの複数のコンポーネントの入力ポートの各々について、前記入力ポートによって消費されるデータの特性を記述するデータ・サブスクリプション・プロファイルを受け取るサブスクリプション表現マネージャ・モジュールと、
前記受け取ったデータ・プロデューサ・プロファイルと前記受け取ったデータ・サブスクリプション・プロファイルとの比較に基づいて、前記アプリケーション内の前記複数のコンポーネントの出力ポートと入力ポートとの間に接続を確立する前記メモリ上に格納されたデータ・フロー・モジュールと
を備えている、前記システム。