大数据-MapReduce工作机制

MapReduce的工作机制 （1）通过submit()方法将任务提交给客户端 （2）将通过split()方法得出的切片信息提交给Yarn （3）NodeManger计算出MapTask数量（MapTask由Block大小决定） （4）MapTask通过InputFormat类读取文件数据 （5）客户端以(key,value)结构来传输数据 （6）在Mapper阶段执行Mapper类中的map()

>>阅读原文<<