Hi Federico,
If I understand your question correctly, then yes, the application of a Pattern
on a keyed stream
is similar to the application of a map function.
It will search for the pattern on each per-key stream of data.
So there will be state (buffer with partial matches, queued elements, et
Hi all,
I was wondering if it is correct to assume the application of a pattern on
a KeyedStream similar to the application, e.g., of a MapFunction when it
comes to state.
For example, the following
val pattern = ...
val keyedStream = stream.keyBy("id")
val patternKeyedStream = CEP.pattern(patt
