Elastic Complex Event Processing

A non-transitory computer readable storage medium embodying a computer program for performing a method, said method comprising:

• causing a cost explanation component maintaining a cost model, to index a query submitted by a user;
• causing the cost explanation component to forward the query to a query optimization component maintaining a query graph;
• causing the query optimization component to match the query against the query graph to detect re-use or subsumption of operators, and produce a modified query graph;
• forwarding the modified query graph to an operator placement component;
• causing the operator placement component to deploy new operators based upon the modified query graph;
• causing the cost explanation component to receive information regarding system utilization and operator performance statistics, from an associated distributed Complex Event Processing (CEP) system comprising a host upon which the new operator has been deployed;
• based upon the information and the cost model, causing the cost explanation component to provide feedback to the user regarding a monetary cost of the distributed CEP system.

A computer system comprising:

• one or more processors;
• a software program, executable on said computer system, the software program configured to:
• cause a cost explanation component maintaining a cost model, to index a query submitted by a user;
• cause the cost explanation component to forward the query to a query optimization component maintaining a query graph;
• cause the query optimization component to match the query against the query graph to detect re-use or subsumption of operators, and produce a modified query graph;
• forward the modified query graph to an operator placement component;
• cause the operator placement component to deploy new operators based upon the modified query graph;
• cause the cost explanation component to receive information regarding system utilization and operator performance statistics, from an associated distributed Complex Event Processing (CEP) system comprising a host upon which the new operator has been deployed;
• based upon the information and the cost model, cause the cost explanation component to provide feedback to the user regarding a monetary cost of the distributed CEP system.