Hi! You can always use the "rich" version of the function, for example the "RichMapFunction". Inside that function, you can call "getRuntimeContext()", which gives you access to many things, among them the partition number.
Stephan On Wed, Dec 3, 2014 at 3:49 PM, Attila Bernáth <[email protected]> wrote: > 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 >
