为什么在Hadoop中扩展RecordReader时要同步close()方法

Question

我会在这里看看给定alexhomes的hadoop书的例子

我不明白为什么关闭方法是同步的？为什么只有close（）而没有其他方法？

public synchronized void close() throws IOException {
  reader.close();
}

有人能解释一下吗？这将非常有帮助。

Answer 1

正如我在书中提到的，我使用ElephantBird项目的LzoJsonRecordReader类作为我的版本的基础，因为我想写一个不需要LZOP压缩的版本。ElephantBird在他们的RecordReader中使用了同步关闭方法，结果也进入了我的版本。正如其他人所提到的，据我所知，没有任何理由在MapReduce中同步close方法。