大數據-MapReduce工作機制

MapReduce的工作機制 （1）通過submit()方法將任務提交給客戶端 （2）將通過split()方法得出的切片信息提交給Yarn （3）NodeManger計算出MapTask數量（MapTask由Block大小決定） （4）MapTask通過InputFormat類讀取文件數據 （5）客戶端以(key,value)結構來傳輸數據 （6）在Mapper階段執行Mapper類中的map()

>>阅读原文<<