【手続補正書】
【提出日】平成23年3月18日(2011.3.18)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
ストリームデータを配信するストリーム配信装置と、配信される前記ストリームデータをクエリ処理するストリーム処理装置と、前記ストリーム処理装置の障害発生により失われる前記ストリームデータを前記ストリーム処理装置に再投入するための制御を行う障害回復装置と、を用いるストリーム処理システムによるストリーム回復方法であって、
前記ストリームデータは、クエリ処理の対象であるデータタプルと、そのデータタプルの前記ストリームデータ内における位置を示す回復ポイントタプルと、を含めて構成され、
前記ストリーム処理装置は、
前記データタプルをクエリ処理するとともに、前記回復ポイントタプルをクエリ処理から除外して一時的にバッファにプールし、前記データタプルが前記ストリーム処理装置内で削除指示されると、その削除指示対象の前記データタプルより前に位置する前記回復ポイントタプルを前記バッファから読み取って、その回復ポイントタプルが示す前記ストリームデータ内における位置情報を、記憶手段に書き出し、
前記障害回復装置は、
前記ストリーム処理装置に発生する障害を検知すると、前記記憶手段から前記ストリームデータ内における位置情報を読み取り、その位置情報のうちの最も後に位置する位置情報を前記ストリームデータ内の再投入位置とし、その再投入位置を起点とする前記ストリームデータを、前記ストリーム処理装置に再投入する旨を前記ストリーム配信装置に指示することを特徴とする
ストリーム回復方法。
【請求項２】
前記ストリーム配信装置は、入力手段を介してユーザから入力された位置情報を、前記ストリームデータ内の前記回復ポイントタプルの追加位置として、前記ストリームデータを構成することを特徴とする
請求項１に記載のストリーム回復方法。
【請求項３】
前記ストリーム処理装置は、所定の追加条件を満たすか否かを判定し、前記所定の追加条件を満たした時点で前記ストリーム配信装置から受信する前記ストリームデータに対して、前記回復ポイントタプルを挿入することを特徴とする
請求項１に記載のストリーム回復方法。
【請求項４】
前記ストリーム処理装置は、前記所定の追加条件として、受信する前記ストリームデータのデータ量が所定量になる度に、前記回復ポイントタプルを挿入することを特徴とする
請求項３に記載のストリーム回復方法。
【請求項５】
前記ストリーム処理装置は、前記所定の追加条件として、所定時間が経過する度に、前記回復ポイントタプルを挿入することを特徴とする
請求項３に記載のストリーム回復方法。
【請求項６】
前記ストリーム処理装置は、前記所定の追加条件として、前記ストリーム処理装置のハードウェア資源への負荷が所定量以上に増加する度に、前記回復ポイントタプルを挿入することを特徴とする
請求項３に記載のストリーム回復方法。
【請求項７】
前記ストリーム処理装置は、
前記クエリ処理において分岐処理を行うときには、分岐ごとに前記回復ポイントタプルを複製し、削除指示に伴って前記回復ポイントタプルの全てを前記バッファから読み取ったときに、その回復ポイントタプルが示す前記ストリームデータ内における位置情報を、前記記憶手段に書き出すことを特徴とする
請求項１〜請求項６のいずれか１項に記載のストリーム回復方法。
【請求項８】
前記回復ポイントタプルには、その所属する前記ストリームデータを特定するためのストリームＩＤが格納され、
前記ストリーム処理装置は、前記ストリームデータ内における位置情報を、ストリームＩＤごとに前記記憶手段に書き出し、
前記障害回復装置は、ストリームＩＤごとに前記記憶手段から位置情報を読み取り、その位置情報のうちの最も前に位置する位置情報を前記ストリームデータ内の再投入位置とすることを特徴とする
請求項１〜請求項７のいずれか１項に記載のストリーム回復方法。
【請求項９】
ストリームデータを配信するストリーム配信装置と、配信される前記ストリームデータをクエリ処理するストリーム処理装置と、前記ストリーム処理装置の障害発生により失われる前記ストリームデータを前記ストリーム処理装置に再投入するための制御を行う障害回復装置と、を用いるストリーム処理システムにより実行されるストリーム回復プログラムであって、
前記ストリームデータは、クエリ処理の対象であるデータタプルと、そのデータタプルの前記ストリームデータ内における位置を示す回復ポイントタプルと、を含めて構成され、
前記ストリーム処理装置に、
前記データタプルをクエリ処理するとともに、前記回復ポイントタプルをクエリ処理から除外して一時的にバッファにプールし、前記データタプルが前記ストリーム処理装置内で削除指示されると、その削除指示対象の前記データタプルより前に位置する前記回復ポイントタプルを前記バッファから読み取って、その回復ポイントタプルが示す前記ストリームデータ内における位置情報を、記憶手段に書き出す手順を実行させ、
前記障害回復装置に、
前記ストリーム処理装置に発生する障害を検知すると、前記記憶手段から前記ストリームデータ内における位置情報を読み取り、その位置情報のうちの最も後に位置する位置情報を前記ストリームデータ内の再投入位置とし、その再投入位置を起点とする前記ストリームデータを、前記ストリーム処理装置に再投入する旨を前記ストリーム配信装置に指示する手順を実行させることを特徴とする
ストリーム回復プログラム。
【請求項１０】
前記ストリーム配信装置に、入力手段を介してユーザから入力された位置情報を、前記ストリームデータ内の前記回復ポイントタプルの追加位置として、前記ストリームデータを構成する手順を実行させることを特徴とする
請求項９に記載のストリーム回復プログラム。
【請求項１１】
前記ストリーム処理装置に、所定の追加条件を満たすか否かを判定し、前記所定の追加条件を満たした時点で前記ストリーム配信装置から受信する前記ストリームデータに対して、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項９に記載のストリーム回復プログラム。
【請求項１２】
前記ストリーム処理装置に、前記所定の追加条件として、受信する前記ストリームデータのデータ量が所定量になる度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１１に記載のストリーム回復プログラム。
【請求項１３】
前記ストリーム処理装置に、前記所定の追加条件として、所定時間が経過する度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１１に記載のストリーム回復プログラム。
【請求項１４】
前記ストリーム処理装置に、前記所定の追加条件として、前記ストリーム処理装置のハードウェア資源への負荷が所定量以上に増加する度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１１に記載のストリーム回復プログラム。
【請求項１５】
前記ストリーム処理装置に、
前記クエリ処理において分岐処理を行うときには、分岐ごとに前記回復ポイントタプルを複製し、削除指示に伴って前記回復ポイントタプルの全てを前記バッファから読み取ったときに、その回復ポイントタプルが示す前記ストリームデータ内における位置情報を、前記記憶手段に書き出す手順を実行させることを特徴とする
請求項９〜請求項１４のいずれか１項に記載のストリーム回復プログラム。
【請求項１６】
前記回復ポイントタプルには、その所属する前記ストリームデータを特定するためのストリームＩＤが格納され、
前記ストリーム処理装置に、前記ストリームデータ内における位置情報を、ストリームＩＤごとに前記記憶手段に書き出す手順を実行させ、
前記障害回復装置に、ストリームＩＤごとに前記記憶手段から位置情報を読み取り、その位置情報のうちの最も前に位置する位置情報を前記ストリームデータ内の再投入位置とする手順を実行させることを特徴とする
請求項９〜請求項１５のいずれか１項に記載のストリーム回復プログラム。
【請求項１７】
ストリームデータを配信するストリーム配信装置と、配信される前記ストリームデータをクエリ処理するストリーム処理装置と、前記ストリーム処理装置の障害発生により失われる前記ストリームデータを前記ストリーム処理装置に再投入するための制御を行う障害回復装置と、を用いるストリーム処理システムにおける障害回復装置であって、
前記ストリームデータは、クエリ処理の対象であるデータタプルと、そのデータタプルの前記ストリームデータ内における位置を示す回復ポイントタプルと、を含めて構成され、
前記ストリーム処理装置に発生する障害を検知すると、前記ストリーム処理装置のクエリ処理が済んだ前記データタプルの位置を示す、前記ストリームデータ内における位置情報を記憶手段から読み取り、その位置情報のうちの最も後に位置する位置情報を前記ストリームデータ内の再投入位置とし、その再投入位置を起点とする前記ストリームデータを、前記ストリーム処理装置に再投入する旨を前記ストリーム配信装置に指示することを特徴とする
障害回復装置。
【請求項１８】
前記ストリーム配信装置に、入力手段を介してユーザから入力された位置情報を、前記ストリームデータ内の前記回復ポイントタプルの追加位置として、前記ストリームデータを構成する手順を実行させることを特徴とする
請求項１７に記載の障害回復装置。
【請求項１９】
前記ストリーム処理装置に、所定の追加条件を満たすか否かを判定し、前記所定の追加条件を満たした時点で前記ストリーム配信装置から受信する前記ストリームデータに対して、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１７に記載の障害回復装置。
【請求項２０】
前記ストリーム処理装置に、前記所定の追加条件として、受信する前記ストリームデータのデータ量が所定量になる度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１９に記載の障害回復装置。
【請求項２１】
前記ストリーム処理装置に、前記所定の追加条件として、所定時間が経過する度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１９に記載の障害回復装置。
【請求項２２】
前記ストリーム処理装置に、前記所定の追加条件として、前記ストリーム処理装置のハードウェア資源への負荷が所定量以上に増加する度に、前記回復ポイントタプルを挿入する手順を実行させることを特徴とする
請求項１９に記載の障害回復装置。
【請求項２３】
前記ストリーム処理装置に、
前記クエリ処理において分岐処理を行うときには、分岐ごとに前記回復ポイントタプルを複製し、削除指示に伴って前記回復ポイントタプルの全てを前記バッファから読み取ったときに、その回復ポイントタプルが示す前記ストリームデータ内における位置情報を、前記記憶手段に書き出す手順を実行させることを特徴とする
請求項１７〜請求項２２のいずれか１項に記載の障害回復装置。
【請求項２４】
前記回復ポイントタプルには、その所属する前記ストリームデータを特定するためのストリームＩＤが格納され、
前記ストリーム処理装置に、前記ストリームデータ内における位置情報を、ストリームＩＤごとに前記記憶手段に書き出す手順を実行させ、
ストリームＩＤごとに前記記憶手段から位置情報を読み取り、その位置情報のうちの最も前に位置する位置情報を前記ストリームデータ内の再投入位置とすることを特徴とする
請求項１７〜請求項２３のいずれか１項に記載の障害回復装置。