Data Lake for Enterprises

Complex event processing

During our discussion of Flink framework, we came across various mechanisms by that Flink can perform in stream analysis since it supports exactly once processing of events and also enables windowing functions. One of the main components of CEP engine is accurate data aggregation that would be possible only if the events are processed only once. These are some of the building blocks of full fledged CEP engine and with these capabilities specific CEP capabilities can be built from ground up.

However in order to build a complete CEP engine, it may need considerable efforts and some use cases may demand use of a complete CEP engine right away. For such scenarios there are embeddable CEP engines like Esper that can be ...