MapReduce的詳細運行階段

①②③④ map task讀文件,通過TextInputFormat讀文本切片,一次讀一行,返回(key,value); ⑤ 上一步獲取的(key,value)鍵值對經過map方法邏輯處理成新的(key,value)鍵值對,通過context.write輸出到OutputCollectior收集器 shuffle階段 ⑥ OutputCollectior把手機的(key,value)鍵值對寫入到環
相關文章
相關標籤/搜索