java - 如何知道reducer已经完成了它的任务

Question

我想在mapreducewordcount示例中的reducer完成其任务后执行文件操作。那么有没有标准方法可以知道reducer已经完成了它的任务呢？

Answer 1

重写Reducer的cleanup方法并做任何你想做的事情。 cleanup 方法是在 Mapper/Reducer 任务结束时调用的最后一个方法。下面是 cleanup 方法的示例:

@Override
public void cleanup(Context context) throws IOException, InterruptedException
{
    // do whatever you wish to do here
}