要获得最大值，您应该声明一个示例变量，并使用它来保存mapper（）方法迄今为止看到的最大值。您可能需要某种方法来表明尚未看到任何值。最后调用cleanup（）方法时，变量将保存所需的值。
返回这个值有点困难。hadoop工作流引擎都使用以下方法的变体在hadoop作业之间传递数据。您可以使用此方法在作业完成时将最大值传递给需要它的人。hack/kludge涉及使用一个众所周知的hdfs目录（可以传入）和taskid来构建一个唯一的、可发现的文件名来保存值。使用hdfs文件io api写出值。

但是，这可能不是最好的解决方案，但是作为一种解决方法，您可以将每个任务的最大值存储在 counter 可以在jobrunner类中检索。然后遍历它们并选择最大的值。例如：
Map器：

private long num = 0L;

@Override
protected void map(...) {
  ...
  num++;
  ...
}

@Override 
public void cleanup(Context context) {
  context.getCounter("MaxValue", "task_" + 
    context.getTaskAttemptID().getTaskID().getId()).increment(num);
}

工作人员
选择作业完成后的最大值：

...
long max = 0;
CounterGroup group = job.getCounters().getGroup("MaxValue");
for (Counter c : group) {
  long val = c.getValue();
  if (val > max) {
    max = val;
  }
}
...