I am pretty new to flink systems, thus can anyone atleast give me an example of how datastream.broadcast() method works? From the documentation i get the following:
broadcast() Sets the partitioning of the DataStream so that the output elements are broadcasted to every parallel instance of the next operation. If the output elements are broadcasted, then how are they retrieved? Or maybe I am looking at this method in a completely wrong way? Thanks Biplob Biswas -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6543.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
