为什么我们可以在 WordCount 示例中重用 Text 对象

Question

看了Hadoop的例子：WordCount，我不明白为什么我们可以重用Text对象而不是为每个写操作“context.write(...)”创建一个新对象？

public class WordCount { 

 public static class TokenizerMapper
   extends Mapper<Object, Text, Text, IntWritable>{

   private final static IntWritable one = new IntWritable(1);

   **private Text word = new Text();**

   public void map(Object key, Text value, Context context
                    ) throws IOException, InterruptedException {
     StringTokenizer itr = new StringTokenizer(value.toString());
     while (itr.hasMoreTokens()) {

       // set other String in Text object
       **word.set(itr.nextToken());**
       **context.write(word, one);**
    }
}....

我的问题是，如果每个map任务中只有一个Text对象，在我们使用“word.set(...)”改变它的内容后，之前的结果键值对会受到影响，因为键使用相同的 Text 对象，其内容现在已更改。

我错过了什么吗？提前感谢您纠正我...

Answer 1

重用对象是避免创建许多新对象的好习惯。因此，map() 方法中的context.write(word, one) 填充并重用了word 和one 对象。

context.write() 将生成一个输出键/值对。当调用context.write() 时，Hadoop 框架将负责序列化数据。因此，您可以安全地重用 map() 方法中的对象。