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