(57)【特許請求の範囲】
【請求項１】
クライアント装置と、複数のノード装置と、を含むデータストリーム処理システムであって、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する構成情報記憶手段を備え、
前記クライアント装置は、
前記情報種特定情報及び前記処理特定情報を含むクエリ要求を受け付け、当該受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を備え、
前記ノード装置は、
前記クライアント装置、又は、他のノード装置から、前記クエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備え、
前記クエリ要求受付手段は、複数の前記情報種特定情報と、当該複数の情報種特定情報のそれぞれにより特定される情報種の前記データストリームに対して行う処理を特定するための前記処理特定情報と、を含む前記クエリ要求を受け付けるように構成され、
さらに、前記ノード装置は、前記受け付けたクエリ要求に含まれる前記複数の情報種特定情報のそれぞれに対して、当該情報種特定情報と対応付けて記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて記憶されているクエリ要求を取得し当該取得したクエリ要求を当該ノード装置へ出力するクエリ要求出力手段を備える、
データストリーム処理システム。
【請求項２】
請求項１に記載のデータストリーム処理システムであって、
前記処理結果出力手段は、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成されたデータストリーム処理システム。
【請求項３】
請求項１又は請求項２に記載のデータストリーム処理システムであって
前記クライアント装置が前記ノード装置へ前記クエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置を特定するためのノード特定情報と、を対応付けて前記構成情報記憶手段に記憶させる構成情報記憶処理手段を備えるデータストリーム処理システム。
【請求項４】
請求項１乃至請求項３のいずれか一項に記載のデータストリーム処理システムであって、
前記クライアント装置は、前記記憶されている情報種特定情報をユーザに通知する情報種特定情報通知手段を備えるデータストリーム処理システム。
【請求項５】
クライアント装置と、複数のノード装置と、を含むデータストリーム処理システムに適用され、
前記クライアント装置が、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付け、
前記クライアント装置が、前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力し、
前記ノード装置が、前記クライアント装置、又は、他のノード装置から、前記クエリ要求を受け付け、
前記ノード装置が、前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力し、
さらに、前記ノード装置が、複数の前記情報種特定情報と、当該複数の情報種特定情報のそれぞれにより特定される情報種の前記データストリームに対して行う処理を特定するための前記処理特定情報と、を含む前記クエリ要求を受け付け、
前記ノード装置が、前記受け付けたクエリ要求に含まれる前記複数の情報種特定情報のそれぞれに対して、当該情報種特定情報と対応付けて記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて記憶されているクエリ要求を取得し当該取得したクエリ要求を当該ノード装置へ出力する、
データストリーム処理方法。
【請求項６】
ノード装置であって、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備え、
前記処理結果出力手段は、
前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成され、
前記クエリ要求受付手段は、複数の前記情報種特定情報と、当該複数の情報種特定情報のそれぞれにより特定される情報種の前記データストリームに対して行う処理を特定するための前記処理特定情報と、を含む前記クエリ要求を受け付けるように構成され、
さらに、前記受け付けたクエリ要求に含まれる前記複数の情報種特定情報のそれぞれに対して、当該情報種特定情報と対応付けて記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて記憶されているクエリ要求を取得し当該取得したクエリ要求を当該ノード装置へ出力するクエリ要求出力手段を備える、
ノード装置。
【請求項７】
ノード装置に、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を実現させるととともに、
前記処理結果出力手段は、
前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成され、
前記クエリ要求受付手段は、複数の前記情報種特定情報と、当該複数の情報種特定情報のそれぞれにより特定される情報種の前記データストリームに対して行う処理を特定するための前記処理特定情報と、を含む前記クエリ要求を受け付けるように構成され、
さらに、前記ノード装置に、前記受け付けたクエリ要求に含まれる前記複数の情報種特定情報のそれぞれに対して、当該情報種特定情報と対応付けて記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて記憶されているクエリ要求を取得し当該取得したクエリ要求を当該ノード装置へ出力するクエリ要求出力手段を実現させるためのプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、時間の経過に伴って逐次生成されるデータであるデータストリームを処理するデータストリーム処理システムに関する。
【背景技術】
【０００２】
時間の経過に伴って逐次生成される大量のイベントデータであるデータストリームをリアルタイムに処理する技術として、データストリーム処理システム（ＤＳＭＳ；Ｄａｔａ  Ｓｔｒｅａｍ  Ｍａｎａｇｅｍｅｎｔ  Ｓｙｓｔｅｍ）が知られている。データストリーム処理システムは、リアルタイムに流れ続ける一過性のデータを、データベースに格納・蓄積することなく、予め登録されたクエリ要求に基づいて逐次処理するとともに、その処理結果を逐次出力する。
【０００３】
この種のデータストリーム処理システムの一つとして非特許文献１に記載のデータストリーム処理システムは、複数のノード装置を含む。各ノード装置には、互いに異なる情報の種類（情報種）のデータストリームが入力される。各ノード装置は、予め登録されたクエリ要求に基づいて、入力されたデータストリームに対する処理を逐次行い、その処理結果を他のノード装置へ逐次出力する。データストリーム処理システムは、複数のデータストリームを、複数のノード装置によって分散して処理するとともに、その処理結果を統合することにより、ユーザにより要求された情報を出力する。
【先行技術文献】
【非特許文献】
【０００４】
【非特許文献１】D.  Abadi、外８名、「Aurora:  A  New  Model  and  Architecture  for  Data  Stream  Management」、The  VLDB  Journal、Springer  Berlin、２００３年８月、第12巻、第2号、p.120−139
【発明の概要】
【発明が解決しようとする課題】
【０００５】
ところで、上記データストリーム処理システムにおいて、ユーザは、データストリーム処理システムに入力されるデータストリームから、所望の情報を取得するためのクエリ要求を、ＧＵＩ（Ｇｒａｐｈｉｃａｌ  Ｕｓｅｒ  Ｉｎｔｅｒｆａｃｅ）を用いて手動で入力する。
【０００６】
従って、ユーザは、各ノード装置に入力されるデータストリームの情報種、及び、ノード装置の構成等をすべて把握しておかなければ、適切なクエリ要求を入力することができない。このため、特に、所望の情報を取得するために比較的複雑な処理が必要とされる場合、ユーザが、適切なクエリ要求を入力することが困難であるという問題があった。
【０００７】
このため、本発明の目的は、上述した課題である「ユーザが、適切なクエリ要求を入力することが困難であること」を解決することが可能なデータストリーム処理システムを提供することにある。
【課題を解決するための手段】
【０００８】
かかる目的を達成するため本発明の一形態であるデータストリーム処理システムは、クライアント装置と、複数のノード装置と、を含むシステムである。
【０００９】
更に、このデータストリーム処理システムは、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する構成情報記憶手段を備え、
上記クライアント装置は、
上記情報種特定情報及び上記処理特定情報を含むクエリ要求を受け付け、当該受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を備え、
上記ノード装置は、
上記クライアント装置、又は、他のノード装置から、上記クエリ要求を受け付けるクエリ要求受付手段と、
上記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の上記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備える。
【００１０】
また、本発明の他の形態であるデータストリーム処理方法は、
クライアント装置と、複数のノード装置と、を含むデータストリーム処理システムに適用され、
上記クライアント装置が、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付け、
上記クライアント装置が、上記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、上記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力し、
上記ノード装置が、上記クライアント装置、又は、他のノード装置から、上記クエリ要求を受け付け、
上記ノード装置が、上記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の上記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する方法である。
【００１１】
また、本発明の他の形態であるクライアント装置は、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるとともに、上記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、上記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を備える。
【００１２】
また、本発明の他の形態であるプログラムは、
クライアント装置に、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるとともに、上記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、上記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を実現させるためのプログラムである。
【００１３】
また、本発明の他の形態であるノード装置は、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
上記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の上記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備え、
上記処理結果出力手段は、
上記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、上記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成される。
【００１４】
また、本発明の他の形態であるプログラムは、
ノード装置に、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
上記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の上記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を実現させるととともに、
上記処理結果出力手段は、
上記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、上記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成される。
【発明の効果】
【００１５】
本発明は、以上のように構成されることにより、ユーザにクエリ要求を容易に入力させることができる。
【図面の簡単な説明】
【００１６】
【図１】本発明の第１実施形態に係るデータストリーム処理システムの概略構成を表す図である。
【図２】本発明の第１実施形態に係るデータストリーム処理システムの機能の概略を表すブロック図である。
【図３】本発明の第１実施形態に係る管理装置が記憶する構成テーブルである。
【図４】本発明の第１実施形態に係る管理装置が記憶する知識テーブルである。
【図５】本発明の第１実施形態に係る管理装置が記憶する構成テーブルである。
【図６】本発明の第１実施形態に係る管理装置が記憶する知識テーブルである。
【図７】本発明の第１実施形態に係る管理装置が記憶する構成テーブルである。
【図８】本発明の第１実施形態に係る管理装置が記憶する知識テーブルである。
【図９】本発明の第２実施形態に係るデータストリーム処理システムの機能の概略を表すブロック図である。
【発明を実施するための形態】
【００１７】
以下、本発明に係る、データストリーム処理システム、データストリーム処理方法、クライアント装置、プログラム、及び、ノード装置、の各実施形態について図１〜図９を参照しながら説明する。
【００１８】
＜第１実施形態＞
（構成）
図１に示したように、第１実施形態に係るデータストリーム処理システム１は、管理装置１０と、クライアント装置２０と、複数（本例では、４つ）のノード装置３０ａ，３０ｂ，３０ｃ，３０ｄと、複数（本例では、５つ）のデータストリーム出力装置４０ａ，４０ｂ，４０ｃ，４０ｄ，４０ｅと、を含む。
【００１９】
なお、ノード装置３０ａは、ノード装置＃１とも表記され、ノード装置３０ｂは、ノード装置＃２とも表記され、ノード装置３０ｃは、ノード装置＃３とも表記され、ノード装置３０ｄは、ノード装置＃４とも表記される。
【００２０】
また、データストリーム出力装置４０ａは、データストリーム出力装置＃１とも表記され、データストリーム出力装置４０ｂは、データストリーム出力装置＃２とも表記され、データストリーム出力装置４０ｃは、データストリーム出力装置＃３とも表記され、データストリーム出力装置４０ｄは、データストリーム出力装置＃４とも表記され、データストリーム出力装置４０ｅは、データストリーム出力装置＃５とも表記される。
【００２１】
管理装置１０、クライアント装置２０、及び、複数のノード装置３０ａ〜３０ｄは、ＩＰ（Ｉｎｔｅｒｎｅｔ  Ｐｒｏｔｏｃｏｌ）網を構成する通信回線ＮＷを介して、互いに通信可能に接続されている。
【００２２】
管理装置１０、クライアント装置２０、及び、複数のノード装置３０ａ〜３０ｄのそれぞれ（各装置１０，２０，３０ａ〜３０ｄ）は、情報処理装置である。各装置１０，２０，３０ａ〜３０ｄは、図示しない中央処理装置（ＣＰＵ；Ｃｅｎｔｒａｌ  Ｐｒｏｃｅｓｓｉｎｇ  Ｕｎｉｔ）、及び、記憶装置（メモリ及びハードディスク駆動装置（ＨＤＤ；Ｈａｒｄ  Ｄｉｓｋ  Ｄｒｉｖｅ））を備える。各装置１０，２０，３０ａ〜３０ｄは、記憶装置に記憶されているプログラムをＣＰＵが実行することにより、後述する機能を実現するように構成されている。
【００２３】
なお、管理装置１０は、ストレージ装置であってもよい。また、クライアント装置２０は、入力装置（例えば、キーボード及びマウス等）、及び、出力装置（例えば、ディスプレイ等）を備える。また、管理装置１０、クライアント装置２０、及び、複数のノード装置３０ａ〜３０ｄの一部（例えば、ノード装置３０ａ及びノード装置３０ｂ）は、１つの情報処理装置により構成されていてもよい。また、管理装置１０、クライアント装置２０、及び、複数のノード装置３０ａ〜３０ｄのすべてが、１つの情報処理装置により構成されていてもよい。
【００２４】
データストリーム出力装置４０ａは、情報の種類である情報種ａのデータであり、且つ、時間の経過に伴って逐次生成されるデータである、データストリームをノード装置３０ａへ出力する。本例では、データストリーム出力装置４０ａは、図示しないセンサを備え、センサが逐次出力するデータをデータストリームとして受け付け、当該受け付けたデータストリームを出力する。
【００２５】
例えば、情報種ａのデータ（データストリーム）は、ＲＦＩＤ（Ｒａｄｉｏ  Ｆｒｅｑｕｅｎｃｙ  Ｉｄｅｎｔｉｆｉｃａｔｉｏｎ）タグから読み取られた識別子及び位置情報である。なお、情報種ａのデータは、走行中の車両の識別子、位置情報、及び、速度情報等であってもよく、販売された商品の識別子、及び、価格情報等であってもよい。
【００２６】
また、データストリーム出力装置４０ｂは、情報種ｂのデータストリームをノード装置３０ｂへ出力する。同様に、データストリーム出力装置４０ｃは、情報種ｃのデータストリームをノード装置３０ｃへ出力する。同様に、データストリーム出力装置４０ｄは、情報種ｄのデータストリームをノード装置３０ｄへ出力する。同様に、データストリーム出力装置４０ｅは、情報種ｅのデータストリームをノード装置３０ｄへ出力する。
なお、複数の情報種ａ，ｂ，ｃ，ｄ，ｅは、互いに異なる情報種である。
【００２７】
（機能）
図２は、上記のように構成されたデータストリーム処理システム１の機能を表すブロック図である。
【００２８】
管理装置１０の機能は、構成情報記憶部（構成情報記憶手段）１１を含む。構成情報記憶部１１は、管理装置１０が備える記憶装置により実現される機能である。
構成情報記憶部１１は、構成テーブルと、知識テーブルと、を記憶する。
【００２９】
構成テーブルは、図３に示したように、情報種特定情報と、ノード特定情報と、からなる組を少なくとも１つ含む。情報種特定情報は、情報種を特定するための情報である。例えば、情報種ａを特定するための情報種特定情報は、「ａ」と表記され、情報種ｂを特定するための情報種特定情報は、「ｂ」と表記される。
【００３０】
また、ノード特定情報は、当該ノード特定情報と同一の組を構成する情報種特定情報により特定される情報種のデータを出力可能なノード装置を特定するための情報である。例えば、ノード装置＃１を特定するためのノード特定情報は、「１」と表記され、ノード装置＃２を特定するためのノード特定情報は、「２」と表記される。
【００３１】
知識テーブルは、図４に示したように、情報種特定情報と、クエリ要求と、からなる組を少なくとも１つ含む。クエリ要求は、当該クエリ要求と同一の組を構成する情報種特定情報により特定される情報種のデータを処理結果として出力する基となった情報である。クエリ要求は、情報種特定情報と、当該情報種特定情報により特定される情報種のデータストリームに対して行う処理を特定するための処理特定情報と、を含む。
【００３２】
例えば、情報種ａを特定するための情報種特定情報と、情報種ａのデータストリームに対して処理を行うことなく当該データストリームを処理結果として出力させる処理を特定するための処理特定情報と、を含むクエリ要求は、「ａ」と表記される。また、情報種ａを特定するための情報種特定情報と、情報種ａのデータストリームを引数として与えた場合の関数ＱＦの値を処理結果として出力させる処理を特定するための処理特定情報と、を含むクエリ要求は、「ＱＦ（ａ）」と表記される。
【００３３】
本例では、クエリ要求は、ＣＱＬ（Ｃｏｎｔｉｎｕｏｕｓ  Ｑｕｅｒｙ  Ｌａｎｇｕａｇｅ）に従った情報である。なお、クエリ要求は、ＴＱＬ（Ｔａｐｅｓｔｒｙ  Ｑｕｅｒｙ  Ｌａｎｇｕａｇｅ）、又は、ＳＱＬ（Ｓｔｒｕｃｔｕｒｅｄ  Ｑｕｅｒｙ  Ｌａｎｇｕａｇｅ）に従った情報であってもよい。
【００３４】
このように、構成情報記憶部１１は、クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶している、と言うことができる。
【００３５】
また、管理装置１０は、クライアント装置２０、又は、ノード装置３０ａ〜３０ｄから、ノード特定情報送信要求を受信する。ノード特定情報送信要求は、情報種特定情報を含む。管理装置１０は、ノード特定情報送信要求を受信した場合、当該ノード特定情報送信要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報を、当該ノード特定情報送信要求を送信してきた装置（即ち、クライアント装置２０、又は、ノード装置３０ａ〜３０ｄ）へ送信する。
【００３６】
また、管理装置１０は、ノード装置３０ａ〜３０ｄから、クエリ要求送信要求を受信する。クエリ要求送信要求は、情報種特定情報を含む。管理装置１０は、クエリ要求送信要求を受信した場合、当該クエリ要求送信要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求を、当該クエリ要求送信要求を送信してきた装置（即ち、ノード装置３０ａ〜３０ｄ）へ送信する。
【００３７】
また、管理装置１０は、クライアント装置２０から、知識テーブル送信要求を受信する。知識テーブル送信要求は、構成情報記憶部１１が記憶している知識テーブルの送信を要求する旨を表す情報である。管理装置１０は、知識テーブル送信要求を受信した場合、構成情報記憶部１１に記憶されている知識テーブルをクライアント装置２０へ送信する。
【００３８】
また、管理装置１０は、ノード装置３０ａ〜３０ｄから、構成情報登録要求を受信する。構成情報登録要求は、ノード特定情報と、クエリ要求と、を含む。管理装置１０は、構成情報登録要求を受信した場合、構成情報記憶部１１に記憶されていない情報種特定情報（即ち、構成情報登録要求に含まれるクエリ要求に基づく処理結果の情報種を特定するための情報）を生成する。
【００３９】
そして、管理装置１０は、生成した情報種特定情報と、構成情報登録要求に含まれるノード特定情報と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報と、構成情報登録要求に含まれるクエリ要求と、からなる組を知識テーブルに追加する。
【００４０】
このように、管理装置１０は、生成した情報種特定情報と、構成情報登録要求に含まれるノード特定情報と、当該構成情報登録要求に含まれるクエリ要求と、を対応付けて構成情報記憶部１１に記憶させる。
【００４１】
クライアント装置２０の機能は、情報種特定情報通知部（情報種特定情報通知手段）２１と、クエリ要求出力部（クエリ要求出力手段）２２と、を含む。
【００４２】
情報種特定情報通知部２１は、予め設定された送信周期が経過する毎に、知識テーブル送信要求を管理装置１０へ送信する。これにより、情報種特定情報通知部２１は、管理装置１０から知識テーブルを受信する。情報種特定情報通知部２１は、受信した知識テーブルを出力装置を介して出力する。これにより、情報種特定情報通知部２１は、構成情報記憶部１１に記憶されている情報種特定情報をユーザに通知する。
【００４３】
これによれば、ユーザは、通知された情報種特定情報を用いてクエリ要求を入力することができる。この結果、ユーザの利便性をより一層向上させることができる。
【００４４】
クエリ要求出力部２２は、ユーザにより入力装置を介して入力されたクエリ要求を受け付ける。クエリ要求出力部２２は、受け付けたクエリ要求に含まれる情報種特定情報を取得する。クエリ要求出力部２２は、取得した情報種特定情報を含むノード特定情報送信要求を管理装置１０へ送信する。
【００４５】
これにより、クエリ要求出力部２２は、管理装置１０からノード特定情報を受信する。そして、クエリ要求出力部２２は、受信したノード特定情報により特定されるノード装置３０ａ〜３０ｄへ、上記受け付けたクエリ要求を送信する。このように、クエリ要求出力部２２は、受け付けたクエリ要求に含まれる情報種特定情報と対応付けて構成情報記憶部１１に記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力する。
【００４６】
ノード装置３０ａの機能は、クエリ要求受付部（クエリ要求受付手段）３１と、処理結果出力部（処理結果出力手段）３２と、構成情報記憶処理部（構成情報記憶処理手段）３３と、クエリ要求出力部（クエリ要求出力手段）３４と、を含む。
【００４７】
クエリ要求受付部３１は、クライアント装置２０、又は、他のノード装置３０ｂ〜３０ｄから、クエリ要求を受け付ける。本例では、クエリ要求は、少なくとも１つの情報種特定情報と、当該情報種特定情報のそれぞれにより特定される情報種のデータストリームに対して行う処理を特定するための処理特定情報と、を含む。
【００４８】
処理結果出力部３２は、クエリ要求受付部３１により受け付けられたクエリ要求に含まれる情報種特定情報のそれぞれにより特定される情報種のデータストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。そして、処理結果出力部３２は、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する。
【００４９】
具体的には、処理結果出力部３２は、受け付けられたクエリ要求に含まれる情報種特定情報のそれぞれに対して、下記の処理を行う。
処理結果出力部３２は、情報種特定情報を含むノード特定情報送信要求を管理装置１０へ送信する。処理結果出力部３２は、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報を受信する。
【００５０】
処理結果出力部３２は、受信したノード特定情報により特定されるノード装置が自装置（ノード装置３０ａ）である場合に、上記情報種特定情報を含むクエリ要求送信要求を管理装置１０へ送信する。処理結果出力部３２は、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求を受信する。
【００５１】
処理結果出力部３２は、受信したクエリ要求に含まれる情報種特定情報により特定される情報種（ここでは、情報種ａ）のデータストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。そして、処理結果出力部３２は、その処理結果を取得する。即ち、処理結果出力部３２は、クエリ要求受付部３１により受け付けられたクエリ要求に含まれる情報種特定情報と対応付けて構成情報記憶部１１に記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得する。
【００５２】
このようにして、処理結果出力部３２は、受け付けられたクエリ要求に含まれる情報種特定情報のそれぞれに対して、上記の処理を行う。
【００５３】
クエリ要求出力部３４は、クエリ要求受付部３１により受け付けられたクエリ要求に含まれる情報種特定情報のそれぞれに対して、下記の処理を行う。
クエリ要求出力部３４は、情報種特定情報を含むノード特定情報送信要求を管理装置１０へ送信する。クエリ要求出力部３４は、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報を受信する。
【００５４】
クエリ要求出力部３４は、受信したノード特定情報により特定されるノード装置が自装置（ノード装置３０ａ）でない場合に、上記情報種特定情報を含むクエリ要求送信要求を管理装置１０へ送信する。クエリ要求出力部３４は、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求を受信（取得）する。
【００５５】
クエリ要求出力部３４は、受信したクエリ要求を、上記受信したノード特定情報により特定されるノード装置へ送信（出力）する。即ち、クエリ要求出力部３４は、情報種特定情報と対応付けて構成情報記憶部１１に記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて構成情報記憶部１１に記憶されているクエリ要求を取得し、当該取得したクエリ要求を当該ノード装置へ出力する。
【００５６】
クエリ要求出力部３４は、クエリ要求に応じて当該ノード装置により送信された処理結果を受信（取得）する。
このようにして、クエリ要求出力部３４は、受け付けられたクエリ要求に含まれる情報種特定情報のそれぞれに対して、上記の処理を行う。
【００５７】
これによれば、ノード装置３０ａは、自装置が取得できないデータの情報種を特定するための情報種特定情報を含むクエリ要求を受け付けた場合に、当該データを取得するためのクエリ要求を、当該データを出力可能な他のノード装置３０ｂ〜３０ｄへ出力する。これにより、データストリーム処理システム１は、複数のノード装置３０ａ〜３０ｄのそれぞれから出力される処理結果に基づく情報を適切に取得することができる。
【００５８】
更に、処理結果出力部３２は、取得した処理結果と、クエリ要求出力部３４により取得された処理結果と、クエリ要求受付部３１により受け付けられたクエリ要求と、に基づいて、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。そして、処理結果出力部３２は、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する。
【００５９】
構成情報記憶処理部３３は、ノード装置３０ａと管理装置１０とが通信可能となった場合、データストリーム出力装置（ここでは、データストリーム出力装置４０ａ）から自装置に入力されるデータストリームの情報種（ここでは、情報種ａ）毎に、構成情報登録要求を管理装置１０へ送信する。
【００６０】
この構成情報登録要求は、自装置に入力されるデータストリームの情報種を特定するための情報種特定情報と、当該情報種のデータストリームに対して処理を行うことなく当該データストリームを処理結果として出力させる処理を特定するための処理特定情報と、を含むクエリ要求（ここでは、「ａ」）と、自装置（ノード装置３０ａ）を特定するためのノード特定情報（ここでは、「１」）と、を含む。
【００６１】
また、構成情報記憶処理部３３は、クエリ要求受付部３１によりクエリ要求が受け付けられた場合、構成情報登録要求を管理装置１０へ送信する。この構成情報登録要求は、当該受け付けられたクエリ要求と、自装置（ノード装置３０ａ）を特定するためのノード特定情報（ここでは、「１」）と、を含む。
【００６２】
上述したように、管理装置１０は、構成情報登録要求を受信すると、構成情報記憶部１１に記憶されていない情報種特定情報を生成する。そして、管理装置１０は、生成した情報種特定情報と、構成情報登録要求に含まれるノード特定情報と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報と、構成情報登録要求に含まれるクエリ要求と、からなる組を知識テーブルに追加する。
【００６３】
このようにして、構成情報記憶処理部３３は、クエリ要求を受け付けた（例えば、クライアント装置２０がノード装置３０ａへクエリ要求を出力した）場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、ノード装置３０ａを特定するためのノード特定情報と、を対応付けて構成情報記憶部１１に記憶させている、と言うことができる。
【００６４】
なお、ノード装置３０ｂ〜３０ｄも、ノード装置３０ａと同様の機能を有する。
【００６５】
（作動）
次に、上述したデータストリーム処理システム１の作動について説明する。
先ず、各ノード装置３０ａ〜３０ｄと、管理装置１０と、が通信可能な状態となった時点から説明する。
【００６６】
この時点では、ノード装置３０ａは、クエリ要求「ａ」と、ノード特定情報「１」と、を含む構成情報登録要求を管理装置１０へ送信する。これにより、管理装置１０は、情報種特定情報「ａ」を生成する。そして、管理装置１０は、生成した情報種特定情報「ａ」と、構成情報登録要求に含まれるノード特定情報「１」と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報「ａ」と、構成情報登録要求に含まれるクエリ要求「ａ」と、からなる組を知識テーブルに追加する。
【００６７】
同様に、ノード装置３０ｂは、クエリ要求「ｂ」と、ノード特定情報「２」と、を含む構成情報登録要求を管理装置１０へ送信する。また、ノード装置３０ｃは、クエリ要求「ｃ」と、ノード特定情報「３」と、を含む構成情報登録要求を管理装置１０へ送信する。同様に、ノード装置３０ｄは、クエリ要求「ｄ」と、ノード特定情報「４」と、を含む構成情報登録要求を管理装置１０へ送信する。更に、ノード装置３０ｄは、クエリ要求「ｅ」と、ノード特定情報「４」と、を含む構成情報登録要求を管理装置１０へ送信する。
【００６８】
これにより、この時点では、構成情報記憶部１１に記憶されている構成テーブルは、図３に示したようになる。また、構成情報記憶部１１に記憶されている知識テーブルは、図４に示したようになる。
【００６９】
一方、クライアント装置２０は、送信周期が経過する毎に、知識テーブル送信要求を管理装置１０へ送信する。これにより、クライアント装置２０は、管理装置１０から知識テーブルを受信する。そして、クライアント装置２０は、受信した知識テーブルを出力装置を介して出力する。これにより、クライアント装置２０は、構成情報記憶部１１に記憶されている情報種特定情報をクライアント装置２０のユーザに通知する。
【００７０】
これにより、ユーザは、出力されている情報種特定情報を用いたクエリ要求をクライアント装置２０に入力する。
いま、ユーザが、クエリ要求「ＱＦ（ａ）」を入力した場合を想定して説明を続ける。この場合、クライアント装置２０は、ユーザにより入力されたクエリ要求「ＱＦ（ａ）」を受け付ける。
【００７１】
クライアント装置２０は、受け付けたクエリ要求「ＱＦ（ａ）」に含まれる情報種特定情報「ａ」を取得する。クライアント装置２０は、取得した情報種特定情報「ａ」を含むノード特定情報送信要求を管理装置１０へ送信する。
【００７２】
これにより、クライアント装置２０は、管理装置１０からノード特定情報「１」を受信する。そして、クライアント装置２０は、受信したノード特定情報「１」により特定されるノード装置３０ａへ、上記受け付けたクエリ要求「ＱＦ（ａ）」を送信する。
【００７３】
ノード装置３０ａは、クライアント装置２０からクエリ要求「ＱＦ（ａ）」を受信する（受け付ける）。次いで、ノード装置３０ａは、受け付けたクエリ要求「ＱＦ（ａ）」に含まれる情報種特定情報「ａ」を含むノード特定情報送信要求を管理装置１０へ送信する。
【００７４】
これにより、管理装置１０は、情報種特定情報「ａ」と対応付けて記憶されているノード特定情報「１」をノード装置３０ａへ送信する。
そして、ノード装置３０ａは、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報「１」を受信する。
【００７５】
ノード装置３０ａが受信したノード特定情報「１」により特定されるノード装置＃１は、自装置（ノード装置３０ａ）である。従って、ノード装置３０ａは、情報種特定情報「ａ」を含むクエリ要求送信要求を管理装置１０へ送信する。
【００７６】
これにより、管理装置１０は、情報種特定情報「ａ」と対応付けて記憶されているクエリ要求「ａ」をノード装置３０ａへ送信する。
そして、ノード装置３０ａは、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求「ａ」を受信する。
【００７７】
次いで、ノード装置３０ａは、受信したクエリ要求「ａ」に含まれる情報種特定情報「ａ」により特定される情報種ａのデータストリーム（ここでは、データストリーム出力装置４０ａから入力されるデータストリーム）に対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。
【００７８】
ここでは、クエリ要求「ａ」に含まれる処理特定情報は、情報種ａのデータストリームに対して処理を行うことなく当該データストリームを処理結果として出力させる処理を特定するための情報である。従って、ノード装置３０ａは、データストリーム出力装置４０ａから入力されるデータストリームを、クエリ要求「ａ」に基づく処理結果として取得する。
【００７９】
そして、ノード装置３０ａは、取得した処理結果と、上記受け付けたクエリ要求「ＱＦ（ａ）」と、に基づいて、クエリ要求「ＱＦ（ａ）」に含まれる処理特定情報により特定される処理を逐次行う。そして、ノード装置３０ａは、その処理結果をクライアント装置２０へ逐次送信（出力）する。
【００８０】
なお、ノード装置３０ａは、受け付けたクエリ要求に含まれる情報種特定情報が、ノード装置３０ａに入力されるデータストリームの情報種を特定するための情報種特定情報と一致している場合、ノード特定情報送信要求、及び、クエリ要求送信要求を管理装置１０へ送信することなく、受け付けたクエリ要求「ＱＦ（ａ）」に基づく処理を逐次行い、その処理結果をクライアント装置２０へ逐次出力するように構成されていてもよい。
【００８１】
クライアント装置２０は、ノード装置３０ａから処理結果を受信し、受信した処理結果を出力装置を介して出力する。
【００８２】
また、ノード装置３０ａは、受け付けたクエリ要求「ＱＦ（ａ）」と、自装置（ノード装置３０ａ）を特定するためのノード特定情報「１」と、を含む構成情報登録要求を管理装置１０へ送信する。これにより、管理装置１０は、情報種特定情報「ｆ」を生成する。そして、管理装置１０は、生成した情報種特定情報「ｆ」と、構成情報登録要求に含まれるノード特定情報「１」と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報「ｆ」と、構成情報登録要求に含まれるクエリ要求「ＱＦ（ａ）」と、からなる組を知識テーブルに追加する。
【００８３】
この時点では、クライアント装置２０は、情報種特定情報ａ〜ｆを含む知識テーブルを出力装置を介して出力する。これにより、ユーザは、情報種特定情報ａ〜ｆを用いたクエリ要求をクライアント装置２０に入力することができる。
【００８４】
その後、ユーザが、クエリ要求「ＱＧ（ｃ）」、クエリ要求「ＱＨ（ｃ）」、及び、クエリ要求「ＱＩ（ｄ，ｅ）」、をこの順に入力した場合を想定して説明を続ける。
【００８５】
この場合、データストリーム処理システム１は、上述した場合と同様に作動する。その結果、構成情報記憶部１１に記憶されている構成テーブルは、図５に示したようになる。また、構成情報記憶部１１に記憶されている知識テーブルは、図６に示したようになる。
【００８６】
この時点では、クライアント装置２０は、情報種特定情報ａ〜ｉを含む知識テーブルを出力装置を介して出力する。これにより、ユーザは、情報種特定情報ａ〜ｉを用いたクエリ要求をクライアント装置２０に入力することができる。
【００８７】
次に、この時点にて、ユーザが、クエリ要求「ＱＪ（ｂ，ｇ）」を入力した場合を想定して説明を続ける。
この場合、クライアント装置２０は、ユーザにより入力されたクエリ要求「ＱＪ（ｂ，ｇ）」を受け付ける。
【００８８】
クライアント装置２０は、受け付けたクエリ要求「ＱＪ（ｂ，ｇ）」に含まれる、情報種特定情報「ｂ」、及び、情報種特定情報「ｇ」、を取得する。
【００８９】
クライアント装置２０は、取得した情報種特定情報の１つを選択し、選択した情報種特定情報（ここでは、「ｂ」）を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、クライアント装置２０は、管理装置１０からノード特定情報「２」を受信する。そして、クライアント装置２０は、受信したノード特定情報「２」により特定されるノード装置３０ｂへ、上記受け付けたクエリ要求「ＱＪ（ｂ，ｇ）」を送信する。
【００９０】
ノード装置３０ｂは、クライアント装置２０からクエリ要求「ＱＪ（ｂ，ｇ）」を受信する（受け付ける）。次いで、ノード装置３０ｂは、受け付けたクエリ要求「ＱＪ（ｂ，ｇ）」に含まれる、情報種特定情報「ｂ」、及び、情報種特定情報「ｇ」、を取得する。
【００９１】
先ず、ノード装置３０ｂは、取得した情報種特定情報「ｂ」を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、ノード装置３０ｂは、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報「２」を受信する。
【００９２】
ノード装置３０ｂが受信したノード特定情報「２」により特定されるノード装置＃２は、自装置（ノード装置３０ｂ）である。従って、ノード装置３０ｂは、情報種特定情報「ｂ」を含むクエリ要求送信要求を管理装置１０へ送信する。これにより、ノード装置３０ｂは、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求「ｂ」を受信する。
【００９３】
次いで、ノード装置３０ｂは、受信したクエリ要求「ｂ」に含まれる情報種特定情報「ｂ」により特定される情報種ｂのデータストリーム（ここでは、データストリーム出力装置４０ｂから入力されるデータストリーム）に対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。
【００９４】
ここでは、クエリ要求「ｂ」に含まれる処理特定情報は、情報種ｂのデータストリームに対して処理を行うことなく当該データストリームを処理結果として出力させる処理を特定するための情報である。従って、ノード装置３０ｂは、データストリーム出力装置４０ｂから入力されるデータストリームを、クエリ要求「ｂ」に基づく処理結果として取得する。
【００９５】
更に、ノード装置３０ｂは、取得した情報種特定情報「ｇ」を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、ノード装置３０ｂは、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報「３」を受信する。
【００９６】
ノード装置３０ｂが受信したノード特定情報「３」により特定されるノード装置＃３は、自装置（ノード装置３０ｂ）でない。従って、ノード装置３０ｂは、情報種特定情報「ｇ」を含むクエリ要求送信要求を管理装置１０へ送信する。これにより、ノード装置３０ｂは、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求「ＱＧ（ｃ）」を受信する。
【００９７】
次いで、ノード装置３０ｂは、受信したクエリ要求「ＱＧ（ｃ）」を、受信したノード特定情報「３」により特定されるノード装置３０ｃへ送信（出力）する。
【００９８】
これにより、ノード装置３０ｃは、クエリ要求「ＱＧ（ｃ）」を受け付ける。そして、上述した場合と同様に、ノード装置３０ｃは、クエリ要求「ＱＧ（ｃ）」に基づく処理を行い、その処理結果をノード装置３０ｂへ送信（出力）する。
【００９９】
これにより、ノード装置３０ｂは、クエリ要求「ＱＧ（ｃ）」に応じてノード装置３０ｃにより送信された処理結果を受信（取得）する。
【０１００】
そして、ノード装置３０ｂは、クエリ要求「ｂ」に基づく処理結果として取得した情報種ｂのデータと、クエリ要求「ＱＧ（ｃ）」に基づく処理結果としてノード装置３０ｃから受信した情報種ｇのデータと、クライアント装置２０から受け付けたクエリ要求「ＱＪ（ｂ，ｇ）」と、に基づいて、クエリ要求「ＱＪ（ｂ，ｇ）」に含まれる処理特定情報により特定される処理を逐次行う。そして、ノード装置３０ｂは、その処理結果をクライアント装置２０へ逐次送信（出力）する。
【０１０１】
クライアント装置２０は、ノード装置３０ｂから処理結果を受信し、受信した処理結果を出力装置を介して出力する。
【０１０２】
また、ノード装置３０ｂは、受け付けたクエリ要求「ＱＪ（ｂ，ｇ）」と、自装置（ノード装置３０ｂ）を特定するためのノード特定情報「２」と、を含む構成情報登録要求を管理装置１０へ送信する。これにより、管理装置１０は、情報種特定情報「ｊ」を生成する。そして、管理装置１０は、生成した情報種特定情報「ｊ」と、構成情報登録要求に含まれるノード特定情報「２」と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報「ｊ」と、構成情報登録要求に含まれるクエリ要求「ＱＪ（ｂ，ｇ）」と、からなる組を知識テーブルに追加する。
【０１０３】
その結果、構成情報記憶部１１に記憶されている構成テーブルは、図７に示したようになる。また、構成情報記憶部１１に記憶されている知識テーブルは、図８に示したようになる。
【０１０４】
この時点では、クライアント装置２０は、情報種特定情報ａ〜ｊを含む知識テーブルを出力装置を介して出力する。これにより、ユーザは、情報種特定情報ａ〜ｊを用いたクエリ要求をクライアント装置２０に入力することができる。
【０１０５】
次に、この時点にて、ユーザが、クエリ要求「ＱＫ（ｆ，ｊ）」を入力した場合を想定して説明を続ける。
この場合、クライアント装置２０は、ユーザにより入力されたクエリ要求「ＱＫ（ｆ，ｊ）」を受け付ける。
【０１０６】
クライアント装置２０は、受け付けたクエリ要求「ＱＫ（ｆ，ｊ）」に含まれる、情報種特定情報「ｆ」、及び、情報種特定情報「ｊ」、を取得する。
【０１０７】
クライアント装置２０は、取得した情報種特定情報の１つを選択し、選択した情報種特定情報（ここでは、「ｆ」）を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、クライアント装置２０は、管理装置１０からノード特定情報「１」を受信する。そして、クライアント装置２０は、受信したノード特定情報「１」により特定されるノード装置３０ａへ、上記受け付けたクエリ要求「ＱＫ（ｆ，ｊ）」を送信する。
【０１０８】
ノード装置３０ａは、クライアント装置２０からクエリ要求「ＱＫ（ｆ，ｊ）」を受信する（受け付ける）。次いで、ノード装置３０ａは、受け付けたクエリ要求「ＱＫ（ｆ，ｊ）」に含まれる、情報種特定情報「ｆ」、及び、情報種特定情報「ｊ」、を取得する。
【０１０９】
先ず、ノード装置３０ａは、取得した情報種特定情報「ｆ」を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、ノード装置３０ａは、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報「１」を受信する。
【０１１０】
ノード装置３０ａが受信したノード特定情報「１」により特定されるノード装置＃１は、自装置（ノード装置３０ａ）である。従って、ノード装置３０ａは、情報種特定情報「ｆ」を含むクエリ要求送信要求を管理装置１０へ送信する。これにより、ノード装置３０ａは、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求「ＱＦ（ａ）」を受信する。
【０１１１】
次いで、ノード装置３０ａは、受信したクエリ要求「ＱＦ（ａ）」に含まれる情報種特定情報「ａ」により特定される情報種ａのデータストリーム（ここでは、データストリーム出力装置４０ａから入力されるデータストリーム）に対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行う。そして、ノード装置３０ａは、その処理結果を情報種ｆのデータとして取得する。
【０１１２】
更に、ノード装置３０ａは、取得した情報種特定情報「ｊ」を含むノード特定情報送信要求を管理装置１０へ送信する。これにより、ノード装置３０ａは、ノード特定情報送信要求に応じて管理装置１０により送信されたノード特定情報「２」を受信する。
【０１１３】
ノード装置３０ａが受信したノード特定情報「２」により特定されるノード装置＃２は、自装置（ノード装置３０ａ）でない。従って、ノード装置３０ａは、情報種特定情報「ｊ」を含むクエリ要求送信要求を管理装置１０へ送信する。これにより、ノード装置３０ａは、クエリ要求送信要求に応じて管理装置１０により送信されたクエリ要求「ＱＪ（ｂ，ｇ）」を受信する。
【０１１４】
次いで、ノード装置３０ａは、受信したクエリ要求「ＱＪ（ｂ，ｇ）」を、受信したノード特定情報「２」により特定されるノード装置３０ｂへ送信（出力）する。
【０１１５】
これにより、ノード装置３０ｂは、クエリ要求「ＱＪ（ｂ，ｇ）」を受け付ける。そして、上述した場合と同様に、ノード装置３０ｂは、クエリ要求「ＱＪ（ｂ，ｇ）」に基づく処理を行い、その処理結果をノード装置３０ａへ送信（出力）する。
【０１１６】
これにより、ノード装置３０ａは、クエリ要求「ＱＪ（ｂ，ｇ）」に応じてノード装置３０ｂにより送信された処理結果を，情報種ｊのデータとして受信（取得）する。
【０１１７】
そして、ノード装置３０ａは、クエリ要求「ＱＦ（ａ）」に基づく処理結果として取得した情報種ｆのデータと、クエリ要求「ＱＪ（ｂ，ｇ）」に基づく処理結果としてノード装置３０ｂから受信した情報種ｊのデータと、クライアント装置２０から受け付けたクエリ要求「ＱＫ（ｆ，ｊ）」と、に基づいて、クエリ要求「ＱＫ（ｆ，ｊ）」に含まれる処理特定情報により特定される処理を逐次行う。そして、ノード装置３０ａは、その処理結果をクライアント装置２０へ逐次送信（出力）する。
【０１１８】
クライアント装置２０は、ノード装置３０ａから処理結果を受信し、受信した処理結果を出力装置を介して出力する。
【０１１９】
また、ノード装置３０ａは、受け付けたクエリ要求「ＱＫ（ｆ，ｊ）」と、自装置（ノード装置３０ａ）を特定するためのノード特定情報「１」と、を含む構成情報登録要求を管理装置１０へ送信する。これにより、管理装置１０は、情報種特定情報「ｋ」を生成する。そして、管理装置１０は、生成した情報種特定情報「ｋ」と、構成情報登録要求に含まれるノード特定情報「１」と、からなる組を構成テーブルに追加する。更に、管理装置１０は、生成した情報種特定情報「ｋ」と、構成情報登録要求に含まれるクエリ要求「ＱＫ（ｆ，ｊ）」と、からなる組を知識テーブルに追加する。
【０１２０】
以上、説明したように、本発明の第１実施形態に係るデータストリーム処理システムによれば、クライアント装置２０は、クエリ要求に基づく処理結果を出力可能なノード装置３０ａ〜３０ｄへ、当該クエリ要求を出力する。即ち、ユーザがクライアント装置２０にノード特定情報を入力しなくても、クライアント装置２０は、適切なノード装置３０ａ〜３０ｄへクエリ要求を出力することができる。
【０１２１】
更に、ノード装置３０ａ〜３０ｄは、受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種のデータを、当該情報種特定情報と対応付けて記憶されているクエリ要求に基づいて取得することができる。即ち、ユーザは、情報種特定情報を用いることにより簡略化したクエリ要求をクライアント装置２０に入力することができる。
【０１２２】
このように、上記データストリーム処理システム１によれば、ユーザにクエリ要求を容易に入力させることができる。
【０１２３】
更に、第１実施形態に係るデータストリーム処理システム１は、クライアント装置２０がノード装置３０ａ〜３０ｄへクエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置３０ａ〜３０ｄを特定するためのノード特定情報と、を対応付けて構成情報記憶部１１に記憶させる。
【０１２４】
これによれば、ユーザがクライアント装置２０にクエリ要求を入力する際に用いることができる情報種特定情報を、ユーザが別途入力することなく、自動的に増やすことができる。この結果、ユーザの利便性をより一層向上させることができる。
【０１２５】
なお、第１実施形態に係るデータストリーム処理システム１においては、各ノード装置３０ａ〜３０ｄが構成情報登録要求を管理装置１０へ送信することにより、クエリ要求と、情報種特定情報と、ノード特定情報と、を対応付けて構成情報記憶部１１に記憶させるように構成されていた。
【０１２６】
ところで、第１実施形態の変形例に係るデータストリーム処理システム１においては、クライアント装置２０が構成情報登録要求を管理装置１０へ送信することにより、クエリ要求と、情報種特定情報と、ノード特定情報と、を対応付けて構成情報記憶部１１に記憶させるように構成されていてもよい。この場合、クライアント装置２０は、クエリ要求をノード装置３０ａ〜３０ｄへ送信（出力）した場合に、当該クエリ要求と、当該ノード装置３０ａ〜３０ｄを特定するためのノード特定情報と、を含む構成情報登録要求を管理装置１０へ送信するように構成されることが好適である。
【０１２７】
＜第２実施形態＞
次に、本発明の第２実施形態に係るデータストリーム処理システムについて図９を参照しながら説明する。
第２実施形態に係るデータストリーム処理システム１００は、クライアント装置１１０と、複数のノード装置１２０ａ，…と、を含むシステムである。
【０１２８】
更に、このデータストリーム処理システム１００は、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する構成情報記憶部（構成情報記憶手段）１３１を備える。
【０１２９】
加えて、クライアント装置１１０は、
上記情報種特定情報及び上記処理特定情報を含むクエリ要求を受け付け、当該受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力部（クエリ要求出力手段）１１１を備える。
【０１３０】
更に、ノード装置１２０ａ，…は、
クライアント装置１１０、又は、他のノード装置から、上記クエリ要求を受け付けるクエリ要求受付部（クエリ要求受付手段）１２１と、
上記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の上記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力部（処理結果出力手段）１２２と、
を備える。
【０１３１】
これによれば、クライアント装置１１０は、クエリ要求に基づく処理結果を出力可能なノード装置１２０ａ，…へ、当該クエリ要求を出力する。即ち、ユーザがクライアント装置１１０にノード特定情報を入力しなくても、クライアント装置１１０は、適切なノード装置１２０ａ，…へクエリ要求を出力することができる。
【０１３２】
更に、ノード装置１２０ａ，…は、受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種のデータを、当該情報種特定情報と対応付けて記憶されているクエリ要求に基づいて取得することができる。即ち、ユーザは、情報種特定情報を用いることにより簡略化したクエリ要求をクライアント装置１１０に入力することができる。
【０１３３】
このように、上記データストリーム処理システム１００によれば、ユーザにクエリ要求を容易に入力させることができる。
【０１３４】
以上、上記実施形態を参照して本願発明を説明したが、本願発明は、上述した実施形態に限定されるものではない。本願発明の構成及び詳細に、本願発明の範囲内において当業者が理解し得る様々な変更をすることができる。
【０１３５】
なお、上記各実施形態においてデータストリーム処理システム１の各機能は、ＣＰＵがプログラム（ソフトウェア）を実行することにより実現されていたが、回路等のハードウェアにより実現されていてもよい。
【０１３６】
また、上記各実施形態においてプログラムは、記憶装置に記憶されていたが、コンピュータが読み取り可能な記録媒体に記憶されていてもよい。例えば、記録媒体は、フレキシブルディスク、光ディスク、光磁気ディスク、及び、半導体メモリ等の可搬性を有する媒体である。
【０１３７】
また、上記実施形態の他の変形例として、上述した実施形態及び変形例の任意の組み合わせが採用されてもよい。
【０１３８】
＜付記＞
上記実施形態の一部又は全部は、以下の付記のように記載され得るが、以下には限られない。
【０１３９】
（付記１）
クライアント装置と、複数のノード装置と、を含むデータストリーム処理システムであって、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する構成情報記憶手段を備え、
前記クライアント装置は、
前記情報種特定情報及び前記処理特定情報を含むクエリ要求を受け付け、当該受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を備え、
前記ノード装置は、
前記クライアント装置、又は、他のノード装置から、前記クエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備えるデータストリーム処理システム。
【０１４０】
これによれば、クライアント装置は、クエリ要求に基づく処理結果を出力可能なノード装置へ、当該クエリ要求を出力する。即ち、ユーザがクライアント装置にノード特定情報を入力しなくても、クライアント装置は、適切なノード装置へクエリ要求を出力することができる。
【０１４１】
更に、ノード装置は、受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種のデータを、当該情報種特定情報と対応付けて記憶されているクエリ要求に基づいて取得することができる。即ち、ユーザは、情報種特定情報を用いることにより簡略化したクエリ要求をクライアント装置に入力することができる。
【０１４２】
このように、上記データストリーム処理システムによれば、ユーザにクエリ要求を容易に入力させることができる。
【０１４３】
（付記２）
付記１に記載のデータストリーム処理システムであって、
前記処理結果出力手段は、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成されたデータストリーム処理システム。
【０１４４】
（付記３）
付記１又は付記２に記載のデータストリーム処理システムであって
前記クライアント装置が前記ノード装置へ前記クエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置を特定するためのノード特定情報と、を対応付けて前記構成情報記憶手段に記憶させる構成情報記憶処理手段を備えるデータストリーム処理システム。
【０１４５】
これによれば、ユーザがクライアント装置にクエリ要求を入力する際に用いることができる情報種特定情報を、ユーザが別途入力することなく、自動的に増やすことができる。この結果、ユーザの利便性をより一層向上させることができる。
【０１４６】
（付記４）
付記１乃至付記３のいずれか一項に記載のデータストリーム処理システムであって、
前記クエリ要求受付手段は、複数の前記情報種特定情報と、当該複数の情報種特定情報のそれぞれにより特定される情報種の前記データストリームに対して行う処理を特定するための前記処理特定情報と、を含む前記クエリ要求を受け付けるように構成され、
前記ノード装置は、
前記受け付けたクエリ要求に含まれる前記複数の情報種特定情報のそれぞれに対して、当該情報種特定情報と対応付けて記憶されているノード特定情報を取得するとともに、当該取得したノード特定情報により特定されるノード装置が自装置でない場合に当該情報種特定情報と対応付けて記憶されているクエリ要求を取得し当該取得したクエリ要求を当該ノード装置へ出力するクエリ要求出力手段を備えるデータストリーム処理システム。
【０１４７】
これによれば、ノード装置は、自装置が取得できないデータの情報種を特定するための情報種特定情報を含むクエリ要求を受け付けた場合に、当該データを取得するためのクエリ要求を、当該データを出力可能なノード装置へ出力する。これにより、データストリーム処理システムは、複数のノード装置のそれぞれから出力される処理結果に基づく情報を適切に取得することができる。
【０１４８】
（付記５）
付記１乃至付記４のいずれか一項に記載のデータストリーム処理システムであって、
前記クライアント装置は、前記記憶されている情報種特定情報をユーザに通知する情報種特定情報通知手段を備えるデータストリーム処理システム。
【０１４９】
これによれば、ユーザは、通知された情報種特定情報を用いてクエリ要求を入力することができる。この結果、ユーザの利便性をより一層向上させることができる。
【０１５０】
（付記６）
クライアント装置と、複数のノード装置と、を含むデータストリーム処理システムに適用され、
前記クライアント装置が、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付け、
前記クライアント装置が、前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力し、
前記ノード装置が、前記クライアント装置、又は、他のノード装置から、前記クエリ要求を受け付け、
前記ノード装置が、前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する、データストリーム処理方法。
【０１５１】
（付記７）
付記６に記載のデータストリーム処理方法であって、
前記ノード装置が、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得する、データストリーム処理方法。
【０１５２】
（付記８）
付記６又は付記７に記載のデータストリーム処理方法であって、
前記クライアント装置が前記ノード装置へ前記クエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置を特定するためのノード特定情報と、を対応付けて前記記憶装置に記憶させる、データストリーム処理方法。
【０１５３】
（付記９）
クライアント装置であって、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるとともに、前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を備えるクライアント装置。
【０１５４】
（付記１０）
付記９に記載のクライアント装置であって、
前記ノード装置へ前記クエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置を特定するためのノード特定情報と、を対応付けて前記記憶装置に記憶させる構成情報記憶処理手段を備えるクライアント装置。
【０１５５】
（付記１１）
クライアント装置に、
情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるとともに、前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているノード特定情報により特定されるノード装置へ、当該受け付けたクエリ要求を出力するクエリ要求出力手段を実現させるためのプログラム。
【０１５６】
（付記１２）
付記１１に記載のプログラムであって、
前記クライアント装置に、更に、
前記ノード装置へ前記クエリ要求を出力した場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該ノード装置を特定するためのノード特定情報と、を対応付けて前記記憶装置に記憶させる構成情報記憶処理手段を実現させるためのプログラム。
【０１５７】
（付記１３）
ノード装置であって、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を備え、
前記処理結果出力手段は、
前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成されたノード装置。
【０１５８】
（付記１４）
付記１３に記載のノード装置であって、
前記クライアント装置から前記クエリ要求を受け付けた場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、自装置を特定するためのノード特定情報と、を対応付けて前記記憶装置に記憶させる構成情報記憶処理手段を備えるノード装置。
【０１５９】
（付記１５）
ノード装置に、
クライアント装置、又は、他のノード装置から、情報の種類である情報種を特定するための情報種特定情報と、当該情報種のデータであり且つ時間の経過に伴って逐次生成されるデータである、データストリームに対して行う処理を特定するための処理特定情報と、を含むクエリ要求を受け付けるクエリ要求受付手段と、
前記受け付けたクエリ要求に含まれる情報種特定情報により特定される情報種の前記データストリームに対して、当該クエリ要求に含まれる処理特定情報により特定される処理を逐次行い、その処理結果を、当該クエリ要求を出力した装置へ逐次出力する処理結果出力手段と、
を実現させるととともに、
前記処理結果出力手段は、
前記クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、当該クエリ要求に基づく処理結果を出力可能なノード装置を特定するためのノード特定情報と、を対応付けて記憶する記憶装置に、前記受け付けたクエリ要求に含まれる情報種特定情報と対応付けて記憶されているクエリ要求に基づいて、当該情報種特定情報により特定される情報種のデータを取得するように構成されたプログラム。
【０１６０】
（付記１６）
付記１５に記載のプログラムであって、
前記ノード装置に、更に、
前記クライアント装置から前記クエリ要求を受け付けた場合、当該クエリ要求と、当該クエリ要求に基づく処理結果の情報種を特定するための情報種特定情報と、自装置を特定するためのノード特定情報と、を対応付けて前記記憶装置に記憶させる構成情報記憶処理手段を実現させるためのプログラム。
【産業上の利用可能性】
【０１６１】
本発明は、時間の経過に伴って逐次生成されるデータであるデータストリームを処理するデータストリーム処理システム等に適用可能である。
【符号の説明】
【０１６２】
１      データストリーム処理システム
１０    管理装置
１１    構成情報記憶部
２０    クライアント装置
２１    情報種特定情報通知部
２２    クエリ要求出力部
３０ａ，３０ｂ，３０ｃ，３０ｄ  ノード装置
３１    クエリ要求受付部
３２    処理結果出力部
３３    構成情報記憶処理部
３４    クエリ要求出力部
４０ａ，４０ｂ，４０ｃ，４０ｄ，４０ｅ  データストリーム出力装置
１００  データストリーム処理システム
１１０  クライアント装置
１１１  クエリ要求出力部
１２０ａ，…  ノード装置
１２１  クエリ要求受付部
１２２  処理結果出力部
１３１  構成情報記憶部
ＮＷ    通信回線
【図１】
0005488039.tif 000002
【図２】
0005488039.tif 000003
【図３】
0005488039.tif 000004
【図４】
0005488039.tif 000005
【図５】
0005488039.tif 000006
【図６】
0005488039.tif 000007
【図７】
0005488039.tif 000008
【図８】
0005488039.tif 000009
【図９】
0005488039.tif 000010