Hi,
It's stating that you can't use a DataStream which was not part of the
iteration. It works with `newCentroids` because it is part of the
loop.
The only way to get the centroids DataStream in, is to union/join it
with the `newCentroids` stream.
Cheers,
Max
On Wed, Jul 20, 2016 at 11:33 AM, s
Hello all,
When I execute the below streaming code:
DataStream *centroids* = newCentroidDataStream.map(new
TupleCentroidConverter());
ConnectedIterativeStreams loop =
*points*.iterate().withFeedbackType(Centroid.class);
DataStream *newCentroids* = loop.flatMap(new
SelectNearestCenter(10)).map(new