[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

BroadcastStream vs Broadcasted DataStream


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 Van Aeken

Consultant - Data Engineer
(M) +32 (0) 474 06 64 48


Rue Emile Francqui, 4

1435 Mont-Saint-Guibert

(T) +32 10 75 02 00

 Be green, keep it on the screen