System and Method of Planning for Cooperative Information Processing
First Claim
1. A method for planning cooperative processing in a cooperative data stream processing system, the method comprising:
- identifying a plurality of distributed sites, each site comprising components capable of independently processing continuous dynamic streams of data;
communicating an identification of resources disposed on each site and available for sharing among the plurality of distributed sites to at least one planner disposed on one of the identified plurality of sites;
communicating an inquiry to be processed over the continuous dynamic streams of data to the planner; and
creating a distributed plan comprising the identified resources for processing the inquiry.
1 Assignment
0 Petitions
Accused Products
Abstract
A cooperative data stream processing system is provided that utilizes a plurality of independent, autonomous and possibly heterogeneous sites in a cooperative arrangement to execute jobs derived from user-define inquires over dynamic, continuous streams of data. A method is provided for cooperative planning for the execution of the jobs across the distributed plurality of sites. An identification of the resources available for sharing from each one of the plurality of sites is communicated to one or more planners disposed on the distributed sites. These planners use the resource information to generate planning domains in which the jobs can be processed. Upon receipt of an inquiry at one of the sites, the inquiry is communicated to one of the planners that uses the planning domain to create at least one distributed plan for the inquiry. Processing of the inquiry is conducted in accordance with the distributed plan. Planning can take advantage of the structure of virtual organizations including cooperative and federated virtual organizations. The distributed plans can make use of the resources within a single virtual organization or across multiple organizations.
-
Citations
20 Claims
-
1. A method for planning cooperative processing in a cooperative data stream processing system, the method comprising:
-
identifying a plurality of distributed sites, each site comprising components capable of independently processing continuous dynamic streams of data; communicating an identification of resources disposed on each site and available for sharing among the plurality of distributed sites to at least one planner disposed on one of the identified plurality of sites; communicating an inquiry to be processed over the continuous dynamic streams of data to the planner; and creating a distributed plan comprising the identified resources for processing the inquiry. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification