SYSTEMS AND/OR METHODS FOR CAPABILITY-AWARE DYNAMIC DISTRIBUTED EVENT PROCESSING

• US 20150356153A1
• Filed: 06/06/2014
• Published: 12/10/2015
• Est. Priority Date: 06/06/2014
• Status: Active Grant

• Current Assignee: Software AG
• Original Assignee: Software AG
• Inventors: SCHOENING, Harald
• Granted Patent: US 9,633,087 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2453 Query optimisation
• CPC Class Codes: G06F 16/2455 Query execution
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/2471 Distributed queries
• CPC Class Codes: G06F 16/285 Clustering or classification

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.

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.

2. The system according to claim 1, 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.

3. The system according to claim 2, wherein the forming the first sub-query comprises:

determining an operator graph for the query;

computing the determined operator graph in accordance with at least one predetermined execution condition; and

determining the first sub-query based upon a sub-graph in the optimized operator graph.

4. The system according to claim 3, wherein the predetermined execution condition includes (a) executability of the query using processing resources available at respective ones of said operating contexts, and (b) executability of the query in view of bandwidth availability between the first processing resource and respective operating contexts.

5. The system according to claim 2, wherein the deploying the first sub-query to a second processing resource associated with the first one of the processing contexts comprises:

comparing the first sub-query to a sub-query previously deployed to the first one of the operating contexts to determine a substantial similarity; and

performing said deploying of the first sub-query when the comparing does not determine the substantial similarity.

6. The system according to claim 1, wherein the plurality of event streams are received from respective ones of the operating contexts in accordance with the CEP query, and wherein a partial subset of the operating contexts is altered in response to the identified dynamically changing condition in the first one of said operating contexts.

7. The system according to claim 1, wherein the first processing resource is further configured to update the stored information in accordance with the identified dynamically changing condition, and wherein the automatic decomposing is based upon the stored information including the updated stored information.

8. The system according to claim 1, wherein the automatic decomposing is based upon the stored information including information regarding bandwidth capabilities and/or processor capabilities of the first one of the operating contexts.

9. The system according to claim 1, wherein the dynamically changing condition includes an alteration of an association between at least one event source and the first processing context.

10. The system according to claim 1, wherein the first processing resource is further configured to cause the first one of said operating contexts to (a) store locally-generated events without transmitting to the first processing resource when communication bandwidth is determined to be low between the first processing context and the first processing resource, and (b) transmit locally-generated events substantially in real-time when said communication bandwidth is not low between the first processing context and the first processing resource.

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.

12. The method according to claim 11, further comprising effecting 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.

13. The method according to claim 11, wherein the plurality of event streams are received from respective ones of the operating contexts in accordance with the CEP query, and wherein a partial subset of the operating contexts is altered in response to the identified dynamically changing condition in the first one of said operating contexts.

14. The method according to claim 11, wherein the first processing resource is further configured to update the stored information in accordance with the identified dynamically changing condition, and wherein the automatic decomposing is based upon the stored information including the updated stored information.

15. The method according to claim 11, wherein the automatic decomposing is based upon the stored information including information regarding bandwidth capabilities and/or processor capabilities of the first one of the operating contexts.

16. The method according to claim 11, wherein the dynamically changing condition includes an alteration of an association between at least one event source and the first one of the processing contexts.

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.

18. The non-transitory computer readable medium according to claim 17, 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.

19. The non-transitory computer readable medium according to claim 17, wherein the plurality of event streams are received from respective ones of the operating contexts in accordance with the CEP query, and wherein a partial subset of the operating contexts is altered in response to the identified dynamically changing condition in the first one of said operating contexts.

20. The non-transitory computer readable medium according to claim 17, wherein the first processing resource is further configured to update the stored information in accordance with the identified dynamically changing condition, and wherein the automatic decomposing is based upon the stored information including the updated stored information.