Mapreduce過程詳解(圖解+註解)

MapReduce一共分爲map和reduce兩個階段 (1234)map task流程是通過TextInputFormat->RecordReadeer->read()一次讀一行,返回到(key,value) (5)獲取(key,value)單行數據,進行數據分割,生成新的(key,value),通過context.write()把新的(key,value)輸出到OutpuCollector收集
相關文章
相關標籤/搜索