MapReduce原理全剖析

MapReduce剖析图 如上图所示是MR的运行详细过程web 首先mapTask读文件是经过InputFormat（内部是调RecordReader()–＞read()）来一次读一行，返回K,V值。（默认是TextInputFormat，还能够输入其余的类型如:音视频，图片等。）。 mapper(map(k,v))–＞context.write()即mapTask阶段。 输出数据到OutputC

>>阅读原文<<