Hi everybody, recently we've seen an increased interest in complex event processing (CEP) by Flink users. Even though most functionality is already there to solve many use cases it would still be helpful for most users to have an easy to use library. Having such a library which allows to define complex event patterns would increase Flink's user range to the CEP community. Once having laid the foundation, I'm optimistic that people will quickly pick it up and further extend it.
The major contribution of this library would be to add an efficient non-deterministic finite automaton which can detect complex event patterns. For everything else, Flink already has most of the functionality in place. I've drafted a design document for the first version. Please review it and comment: https://docs.google.com/document/d/15iaBCZkNcpqSma_qrF0GUyobKV_JttEDVuhNd0Y1aAU/edit?usp=sharing Thanks, Till
