Hello Aljoscha Krettek,
Thank you. As you suggested, I changed my code as below:
*snippet 1:*
DataStream centroids = newCentroidDataStream.map(new
TupleCentroidConverter());
ConnectedIterativeStreams loop =
points.iterate().withFeedbackType(Centroid.class);
DataStream newCentroids = loop.flatMap(n
Hi,
you have to ensure to filter the data that you send back on the feedback
edge, i.e. the loop.closeWith(newCentroids.broadcast()); statement needs to
take a stream that only has the centroids that you want to send back. And
you need to make sure to emit centroids with a good timestamp if you wan
Hello all,
I am trying to cluster datastream points around a centroid. My input is
stock data where the centroid id I have taken as the timestamp of the
stock. The error I am facing is in getting *id *of the *centroid* within
*flatMap2*. Below is my code if you could look:
ConnectedIterativeStrea
