Re: Regarding source Parallelism and usage of coflatmap transformation

2016-05-09 Thread Biplob Biswas
nnectedIterativeStreams<Point, Centroid> ptct= >> tuples.iterate().withFeedbackType(MicroCluster.class); >> DataStream > > updatedcentroids = ptct.flatMap(new MyCoFlatmap()) >> inputsAndMicroCluster.closeWith(updatedcentroids .broadcast());/ >> >> >> but

Re: Regarding source Parallelism and usage of coflatmap transformation

2016-05-09 Thread Aljoscha Krettek
FeedbackType(MicroCluster.class); > DataStream updatedcentroids = ptct.flatMap(new MyCoFlatmap()) > inputsAndMicroCluster.closeWith(updatedcentroids .broadcast());/ > > > but i can't see the centroids already broadcasted by > centroidStream.broadcast() in the map functions. > > Any ki

Regarding source Parallelism and usage of coflatmap transformation

2016-05-05 Thread Biplob Biswas
27;t see the centroids already broadcasted by centroidStream.broadcast() in the map functions. Any kind of help is hugely appreciated. Thanks and Regards Biplob Biswas -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Regarding-source-Parallelism-and-usage