0

我们在 HBase 上设置了一个 map reduce 任务。一旦框架实例化的映射器完成其任务,我需要知道一个要求。

有什么我必须看的事件吗?谢谢。

4

2 回答 2

3

您可以在cleanup()方法中转储该数据。cleanup() 会在映射器完成所有操作后被调用,因此它应该服务于目的,恕我直言。

于 2013-09-17T20:31:44.127 回答
1

要添加到 Tariq 的答案,您实际上可以覆盖 Mapper 类中的 setup() 和 cleanup() 方法。因此,对于每个地图任务,最后都会调用一次 cleanup() 方法。请在那里进行最后的处理。

于 2013-09-18T08:12:18.593 回答