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
Hi guys,
I have a question for you. I have an application with two keyed data streams:
one for control and the other one for the data. Each control message represents
an operation to be performed on the data values marked with a certain
identifier. I connected the two streams and I process the
