Efficient adaptive detection of complex event patterns

A system comprising:

• at least one hardware processor;
• and
• a non-transitory computer-readable storage medium having stored thereon program code, the program code executable by the at least one hardware processor to:
• receive, as input, a data stream representing events,
• receive a complex event pattern (CEP) specification representing an occurrence of a CEP in said data stream, wherein said CEP specification comprises (a) a set of conditions associated with relations among said events, and (b) a set of attributes associated with said events,
• continuously update, from said data stream, current values associated with said set of attributes,
• apply an algorithm to generate, based on said CEP specification and said current values, a current CEP plan configured to determine said occurrence of said CEP in said data stream, wherein said current CEP plan comprises of a series of execution steps, and
• optimize said current CEP plan by, iteratively:
• (i) executing said current CEP plan,
• (ii) identifying, with respect to each of said execution steps, one of said conditions as an invariant condition whose verification causes said execution step to be included in said current CEP plan,
• (iii) performing a re-verification of all of said invariant conditions using said updated current values, and
• (iv) re-applying said algorithm when said re-verification fails with respect to at least one of said invariant conditions, to generate an updated CEP plan.

A computer program product comprising a non-transitory computer-readable storage medium having program code embodied therewith, the program code executable by at least one hardware processor to:

• receive, as input, a data stream representing events;
• receive a complex event pattern (CEP) specification representing an occurrence of a CEP in said data stream, wherein said CEP specification comprises (a) a set of conditions associated with relations among said events, and (b) a set of attributes associated with said events;
• continuously update, from said data stream, current values associated with said set of attributes;
• apply an algorithm to generate, based on said CEP specification and said current values, a current CEP plan configured to determine said occurrence of said CEP in said data stream, wherein said current CEP plan comprises of a series of execution steps;
• and
• optimize said current CEP plan by, iteratively:
• (i) executing said current CEP plan,
• (ii) identifying, with respect to each of said execution steps, one of said conditions as an invariant condition whose verification causes said execution step to be included in said current CEP plan,
• (iii) performing a re-verification of all of said invariant conditions using said updated current values, and
• (iv) re-applying said algorithm when said re-verification fails with respect to at least one of said invariant conditions, to generate an updated CEP plan.