Hello,
I have a question regarding the loop-awareness of Flink wrt invariant
datasets.
Does Flink serialize the DataSet 'points' in line 85
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
that the hash values are indeed preserved
during MapReduce. However, hacking the library is a very clumsy approach.
My question now is: does Flink provide a more elegant solution?
Thanks for your help!
Regards,
Robert Schwarzenberg
