hadoop - mapper run() 方法如何处理最后一条记录？

Question

public void run(Context context) throws IOException, InterruptedException 
{
setup(context);

while (context.nextKeyValue()) {
map(context.getCurrentKey(), context.getCurrentValue(), context);
 }
cleanup(context);
}

使用上面的代码片段，当映射器的 run 方法被调用时，每次它通过 recordreader 的 nextkeyvalue() 函数获取下一个键值对并处理当前键值对。因此，在那种情况下，如果我们正在处理特定输入拆分的最后一条记录，nextkeyvalue() 函数将返回 false，并且我们不会丢失每个输入拆分中的最后一条记录？

Answer 1

nextKeyValue()要么前进到下一个键/值并返回 true，要么已经到达终点并返回 false。因此，当 nextKeyValue() 最后一次返回 true 时，getCurrentKey() 和 getCurrentValue() 将获得拆分的最终键/值。