与旧HadoopAPI中的mapper.cleanup()方法等效的是什么?

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

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

p4tfgftt

p4tfgftt1#

在旧的api中,需要重写 java.io.Closeable.close() 方法。另一方面,您可以从job tracker获得map任务执行时间。

7kjnsjlb

7kjnsjlb2#

您可能会发现outputcommiter.commitjob很有用。但是为什么要使用旧的api呢。新的干净多了。

相关问题