我试图测量每个Map任务从开始到结束所花费的时间。我这样做的方法是在setup()函数中启动计时器,然后在cleanup()函数中输出计时器。现在的问题是,我正在尝试做同样的事情,但对旧的hadoopapi,但似乎没有什么等效于cleanup()
p4tfgftt1#
在旧的api中,需要重写 java.io.Closeable.close() 方法。另一方面,您可以从job tracker获得map任务执行时间。
java.io.Closeable.close()
7kjnsjlb2#
您可能会发现outputcommiter.commitjob很有用。但是为什么要使用旧的api呢。新的干净多了。
2条答案
按热度按时间p4tfgftt1#
在旧的api中,需要重写
java.io.Closeable.close()
方法。另一方面,您可以从job tracker获得map任务执行时间。7kjnsjlb2#
您可能会发现outputcommiter.commitjob很有用。但是为什么要使用旧的api呢。新的干净多了。