mapper任务完成事件

hec6srdp  于 2021-06-03  发布在  Hadoop
关注(0)|答案(2)|浏览(282)

我们在hbase上设置了map reduce任务。一旦框架示例化的Map器完成任务,我就需要知道一个需求。
有什么我要看的事件吗?谢谢。

vm0i2vca

vm0i2vca1#

可以在cleanup()方法中转储该数据。cleanup()会在Map程序完成所有操作后被调用,所以它应该可以达到目的,imho。

8wtpewkr

8wtpewkr2#

要添加到tariq的答案中,实际上可以重写mapper类中的setup()和cleanup()方法。因此,对于每个map任务,cleanup()方法在最后被调用一次。请在那里做最后的处理。

相关问题