partition identifier

Posted by Attila Bernáth on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/partition-identifier-tp513.html

Dear Developers,

Datasets are partitioned between machines. I wonder if there is a way
to get some identifier of a partition. I see that the class
HashPartition has a getPartitionNumber method, but I don't see how I
could use this.
(For example, I would like to see the partition identifier in a
MapFunction, or in a MapPartitionFunction).

Attila