6)Hadoop之MapReduce(MapTask、ReduceTask工作機制)

MapTask工作機制: Read階段: MapTask通過用戶編寫的RecorderReader,從輸入的InputSplit中解析出一個個的key/vale; Map階段: 該階段主要是將解析出的key/value交給用戶編寫的map()方法處理,併產生一系列新的key/value; Collect收集階段: 結束map()方法中的數據處理後,一般會調用OutputCollector.coll
相關文章
相關標籤/搜索