【手続補正書】
【提出日】令和2年6月22日(2020.6.22)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
連続クエリ言語（ＣＱＬ）エンジンから作成されるスナップショットを管理するための方法であって、
コンピューティングデバイスが、アプリケーションに関連する入力イベントのマイクロバッチストリームを受信することと、
前記コンピューティングデバイスが、前記ＣＱＬエンジンを用いて、前記入力イベントを処理して、前記アプリケーションに関連する出力イベントのセットを生成することと、
前記コンピューティングデバイスが、前記ＣＱＬエンジンによって実現されるスナップショット管理アルゴリズムを用いて、前記アプリケーションに関連する前記出力イベントのセットに少なくとも部分的に基づいて、システムの現在の状態のスナップショットを生成することと、
前記コンピューティングデバイスが、前記システムの前記現在の状態の前記スナップショットに関連付けられるスナップショット情報にアクセスするために第１のディレクトリ構造を生成することと、
前記コンピューティングデバイスが、前記システムの前記現在の状態に関連付けられるスナップショットのリストを生成するために第２のディレクトリ構造を生成することと、
前記コンピューティングデバイスが、前記システムの前記現在の状態に関連付けられる前記スナップショットのリストを取得、追加、またはクリーンにするために前記スナップショット管理アルゴリズムに少なくとも部分的に基づいてプロセスを決定することとを備える、方法。
【請求項２】
前記マイクロバッチストリームは、１秒未満のマイクロバッチに離散化されたデータの連続ストリームである、請求項１に記載の方法。
【請求項３】
前記入力イベントを処理することは、変換されたクエリプランに少なくとも部分的に基づいて、前記入力イベントを処理することを含む、請求項２に記載の方法。
【請求項４】
前記コンピューティングデバイスが、前記アプリケーションに関連する前記出力イベントのセットを出力待ち行列に格納することと、前記入力イベントのすべてが処理されたときに、前記コンピューティングデバイスが前記出力待ち行列内の前記出力イベントを送信することとをさらに備える、請求項３に記載の方法。
【請求項５】
前記マイクロバッチストリームは、マイクロバッチのデータまたはレジリエント分散データセット（ＲＤＤ）を含む、請求項４に記載の方法。
【請求項６】
前記入力イベントの各々を処理することは、前記変換されたクエリプランに少なくとも部分的に基づいて、前記入力イベントの各々に対して計算を実行することを含む、請求項５に記載の方法。
【請求項７】
前記コンピューティングデバイスが、連続クエリを受信することと、前記連続クエリに変換を適用して前記連続クエリについてクエリプランを生成することと、変換アルゴリズムを用いて前記クエリプランを変換して前記変換されたクエリプランを生成することとをさらに備え、前記連続クエリはパターンマッチングを含む、請求項６に記載の方法。
【請求項８】
システムであって、
コンピュータ実行可能命令を格納するように構成されたメモリと、
前記メモリにアクセスし、前記コンピュータ実行可能命令を実行して、
アプリケーションに関連する入力イベントのマイクロバッチストリームを受信し、
ＣＱＬエンジンを用いて、前記入力イベントを処理して、前記アプリケーションに関連する出力イベントのセットを生成し、
前記ＣＱＬエンジンによって実現されるスナップショット管理アルゴリズムを用いて、前記アプリケーションに関連する前記出力イベントのセットに少なくとも部分的に基づいて、システムの現在の状態のスナップショットを生成し、
前記システムの前記現在の状態の前記スナップショットに関連付けられるスナップショット情報にアクセスするために第１のディレクトリ構造を生成し、
前記システムの前記現在の状態に関連付けられるスナップショットのリストを生成するために第２のディレクトリ構造を生成し、
前記システムの前記現在の状態に関連付けられる前記スナップショットのリストを取得、追加、またはクリーンにするために前記スナップショット管理アルゴリズムに少なくとも部分的に基づいてプロセスを決定するよう構成されるプロセッサとを備える、システム。
【請求項９】
請求項１〜７のいずれか１項に記載の方法をプロセッサに実行させるためのコンピュータ可読プログラム。
【請求項１０】
完全にステートフルなクエリ処理をサポートするようマイクロバッチ方式ストリームを処理するための方法であって、
コンピューティングデバイスが、連続クエリを受信することと、
前記コンピューティングデバイスが、前記連続クエリに対して変換を適用して、前記連続クエリについてクエリプランを生成することと、
前記コンピューティングデバイスが、モニタリング変換プロセスを用いて前記連続クエリを監視することと、
前記コンピューティングデバイスが、アプリケーションに関連する入力イベントのマイクロバッチストリームを受信することと、
前記コンピューティングデバイスが、前記モニタリング変換プロセスに少なくとも部分的に基づいて、前記マイクロバッチストリームの前記入力イベントを処理して、前記アプリケーションに関連する出力イベントのセットを生成することとを備える、方法。
【請求項１１】
前記処理は連続クエリ処理エンジンを用いて実行され、前記処理は前記出力イベントを生成するために前記入力イベントの各々を増分的に処理することを含む、請求項１０に記載の方法。
【請求項１２】
前記変換は有向非巡回グラフ（ＤＡＧ）変換である、請求項１１に記載の方法。
【請求項１３】
前記コンピューティングデバイスが、前記アプリケーションに関連する前記出力イベントのセットを出力待ち行列に格納することと、前記入力イベントのすべてが処理されたときに、前記コンピューティングデバイスが前記出力待ち行列内の前記出力イベントを送信することとをさらに備える、請求項１２に記載の方法。
【請求項１４】
前記マイクロバッチストリームはマイクロバッチのデータまたはレジリエント分散データセット（ＲＤＤ）を含み、前記ＤＡＧ変換は頂点と辺とのセットであり、前記頂点は前記ＲＤＤを表し、前記辺は前記ＲＤＤに適用されるべき操作を表す、請求項１３に記載の方法。
【請求項１５】
前記入力イベントの各々を処理することは、変換されたクエリプランに少なくとも部分的に基づいて、前記入力イベントの各々に対して計算を実行することを含む、請求項１４に記載の方法。
【請求項１６】
前記連続クエリはパターンマッチングを含む、請求項１５に記載の方法。
【請求項１７】
システムであって、
コンピュータ実行可能命令を格納するように構成されたメモリと、
前記メモリにアクセスし、前記コンピュータ実行可能命令を実行して、
連続クエリを受信し、
前記連続クエリに対して変換を適用して、前記連続クエリについてクエリプランを生成し、
モニタリング変換プロセスを用いて前記連続クエリを監視し、
アプリケーションに関連する入力イベントのマイクロバッチストリームを受信し、
前記モニタリング変換プロセスに少なくとも部分的に基づいて、前記マイクロバッチストリームの前記入力イベントを処理して、前記アプリケーションに関連する出力イベントのセットを生成するよう構成されるプロセッサとを備える、システム。
【請求項１８】
請求項１０〜１６のいずれか１項に記載の方法をプロセッサに実行させるためのコンピュータ可読プログラム。