CEP engine and method for processing CEP queries
AssigneeSoftware AG
InventorsMichael Cammert, Christoph Heinz, Jürgen Krämer, Tobias Riemenschneider
Life of this patent
Estimating the term…
Abstract
The present technology concerns a complex event processing (CEP) engine for processing CEP queries over data streams. The CEP engine has a parser, adapted for parsing a received CEP query into a logical query graph and a translator adapted for translating the logical query graph into a physical query plan in accordance with one of a plurality of data stream representations. The logical query graph is independent of the plurality of data stream representations.
Claims21
A system comprising at least one processor and a complex event processing (CEP) engine for processing CEP queries over data streams, the at least one processor controlling the system to:
- parse a received CEP query into a logical query graph that is independent of a plurality of data stream representation models;
- translate the logical query graph into a physical query plan in accordance with a selected data stream representation model from the plurality of data stream representation models, the data stream representation model selected based on preferences related to processing resources used by the CEP engine, the data stream representation model usable as a parameter in the translation process;
- and
- execute the translated physical query plan using the data stream representation model selected from the plurality of data stream representation models based on the logical query graph, wherein
- the plurality of data stream representation models comprise one or more approaches for executing the received CEP query, the one or more approaches corresponding to specific requirements for executing the received CEP query by the CEP engine.
A method implemented in an information processing apparatus having at least one processor and a complex event processing (CEP) engine for processing CEP queries over data streams, the method comprising:
- a. parsing, via the at least one processor, a received CEP query into a logical query graph that is independent of a plurality of data stream representation models;
- b. translating, via the at least one processor, the logical query graph into a physical query plan in accordance with a selected data stream representation model from the plurality of data stream representation models, the data stream representation model selected based on preferences related to processing resources used by the information processing apparatus, the data stream representation model usable as a parameter in the translation process;
- and
- c. executing, via the at least one processor, the translated physical query plan using the data stream representation model selected from the plurality of data stream representation models based on the logical query graph, wherein
- the plurality of data stream representation models comprise one or more approaches for executing the received CEP query, the one or more approaches corresponding to specific requirements for executing the received CEP query by the CEP engine.
A non-transitory computer readable storage medium tangibly storing a computer program comprising instructions for using a complex event processing (CEP) engine for processing CEP queries over data streams that, when executed, cause a computer to:
- parse a received CEP query into a logical query graph that is independent of a plurality of data stream representation models;
- translate the logical query graph into a physical query plan in accordance with a selected data stream representation model from the plurality of data stream representation models, the data stream representation model selected based on preferences related to utilized processing resources, the data stream representation model usable as a parameter in the translation process;
- and
- execute the translated physical query plan using the data stream representation model selected from the plurality of data stream representation models based on the logical query graph, wherein
- the plurality of data stream representation models comprise one or more approaches for executing the received CEP query, the one or more approaches corresponding to specific requirements for executing the received CEP query by the CEP engine.
Dependencies are inferred from the claim text.