SYSTEMS AND/OR METHODS FOR CAPABILITY-AWARE DYNAMIC DISTRIBUTED EVENT PROCESSING
First Claim
1. A system for distributed event processing, comprising:
- a plurality of processing resources and a capability repository, wherein;
a first processing resource from the plurality of processing resources is configured to;
receive a plurality of event streams from a plurality of operating contexts;
identify, based upon the received event streams, a dynamically changing condition in a first one of said operating contexts;
automatically decompose, based upon information stored in the capability repository, a complex event processing (CEP) query to effect a change responsive to the identified dynamically changing condition in the first one of said operating contexts;
based upon the decomposed query, cause the first one of said operating contexts to effect the change; and
effect a related change to operation of the first processing resource, the related change corresponding to the change caused to the first one of said operating contexts, andthe capability repository is configured to store information regarding (a) a plurality of event sources that each transmit events to at least one of said processing resources, and (b) the plurality of operating contexts, each operating context being associated with a respective group of event sources and being associated with at least one of said plurality of processing resources.
1 Assignment
0 Petitions
Accused Products
Abstract
In a system including processing resources and a capability repository, a first processing resource: receives event streams from operating contexts; identifies, based upon the received event streams, a dynamically changing condition in a first one of the operating contexts; automatically decomposes, using the repository, a complex event processing query to effect a change responsive to the identified dynamically changing condition in the first one of the operating contexts; causes the first one of the operating contexts to effect the change based upon the decomposed query; and effects a related change to operation of the first processing resource that corresponds to the change caused to the first one of the operating contexts. The repository stores information regarding event sources that transmit events to the processing resources, and the operating contexts. Each operating context is associated with a respective group of event sources and with at least one of the processing resources.
-
Citations
20 Claims
-
1. A system for distributed event processing, comprising:
-
a plurality of processing resources and a capability repository, wherein; a first processing resource from the plurality of processing resources is configured to; receive a plurality of event streams from a plurality of operating contexts; identify, based upon the received event streams, a dynamically changing condition in a first one of said operating contexts; automatically decompose, based upon information stored in the capability repository, a complex event processing (CEP) query to effect a change responsive to the identified dynamically changing condition in the first one of said operating contexts; based upon the decomposed query, cause the first one of said operating contexts to effect the change; and effect a related change to operation of the first processing resource, the related change corresponding to the change caused to the first one of said operating contexts, and the capability repository is configured to store information regarding (a) a plurality of event sources that each transmit events to at least one of said processing resources, and (b) the plurality of operating contexts, each operating context being associated with a respective group of event sources and being associated with at least one of said plurality of processing resources. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A method for distributed event processing, the method comprising:
-
receiving, at a first processing resource of a plurality of processing resources, event streams from a plurality of operating contexts, wherein a capability repository stores information regarding (a) a plurality of event sources that each transmit events to at least one of the processing resources, and (b) the plurality of operating contexts, each operating context being associated with a respective group of event sources and being associated with at least one of said plurality of processing resources; identifying, based upon the received event streams, a dynamically changing condition in a first one of said operating contexts; automatically decomposing, based upon the stored information, a complex event processing (CEP) query to effect a change responsive to the identified dynamically changing condition in the first one of said operating contexts; and based upon the decomposed query, causing the first one of said operating contexts to effect the change, wherein the automatic decomposing comprises forming a first sub-query configured to effect the change, and wherein said causing the change includes deploying the first sub-query to a second processing resource associated with the first one of said operating contexts. - View Dependent Claims (12, 13, 14, 15, 16)
-
-
17. A non-transitory computer readable storage medium having instructions stored thereon that, when executed by a first processing resource of a plurality of processing resources, cause the first processing resource to perform operations comprising:
-
receiving event streams from a plurality of operating contexts, wherein a capability repository stores information regarding (a) a plurality of event sources that each transmit events to at least one of the processing resources, and (b) the plurality of operating contexts, each operating context being associated with a respective group of event sources and being associated with at least one of said plurality of processing resources; identifying, based upon the received event streams, a dynamically changing condition in a first one of said operating contexts; automatically decomposing, based upon the stored information, a complex event processing (CEP) query to effect a change responsive to the identified dynamically changing condition in the first one of said operating contexts; and based upon the decomposed query, causing the first one of said operating contexts to effect the change. - View Dependent Claims (18, 19, 20)
-
Specification