MapReduce源碼解析之Map端的輸入輸出【小二講堂】

一、Map輸入端 當作業進行切片後被提交到MR進行執行時,必須經過Mapper類的run方法進行任務的執行,這樣我們在map端的自定義map方法也會執行,而根據業務需求我們可以對map端的輸出進行業務邏輯的處理,以達到在Reduce我們對Map端處理的數據進行接收,並進行計算。 1.自定義類中繼承Mapper類 2.進入mapper.class類中,我們可以看到有setup()方法,還有自定義類繼
相關文章
相關標籤/搜索