Hi Björn,
You are correct that CEP library buffers events until a watermark with a
greater timestamp arrives. It is because the order of events in case of CEP is
crucial.
Imagine a Pattern like A next B. And sequence a(t=1) c(t=10) b(t=2). If we do
not wait until the Watermark and sort the even
Hi,
I am writing a small application which monitors a couple of directories for
files which are read by Kafka and later consumed by Flink. Flink then
performs some operations on the records (such as extracting the embedded
timestamp) and tries to find a pattern using CEP. Since the data can be out
