Hi Pieter-Jan,
The second variant stores the elements of the broadcasted stream in operator
(thus non-keyed) state.
On the differences:
The Broadcast stream is not a keyed stream, so you are not in a keyed context,
thus you have no access to keyed state.
Given this, and assuming that you are
Hi,
I am not sure I fully understand the differences between doing something
like
dataStreamX.connect(dataStreamY.broadcast()).process(new
CoProcessFunction{})
and this
dataStreamX.connect(dataStreamY.broadcast(*descriptor*).process(new
BroadcastProcessFunction)
Couldn't I manage the state
