mapTask和ReduceTask工作機制以及mapreduce完整流程

1、mapTask工作機制() 1、Read階段:mapTask通過用戶編寫的RecordReader,從輸入InputSplit中解析出一個個key/value對; 2、Map階段:該節點主要是將解析出的key、value(k1,v2)交給用戶編寫map()函數處理,併產生一系列新的key、value對(k2,v2); 3、Collect收集階段:在用戶編寫map()函數中,當數據處理完成後,一
相關文章
相關標籤/搜索