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(pattern, keyedStream)
val anotherKeyedStream = patternKeyedStream.select(...)
should only check the pattern on each single partition value.
Am I correct in assuming this, or I have misunderstood CEP functioning?
--
Federico D'Ambrosio
