MapReduce之mapTask阶段详解

整个Map阶段流程大体如上图所示。 简单概述：inputFile通过split被逻辑切分为多个split文件，通过Record按行读取内容给 map（用户自己实现的）进行处理，数据被map处理结束之后交给OutputCollector收集 器，对其结果key进行分区（默认使用hash分区），然后写入buffer，每个map task都有 一个内存缓冲区，存储着map的输出结果，当缓冲区快满的时候需

>>阅读原文<<