Cost monitoring and cost-driven optimization of complex event processing system

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

• a cost calculator component of a complex event processing (CEP) system indexing operators of a query received from a user;
• the cost calculator component referencing a cost model including a memory cost, of the CEP system to assign an operator placement algorithm to the query;
• a query optimization component of the CEP system performing a query optimization to generate an optimized query;
• an operator placement component of the CEP system using the operator placement algorithm with the optimized query, to calculate a chosen operator placement;
• the operator placement component deploying the optimized query onto a scalable streaming system;
• the cost calculator component tracking and collecting run-time information regarding the optimized query on an operator level and on a query level from the scalable streaming system;
• and
• the cost calculator component calculating tracked and collected costs of the optimized query and communicating the tracked and collected costs to the user.

A computer system comprising:

• one or more hardware processors;
• a software program, executable on a hardware processor of said computer system, the software program instructing:
• a cost calculator component of a complex event processing (CEP) system, to index operators of a query received from a user;
• the cost calculator component to reference a cost model including a memory cost, of the CEP system to assign an operator placement algorithm to the query;
• a query optimization component of the CEP system to perform a query optimization to generate an optimized query;
• an operator placement component of the CEP system to use the operator placement algorithm with the optimized query, to calculate a chosen operator placement;
• the operator placement component to deploy the optimized query onto a scalable streaming system;
• the cost calculator component to track and collect run-time information regarding the optimized query on an operator level and on a query level from the scalable streaming system;
• and
• the cost calculator component to calculate tracked and collected costs of the optimized query and to communicate the tracked and collected costs to the user.