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 <revolutioni...@gmail.com> 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. >
