I'm not sure in regards of "withBroadcastSet", but in the DataStream you "keyBy" instead of "groupBy".
On Tue, May 3, 2016 at 12:35 PM, subash basnet <yasub...@gmail.com> wrote: > Hello all, > > How could we perform *withBroadcastSet* and *groupBy* in DataStream like > that of DataSet in the below KMeans code: > > DataSet<Centroid> newCentroids = points > .map(new SelectNearestCenter()).*withBroadcastSet*(loop, "centroids") > .map(new CountAppender()).*groupBy*(0).reduce(new CentroidAccumulator()) > .map(new CentroidAverager()); > > > DataStream<Centroid> newCentroids = points.map(new > SelectNearestCenter()).??? > > > Best Regards, > Subash Basnet > -- BR, Stefano Baghino Software Engineer @ Radicalbit
