That would really be great, any example would help me proceed with my work. Thanks a lot.
Aljoscha Krettek wrote > Hi Biplob, > one of our developers had a stream clustering example a while back. It was > using a broadcast feedback edge with a co-operator to update the > centroids. > I'll directly include him in the email so that he will notice and can send > you the example. > > Cheers, > Aljoscha > > On Thu, 28 Apr 2016 at 13:57 Biplob Biswas < > revolutionisme@ > > wrote: > >> 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. >> -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-Broadcast-of-datasets-in-streaming-context-tp6456p6548.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
