MapReduce工作机制详解（MapTask和ReduceTask)

MapTask: 1.maptask0负责切片0 ，maptask1负责切片1，maptask2负责切片2。 2.maptask0通过一个组件TextinputFormat读切片0，这个组件封装一个LineRecordReader,里面有next方法，每调一次方法从切片0里读一行，给maptask返回k1：行起始offset和value1：行内容。 3.调用mapper里的map(k1,v1,co

>>阅读原文<<