Hi Gabriele,
Yes, something like this is possible with Flink. However, you have to implement
a two-stage approach for this that I would roughly call "scatter-gather". You
have three operators:
input -> Scatter -> State -> Gather -> output
Where the "Scatter" analyses the what state you need fo
Hi Gabriele,
I think CEP may be able to deal with this kind of expressions, in
general, although I am not sure about how to deal with different time
windows (5s and 3s, in your case). Take a look at the available patterns
in the CEP library doc:
https://ci.apache.org/projects/flink/flink-docs
