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 exactly the same way using the first option?
The only difference I could find was in read/write permissions for
different states. But other than that, the difference in possibilities
escapes me and I was hoping someone here could clarify.
Kind regards,
Pieter-Jan
___________________________
*Pieter-Jan Van Aeken*
Consultant - Data Engineer
(M) +32 (0) 474 06 64 48
*EURA NOVA*
Rue Emile Francqui, 4
1435 Mont-Saint-Guibert
(T) +32 10 75 02 00
*euranova.eu <http://euranova.eu>*
*research.euranova.eu* <http://research.euranova.eu>
--
♻ Be green, keep it on the screen
