###5.4.11 圆形缓冲区引入

如果有reduce任务，通过NewOutputCollector写到圆形缓冲区中。所以自定义Mapper类在执行context.write(xx)方法时调用的就是NewOutputCollector类中的write方法：

xxxxxxxxxx
@Override
public void write(K key, V value) throws IOException, InterruptedException {
  //将(key,value,partitin)缩写(k,v,p)
  collector.collect(key, value,
                    partitioner.getPartition(key, value, partitions));
}

放回到构造方法中：

xxxxxxxxxx
NewOutputCollector(org.apache.hadoop.mapreduce.JobContext jobContext,
                   JobConf job,
                   TaskUmbilicalProtocol umbilical,
                   TaskReporter reporter
                  ) throws IOException, ClassNotFoundException {
    //涉及到后续的圆形缓冲区，稍后讲：
    collector = createSortingCollector(job, reporter);
    ......
}

点击createSortingCollector方法：

所以该collector就是找MAP_OUTPUT_COLLECTOR_CLASS_ATTR对应的配置的类，如果没有配置则使用默认的MapOutputBuffer类来创建对象。MapOutputBuffer就是圆形缓冲区的类。