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

Reply via email to