Systems and/or methods for user feedback driven dynamic query rewriting in complex event processing environments

A method of configuring a computer system that includes at least one processor 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, using the computer system, 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, using the computer system, enabling a user to dynamically modify the at least one adaptable parameter of the at least one query at execution runtime of the at least one query without interrupting execution of the at least one query and while continuing to receive the at least one stream of event data.

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 execution runtime of the at least one query 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.