Hi Thomas, have a look at DataSetUtils [1].
Best, Fabian [1] https://github.com/apache/flink/blob/master/flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java 2016-11-02 13:17 GMT+01:00 Thomas FOURNIER <thomasfournier...@gmail.com>: > Hello, > > Is it possible with the current Flink-API to give a unique id to each line > of a dataset ? > > More precisely, I've globally sorted my Dataset with partitionByRange and > I'd like to perform a kind of "zipWithIndex" operation, so that I can > retrieve a Map (such as a collectAsMap with Spark). > > Thanks > Regards > > Thomas >
