flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thomas FOURNIER <thomasfournier...@gmail.com>
Subject Assign a unique id to each line of a dataset
Date Wed, 02 Nov 2016 12:17:35 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message