flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From subash basnet <yasub...@gmail.com>
Subject How to iterate over DataSet elements without converting it to List
Date Thu, 18 Feb 2016 14:29:48 GMT
Hello there,

I have been stuck on how to iterate over the DataSet, perform operations
and return a new modified DataSet similar to that of list operation as
shown below.
Eg:
for (Centroid centroid : centroids.collect()) {
    for (Tuple2<Integer, Point> element : clusteredPoints.collect()) {
       //perform necessary operations
     }
//add elements
}
//return elements list

I need to iterate over dataSet without converting it to List.


Best Regards,
Subash Basnet

Mime
View raw message