SYSTEMS AND/OR METHODS FOR USER FEEDBACK DRIVEN DYNAMIC QUERY REWRITING IN COMPLEX EVENT PROCESSING ENVIRONMENTS

• US 20120166421A1
• Filed: 12/27/2010
• Published: 06/28/2012
• Est. Priority Date: 12/27/2010
• Status: Active Grant

• Current Assignee: Software AG
• Original Assignee: Software AG
• Inventors: CAMMERT, Michael, HEINZ, Christoph, KRÄMER, Jürgen, RIEMENSCHNEIDER, Tobias
• Granted Patent: US 8,788,484 B2
• Time in Patent Office: Days
• US Class Current: 707/718
• CPC Class Codes: G06F 16/2425 Iterative querying; Query formulation based on the results of a preceding query
• CPC Class Codes: G06F 16/24549 Run-time optimisation
• CPC Class Codes: G06F 16/24565 Triggers; Constraints
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/24575 using context

Abstract

Certain example embodiments described herein relate to techniques for user feedback driven dynamic query rewriting in complex event processing (CEP) environments. In certain example embodiments, the adjustment of already-initiated queries may be permitted during runtime in order to help continuously or substantially continuously meet a user'"'"'s requirements. In certain example embodiments, parameters of a query may be adapted dynamically, e.g., without the need to redeploy it. Adaptable parameters in certain example embodiments may be identified and/or based on, for instance, an automatic determination from original query creation, user specifications, the way in which a user interacts with a user interface for visualizing the results of queries, etc.

Claims

1. A method of executing queries in a complex event processing (CEP) environment, the method comprising:

receiving a stream of continuous event data;

identifying a query to be run on the received stream, the query including at least one adaptable parameter;

executing the identified query;

displaying results of the identified query in a user interface;

receiving, via the user interface, input indicative of a change to the adaptable parameter; and

modifying the identified query based on the received input, the query being dynamically modified during runtime and as the stream of continuous event data is being received.

2. The method of claim 1, further comprising:

receiving user input defining the query to be run; and

identifying the at least one adaptable parameter within the query.

3. The method of claim 2, wherein the at least one adaptable parameter is identified by a user.

4. The method of claim 2, wherein the at least on adaptable parameter is automatically detected during query parsing.

5. The method of claim 2, further comprising:

developing a logical query plan or graph based on the user input defining the query, the logical query plan or graph describing at a high level steps to be performed when the query is run; and

translating the logical query plan or graph into a physical query plan or graph, the physical query plan or graph including executable logic to be used in the execution of the query.

6. The method of claim 5, further comprising defining and registering access points for dynamically modifying the at least one adaptable parameter in connection with the translating of the logical query plan or graph into the physical query plan or graph.

7. The method of claim 5, further comprising improving or optimizing the logical query plan or graph based on initial settings of parameters that form parts of the query, if any.

8. The method of claim 1, further comprising disposing within the user interface a control element associated with the at least one adaptable parameter, the at least one adaptable parameter being adjustable via its associate control element.

9. The method of claim 1, further comprising:

detecting whether a user has lingered on a query view for a predetermined amount of time; and

when it is determined that the user has lingered on the query view for the predetermined amount of time, adjusting parameters of the query associated with the query view so as to improve accuracy of the query.

10. The method of claim 1, further comprising:

detecting whether a user has lingered on a query view for a predetermined amount of time; and

when it is determined that the user has lingered on the query view for the predetermined amount of time, allocating resources such that the query associated with the query view is given an elevated priority compared to a situation where it is determined that the user has not lingered on the query view for the predetermined amount of time.

16. A non-transitory computer readable storage medium tangibly storing instructions that, when executed by at least one processor of a continuous event processing (CEP) system, perform a method according to claim 1.

11. A method of configuring a system for executing queries in a complex event processing (CEP) environment, the method comprising:

receiving user input defining at least one continuous query to be run on at least one stream of event data;

parsing the at least one query so as to (a) identify at least one adaptable parameter within the at least one query and (b) develop a logical query plan or graph based on the user input defining the query, the logical query plan or graph describing at a high level steps to be performed when the query is run;

translating the logical query plan or graph into a physical query plan or graph, the physical query plan or graph including executable logic to be used in the execution of the query; and

in connection with the translating of the logical query plan or graph into the physical query plan or graph, registering access points enabling a user to dynamically modify the at least one adaptable parameter of the at least one query at runtime without interrupting execution of the at least one query and while continuing to receive the at least one stream of event data.

12. The method of claim 11, wherein the at least one adaptable parameter is identified by a user.

13. The method of claim 11, further comprising automatically detecting the at least on adaptable parameter of the at least one query during query parsing.

14. The method of claim 11, further comprising improving or optimizing the logical query plan or graph based on initial settings of parameters that form parts of the query, if any.

15. A method of executing a query in a complex event processing (CEP) environment, the method comprising:

configuring a system in accordance with the process of claim 11;

executing the identified query;

displaying results of the identified query in a user interface; and

updating the query based on (a) user input received via a user interface indicative of a change to the at least one adaptable parameter directly, and/or (b) a way in which the user interacts with the user interface,

wherein the updating is performed without redeploying the query.

17. A non-transitory computer readable storage medium tangibly storing instructions that, when executed by at least one processor of a continuous event processing (CEP) system, perform a method according to claim 11.

18. A non-transitory computer readable storage medium tangibly storing instructions that, when executed by at least one processor of a continuous event processing (CEP) system, perform a method according to claim 15.

19. A continuous event processing (CEP) system, comprising:

an adapter configured to receive data from at least one event stream;

a query design tool configured to receive user input corresponding to at least one query executable on at least one said event stream;

a query parser configured to (a) identify at least one adaptable parameter within the at least one query and (b) develop a corresponding logical query plan or graph based on the at least one query, each said corresponding logical query plan or graph specifying steps to be performed when the query is run;

a query translator configured to translate each said logical query plan or graph into a corresponding physical query plan or graph, each said physical query plan or graph including executable logic to be used in the execution of the query;

a register of access points enabling a user to dynamically modify the at least one adaptable parameter of the at least one query at runtime without having to redeploy the at least one query and while continuing to receive the at least one stream of event data;

at least one processor configured to execute the at least one query on the at least one stream based on the physical query plan or graph; and

a user interface configured to display results of the query executed by the at least one processor, the user interface including one or more elements enabling the user to adjust the at least one adaptable parameter using the register of access points.

20. The system of claim 19, further comprising a monitoring thread configured to monitor ways in which the user interacts with the user interface and correspondingly adjust or recommend adjustments to the at least one adaptable parameter.