Support for a parameterized query/view in complex event processing

A system for providing parameterized queries in complex event processing (CEP), the system comprising:

• a memory;
• and
• a processor coupled with the memory, wherein the memory has sets of instructions stored thereon which, when executed by the processor, cause the processor to:
• provide a query template which includes one or more bind variables, wherein the one or more bind variables are typeless within the CEP environment;
• provide sets of parameters corresponding to the one or more bind variables;
• parse the query template to determine positions of the one or more bind variables;
• scan the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables;
• bind the one or more bind variables which are determined to be bound to the corresponding sets of parameters;
• insert arbitrary predicates into the query template, based on the one or more bind variables being typeless;
• substitute the bound one or more bind variables with the corresponding sets of parameters;
• based on the sets of parameters, generate a single parameterized query which is a template that provides possible values for the bound one of more bind variables;
• determine a placeholder occurring in the single parameterized query for processing an event stream;
• based on the single parameterized query, generate multiple customized queries and views which differ by at least only one variable, wherein the multiple customized queries and views are maintained by substituting the placeholder at runtime with parameters from the sets of parameters;
• instantiate a new query based on the query temple which includes the corresponding sets of parameters substituted for the one or more bind variables and injecting the new query into a CEP server;
• based on the new query, build a query execution plan;
• adding the query execution plan to a runtime environment as a continuous query;
• and
• execute the continuous query to process the event stream.

A non-transitory computer-readable medium having sets of instructions stored thereon which, when executed by a computer, cause the computer to:

• provide a query template which includes one or more bind variables, wherein the one or more bind variables are typeless within the CEP environment;
• provide sets of parameters corresponding to the one or more bind variables;
• parse the query template to determine positions of the one or more bind variables;
• scan the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables;
• bind the one or more bind variables which are determined to be bound to the corresponding sets of parameters;
• insert arbitrary predicates into the query template, based on the one or more bind variables being typeless;
• substitute the bound one or more bind variables with the corresponding sets of parameters;
• based on the sets of parameters, generate a single parameterized query which is a template that provides possible values for the bound one of more bind variables;
• determine a placeholder occurring in the single parameterized query for processing an event stream;
• based on the single parameterized query, generate multiple customized queries and views which differ by at least only one variable, wherein the multiple customized queries and views are maintained by substituting the placeholder at runtime with parameters from the sets of parameters;
• instantiate a new query based on the query temple which includes the corresponding sets of parameters substituted for the one or more bind variables and injecting the new query into a CEP server;
• based on the new query, build a query execution plan;
• adding the query execution plan to a runtime environment as a continuous query;
• and
• execute the continuous query to process the event stream.