hadoop - 旧 Hadoop API 中的 Mapper.cleanup() 方法等效于什么？

Question

我正在尝试测量每个 Map 任务从开始到结束所花费的时间。我这样做的方法是在 setup() 函数中启动一个计时器，然后在 cleanup() 函数中输出计时器。现在的问题是，除了旧的 Hadoop API，我正在尝试做同样的事情，但似乎没有什么等同于 cleanup()

Answer 1

您可能会找到 OutputCommiter.commitJob有用。但是为什么要使用旧的 API。新的要干净得多。