How to perform Broadcast and groupBy in DataStream like DataSet

[subash basnet]

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