CEP engine and method for processing CEP queries

• US 20120166469A1
• Filed: 01/31/2011
• Published: 06/28/2012
• Est. Priority Date: 12/22/2010
• Status: Active Application

• Current Assignee: Software AG
• Original Assignee: Software AG
• Inventors: Cammert, Michael, Heinz, Christoph, Krämer, Jürgen, Riemenschneider, Tobias
• Granted Patent: US 10,255,238 B2
• Time in Patent Office: Days
• US Class Current: 707/769
• CPC Class Codes: G06F 16/2453 Query optimisation
• CPC Class Codes: G06F 16/24542 Plan optimisation
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

The present invention concerns a complex event processing (CEP) engine (1) for processing CEP queries (10) over data streams, wherein the CEP engine (1) comprises:

• a. a parser (100), adapted for parsing a received CEP query (10) into a logical query graph (20); and
• b. a translator (300), adapted for translating the logical query graph (20) into a physical query plan (30) in accordance with one of a plurality of data stream representations; wherein
• c. the logical query graph (20) is independent of the plurality of data stream representations.

Claims

1. A complex event processing (CEP) engine for processing CEP queries over data streams, wherein the CEP engine comprises:

a. a parser configured to parse a received CEP query into a logical query graph; and

b. a translator configured to translate the logical query graph into a physical query plan in accordance with one of a plurality of data stream representations;

wherein

c. the logical query graph is independent of the plurality of data stream representations.

2. The CEP engine of claim 1, further comprising an optimizer configured to optimize the logical query graph to produce an optimized logical query graph, wherein the optimized logical query graph is independent of the plurality of data stream representations.

3. The CEP engine of claim 1, wherein the physical query plan comprises at least one query building block that is independent of the plurality of data stream representations.

4. The CEP engine of claim 2, wherein the optimizer configured to select one of the plurality of data stream representations and wherein the translator configured to translate the logical query graph into a physical query plan in accordance with the selected data stream representation.

5. The CEP engine of claim 4, further configured to change the selected data stream representation during processing of the CEP query.

6. The CEP engine of claim 1, further comprising at least one operator translator configured to translate data elements of at least one data stream to be processed by the CEP query from a first data stream representation to a second data stream representation.

12. The method of claim 1, further comprising translating, by at least one operator, data elements of at least one data stream to be processed by the CEP query from a first data stream representation to a second data stream representation.

7. A method for processing CEP queries over data streams, the method comprising:

a. parsing a received CEP query into a logical query graph; and

b. translating the logical query graph into a physical query plan in accordance with one of a plurality of data stream representations;

wherein

c. the logical query graph is independent of the plurality of data stream representations.

8. The method of claim 7, further comprising optimizing the logical query graph to produce an optimized logical query graph, wherein the optimized logical query graph is independent of the plurality of data stream representations.

9. The method of claim 7, wherein the physical query plan comprises at least one query building block that is independent of the plurality of data stream representations.

10. The method of claim 8, wherein the optimizing comprises selecting one of the plurality of data stream representations and wherein the translating comprises translating the logical query graph into a physical query plan in accordance with the selected data stream representation.

11. The method of claim 10, further comprising changing the selected data stream representation during processing of the CEP query.

13. A non-transitory computer readable storage medium tangibly storing a computer program comprising instructions that, when executed, implement a method according to claim 7.