我们在hbase上设置了map reduce任务。一旦框架示例化的Map器完成任务,我就需要知道一个需求。有什么我要看的事件吗?谢谢。
vm0i2vca1#
可以在cleanup()方法中转储该数据。cleanup()会在Map程序完成所有操作后被调用,所以它应该可以达到目的,imho。
8wtpewkr2#
要添加到tariq的答案中,实际上可以重写mapper类中的setup()和cleanup()方法。因此,对于每个map任务,cleanup()方法在最后被调用一次。请在那里做最后的处理。
2条答案
按热度按时间vm0i2vca1#
可以在cleanup()方法中转储该数据。cleanup()会在Map程序完成所有操作后被调用,所以它应该可以达到目的,imho。
8wtpewkr2#
要添加到tariq的答案中,实际上可以重写mapper类中的setup()和cleanup()方法。因此,对于每个map任务,cleanup()方法在最后被调用一次。请在那里做最后的处理。