【手続補正書】
【提出日】平成30年4月16日(2018.4.16)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
Ｈａｄｏｏｐクラスタのノードであって、データの第１の部分をＨＤＦＳデータストレージに記憶するノードにおいて、
前記Ｈａｄｏｏｐクラスタ外部のデータソースからデータを受信することが可能なデータ処理エンジンの第１のインスタンスを実行することと、
前記データ処理エンジンによって、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを受信することと、
前記データ処理エンジンの前記第１のインスタンスによって前記データフローグラフの少なくとも一部を実行することと、
前記データ処理エンジンによって前記外部データソースからデータの第２の部分を受信することと、
前記データ処理エンジンによって、少なくとも前記データの第１の部分および前記データの第２の部分を使用する前記データ処理動作を行うことと、を含む方法。
【請求項２】
前記Ｈａｄｏｏｐクラスタは各々が前記データ処理エンジンのインスタンスを実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含むデータの第１の本体であって、前記Ｈａｄｏｏｐクラスタの他のノードによって処理されるデータの他の部分も含む、データの第１の本体に対して、および、ｂ）前記データの第２の部分を含むデータの第２の本体であって、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列でデータ処理動作を実行するために、同時に動く、請求項１に記載の方法。
【請求項３】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記データの第２の部分の前記ソースからのデータフローを表すリンクに接続される、請求項１に記載の方法。
【請求項４】
前記データ処理エンジンはＭａｐＲｅｄｕｃｅプログラミングモデルを実装していない、請求項１に記載の方法。
【請求項５】
前記データの第２の部分は揮発性メモリに記憶される、請求項１に記載の方法。
【請求項６】
データベースクエリを受信することを含み、前記データベースクエリは前記Ｈａｄｏｏｐクラスタを含む少なくとも１つのデータソースから受信されたデータに対して行われるべき少なくとも１つの動作を含み、
前記データフローグラフは前記データベースクエリに対応する動作を表すコンポーネントを含み、前記データフローグラフは、前記少なくとも１つのデータソースを表す少なくとも１つのコンポーネントと、少なくとも１つのデータソースから受信されたデータに対して行われるべき前記動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクとを含む、請求項１に記載の方法。
【請求項７】
前記データの第２の部分は前記データの第１の部分の特徴に基づいて選択された、請求項１に記載の方法。
【請求項８】
前記データの第２の部分は関係データベースの行のサブセットを含み、前記データの第２の部分は前記関係データベースの列のサブセットを含む、請求項１に記載の方法。
【請求項９】
前記データの第２の部分は、前記外部データソースから前記Ｈａｄｏｏｐクラスタの第２のノードで受信されたデータの第３の部分とは別個である、請求項１に記載の方法。
【請求項１０】
前記Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって実行される前記データフローグラフの少なくとも一部のインスタンスと通信することを含む、請求項１に記載の方法。
【請求項１１】
前記Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって前記データフローグラフの少なくとも一部を実行することを含む、請求項１に記載の方法。
【請求項１２】
データの第１の部分をＨＤＦＳデータストレージに記憶するＨａｄｏｏｐクラスタのノードに、
前記Ｈａｄｏｏｐクラスタ外部のデータソースからデータを受信することが可能なデータ処理エンジンの第１のインスタンスを実行すること、
前記データ処理エンジンによって、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを受信すること、
前記データ処理エンジンの前記第１のインスタンスによって前記データフローグラフの少なくとも一部を実行すること、
前記データ処理エンジンによって前記外部データソースからデータの第２の部分を受信すること、ならびに、
前記データ処理エンジンによって、少なくとも前記データの第１の部分および前記データの第２の部分を使用する前記データ処理動作を行うこと、を含む動作を実施させるための命令を含む、コンピュータ可読ストレージデバイス。
【請求項１３】
データの第１の部分をＨＤＦＳストレージに記憶する、Ｈａｄｏｏｐクラスタのノードであって、
前記Ｈａｄｏｏｐクラスタ外部のデータソースからデータを受信することが可能なデータ処理エンジンの第１のインスタンスを実行すること、
前記データ処理エンジンによって、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを受信すること、
前記データ処理エンジンの前記第１のインスタンスによって前記データフローグラフの少なくとも一部を実行すること、
前記データ処理エンジンによって前記外部データソースからデータの第２の部分を受信すること、ならびに、
前記データ処理エンジンによって、少なくとも前記データの第１の部分および前記データの第２の部分を使用する前記データ処理動作を行うこと、を含む動作を実施するように構成されたコンピュータ処理デバイスを含む、
Ｈａｄｏｏｐクラスタのノード。
【請求項１４】
データの第１の部分をＨＤＦＳストレージに記憶する、Ｈａｄｏｏｐクラスタのノードであって、
前記Ｈａｄｏｏｐクラスタ外部のデータソースからデータを受信することが可能なデータ処理エンジンの第１のインスタンスを実行するための手段と、
前記データ処理エンジンによって、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを受信するための手段と、
前記データ処理エンジンの前記第１のインスタンスによって前記データフローグラフの少なくとも一部を実行するための手段と、
前記データ処理エンジンによって前記外部データソースからデータの第２の部分を受信するための手段と、
前記データ処理エンジンによって、少なくとも前記データの第１の部分および前記データの第２の部分を使用する前記データ処理動作を行うための手段と、
を含む、Ｈａｄｏｏｐクラスタのノード。
【請求項１５】
ノードのクラスタのノードで、前記ノードはデータの第１の部分を記憶し、前記ノードのクラスタと共に１つまたは複数のデータ処理動作を実行するように構成され、前記クラスタは前記ノード全体からのデータの集合を記憶し、前記ノードは前記データの集合に対して並列に動作するように構成され、前記データの集合は複数の部分に分割され、各部分に対して前記クラスタのそれぞれの部分が動作し、
前記クラスタ外部のデータソースからデータを受信することが可能なデータ処理エンジンの第１のインスタンスを実行すること、
前記データ処理エンジンによって、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを受信すること、
前記データ処理エンジンの前記第１のインスタンスによって前記データフローグラフの少なくとも一部を実行すること、
前記データの第１の部分の特徴に基づいて、前記データ処理エンジンによってデータの第２の部分を要求すること、
前記データ処理エンジンによって前記外部データソースから前記データの第２の部分を受信すること、
前記データの第２の部分を前記ノードの揮発性メモリに記憶すること、ならびに、
前記データ処理エンジンによって、少なくとも前記データの第１の部分および前記データの第２の部分を使用する前記データ処理動作を行うこと、
を含む、方法。
【請求項１６】
Ｈａｄｏｏｐクラスタのノードのデータ処理エンジンで、前記データ処理エンジンによって実行される、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフによって識別されたデータ処理動作を行うことを含む方法であって、前記データ処理動作は、前記ノードのＨＤＦＳデータストレージに記憶されたデータの少なくとも第１の部分、および前記Ｈａｄｏｏｐクラスタ外部のデータソースから受信されたデータの少なくとも第２の部分を使用して行われる、方法。
【請求項１７】
Ｈａｄｏｏｐクラスタおよび関係データベースを含むデータソースを指定するＳＱＬクエリを受信すること、
前記ＳＱＬクエリに対応する、ａ）前記Ｈａｄｏｏｐクラスタを表す少なくとも１つのコンポーネントと、ｂ）前記Ｈａｄｏｏｐクラスタ外部の前記データソースを表す少なくとも１つのコンポーネントと、ｃ）データ処理動作に関連付けられた少なくとも１つのデータフローを表す少なくとも１つのリンクを含むデータフローグラフを生成すること、
前記Ｈａｄｏｏｐクラスタのノードのデータ処理エンジンで前記データフローグラフを実行すること、ならびに、
前記データ処理エンジンによって少なくとも前記Ｈａｄｏｏｐクラスタのデータおよび前記関係データベースのデータを使用する前記データ処理動作を行うこと、
を含む、方法。
【請求項１８】
Ｈａｄｏｏｐクラスタは前記データ処理エンジンのインスタンスを各々が実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含み、前記Ｈａｄｏｏｐクラスタの他のノードにより処理されるデータの他の部分も含むデータの第１の本体に対して、および、ｂ）前記データの第２の部分を含み、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列で前記データ動作を実行する、請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項１９】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタのからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記データの第２の部分の前記外部データソースからのデータフローを表すリンクに接続される、請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項２０】
前記データ処理エンジンはＭａｐＲｅｄｕｃｅプログラミングモデルを実装していない、請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項２１】
前記データの第２の部分は揮発性メモリに記憶される、請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項２２】
前記動作は、
データベースクエリを受信することを含み、前記データベースクエリは前記Ｈａｄｏｏｐクラスタを含む少なくとも１つのデータソースから受信されたデータに対して行われるべき少なくとも１つの動作を含み、
前記データフローグラフは、前記データベースクエリに対応する動作を表すコンポーネントを含み、前記データフローグラフは、前記少なくとも１つのデータソースを表す少なくとも１つのコンポーネントと、少なくとも１つのデータソースから受信されたデータに対して行われるべき前記動作に関連付けられる少なくとも１つのデータフローを表す少なくとも１つのリンクとを含む、
請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項２３】
前記データの第２の部分は前記データの第１の部分の特徴に基づいて選択された、請求項１２に記載のコンピュータ可読ストレージデバイス。
【請求項２４】
前記データの第２の部分は関係データベースの行のサブセットを含み、前記データの第２の部分は前記関係データベースの列のサブセットを含む、請求項１２に記載のコンピュータストレージデバイス。
【請求項２５】
前記データの第２の部分は、前記外部データソースから前記Ｈａｄｏｏｐクラスタの第２のノードで受信されたデータの第３の部分とは別個である、請求項１２に記載のコンピュータストレージデバイス。
【請求項２６】
前記動作は、Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって実行される前記データフローグラフの少なくとも一部のインスタンスと通信することを含む、請求項１２に記載の非一時的コンピュータストレージデバイス。
【請求項２７】
前記動作は、前記Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって前記データフローグラフの少なくとも一部を実行することを含む、請求項１２に記載の非一時的コンピュータストレージデバイス。
【請求項２８】
Ｈａｄｏｏｐクラスタは前記データ処理エンジンのインスタンスを各々が実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含み、前記Ｈａｄｏｏｐクラスタの他のノードにより処理されるデータの他の部分も含むデータの第１の本体に対して、および、ｂ）前記データの第２の部分を含み、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列で前記データ動作を実行する、請求項１３に記載のノード。
【請求項２９】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタのからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記データの第２の部分の前記外部データソースからのデータフローを表すリンクに接続される、請求項１３に記載のノード。
【請求項３０】
前記データ処理エンジンはＭａｐＲｅｄｕｃｅプログラミングモデルを実装していない、請求項１３に記載のノード。
【請求項３１】
前記データの第２の部分は揮発性メモリに記憶される、請求項１３に記載のノード。
【請求項３２】
前記動作は、
データベースクエリを受信することを含み、前記データベースクエリは前記Ｈａｄｏｏｐクラスタを含む少なくとも１つのデータソースから受信されたデータに対して行われるべき少なくとも１つの動作を含み、
前記データフローグラフは、前記データベースクエリに対応する動作を表すコンポーネントを含み、前記データフローグラフは、前記少なくとも１つのデータソースを表す少なくとも１つのコンポーネントと、少なくとも１つのデータソースから受信されたデータに対して行われるべき前記動作に関連付けられる少なくとも１つのデータフローを表す少なくとも１つのリンクとを含む、
請求項１３に記載のノード。
【請求項３３】
前記データの第２の部分は前記データの第１の部分の特徴に基づいて選択された、請求項１３に記載のノード。
【請求項３４】
前記データの第２の部分は関係データベースの行のサブセットを含み、前記データの第２の部分は前記関係データベースの列のサブセットを含む、請求項１３に記載のノード。
【請求項３５】
前記データの第２の部分は、前記外部データソースから前記Ｈａｄｏｏｐクラスタの第２のノードで受信されたデータの第３の部分とは別個である、請求項１３に記載のノード。
【請求項３６】
前記動作は、Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって実行される前記データフローグラフの少なくとも一部のインスタンスと通信することを含む、請求項１３に記載のノード。
【請求項３７】
前記動作は、前記Ｈａｄｏｏｐクラスタの外側の前記データ処理エンジンの第２のインスタンスによって前記データフローグラフの少なくとも一部を実行することを含む、請求項１３に記載のノード。
【請求項３８】
Ｈａｄｏｏｐクラスタは前記データ処理エンジンのインスタンスを各々が実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含み、前記Ｈａｄｏｏｐクラスタの他のノードにより処理されるデータの他の部分も含むデータの第１の本体に対して、および、ｂ）前記データの第２の部分を含み、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列で前記データ動作を実行する、請求項１５に記載の方法。
【請求項３９】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタのからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記データの第２の部分の前記外部データソースからのデータフローを表すリンクに接続される、請求項１５に記載の方法。
【請求項４０】
Ｈａｄｏｏｐクラスタは前記データ処理エンジンのインスタンスを各々が実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含み、前記Ｈａｄｏｏｐクラスタの他のノードにより処理されるデータの他の部分も含むデータの第１の本体に対して、および、ｂ）前記データの第２の部分を含み、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列で前記データ動作を実行する、請求項１６に記載の方法。
【請求項４１】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタのからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記データの第２の部分の前記外部データソースからのデータフローを表すリンクに接続される、請求項１６に記載の方法。
【請求項４２】
Ｈａｄｏｏｐクラスタは前記データ処理エンジンのインスタンスを各々が実行するノードを含み、前記データ処理エンジンの前記インスタンスは、ａ）前記データの第１の部分を含み、前記Ｈａｄｏｏｐクラスタの他のノードにより処理されるデータの他の部分も含むデータの第１の本体に対して、および、ｂ）前記データの第２の部分を含み、関係データベースシステムに固有の形式で記憶され、前記Ｈａｄｏｏｐクラスタの前記ノードの揮発性メモリに各々が記憶可能な部分に分割されるデータの第２の本体に対して、共に並列で前記データ動作を実行する、請求項１７に記載の方法。
【請求項４３】
前記データフローグラフの少なくとも１つのコンポーネントは前記Ｈａｄｏｏｐクラスタのからのデータフローを表すリンクに接続され、前記少なくとも１つのコンポーネントは前記関係データベースからのデータフローを表すリンクに接続される、請求項１７に記載の方法。