Getting the NumberOfParallelSubtask

[Paschek, Robert]

Hi Mailing list,

using a RichMapPartitionFunction i can access the total number m of this mapper 
utilized in my job with
int m = getRuntimeContext().getNumberOfParallelSubtasks();

I think that would be - in general - the total number of CPU Cores used by 
Apache Flink among the cluster.

Is there a way to access the number of the following reducer?

In general i would assume that the number of the following reducers depends on 
the number of groups generated by the groupBy() transformation. So the number 
of the reducer r would be 1 <= r <= m.

My Job:
DataSet<?> output = input
                                .mapPartition(new MR_GPMRS_Mapper())
                                .groupBy(0)
                                .reduceGroup(new MR_GPMRS_Reducer());

Thank you in advance
Robert