Hi Konstantin,
Thank you so much for your answer. Yes, I think this is exactly what I need.
Thank you.
Best,
Gabriele
> On 18 Jul 2017, at 21:27, Konstantin Knauf
> wrote:
>
> Hi Gabriele,
>
> I think this is actually a quite common pattern. Generally, you can
> `join` the two streams a
Hi Gabriele,
I think this is actually a quite common pattern. Generally, you can
`join` the two streams and then use a `CoFlatMapFunction`. A
`CoFlatMapFunction` allows you to keep shared (checkpointed) state
between two streams. It has two callbacks `flatMap1` and `flatMap2`
which are called when
