ation.
> Returns:
> The DataSet that represents the result of the iteration, after the
> computation has terminated.-------->For
> DataStream
>
> Best Regards,
> Subash Basnet
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/closewith-not-working-in-DataStream-error-but-works-in-DataSet-tp6953p6958.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hello all,
loop.closewith(...) in below code works fine for the dataset, but the
adaptation of the same code for datastream throws exception.
For *DataSet: *
IterativeDataSet *loop* = centroids.iterate(numIterations);
DataSet *newCentroids* = points.map(new SelectNearestCenter()).
*withBroadcastS
