Method for the interoperation of virtual organizations

摘要

A cooperative data stream processing system is provided that utilizes a plurality of independent, autonomous and possibly heterogeneous sites in a cooperative arrangement to process user-defined job requests over dynamic, continuous streams of data. A method is provided to organize the distributed sites into a plurality of virtual organizations that can be further combined and virtualized into virtualized virtual organizations. These virtualized virtual organizations can also include additional distributed sites and existing virtualized virtual organizations and all members of a given virtualized virtual organization can share data and processing resources in order to process jobs on either a task-based or goal-based allocation mechanism. The virtualized virtual organization is created dynamically using ad-hoc collaborations among the members and is arranged in either a federated or cooperative architecture. Collaborations between members is either tightly-coupled or loosely coupled. Flexible management of resources is provided with resources being provided under exclusive control or based on best-effort access.

主权项

1. A method for creating an interoperation of virtual organizations in a cooperative data stream processing system, the method comprising:
identifying a plurality of distributed sites, each site comprising computing system components capable of independently processing continuous dynamic streams of data; identifying a plurality of virtual organizations, each virtual organization comprising a combination of sites selected from the identified plurality of distributed sites and configured to share at least one of data and processing resources within the combination of sites; creating a first interoperation of virtual organizations comprising a first group of virtual organizations selected from the identified plurality of virtual organizations and at least one existing interoperation of virtual organizations, wherein each virtual organization within the first interoperation of virtual organizations is configured to share at least one of data and resources with other members of the first group of virtual organizations; identifying lead virtual organizations within each existing interoperation of virtual organizations; using the identified lead virtual organizations to participate in the first interoperation of virtual organizations; communicating requests for shared data and resources from a first interoperation of virtual organizations lead site to the identified lead virtual organizations in the existing interoperations of lead sites; using the identified lead virtual organizations to negotiate creating a new interoperation of virtual organizations with the requested shared data and resources from member sites in the existing interoperations of lead sites; using the first interoperation of virtual organizations to process user-defined inquiries over continuous dynamic streams of data in the cooperative data stream processing system; delivering results of the inquiries to users that defined the inquiries and wherein each existing interoperation of virtual organizations comprises a federated architecture; and shares at least one of data and resources with the first interoperation of virtual organizations and comprises at least one of member virtual organizations and member sites.