MapReduce作業的執行流程

1,映射精簡實際處理流程 1.1,輸入階段 數據以一定的格式傳遞給映射器,有的TextInputFormat,DBInputFormat,SequenceFileFormat等可以使用,在Job.setInputFormat可以設置,也可以自定義分片函數。 1.2,地圖階段 對輸入的(鍵,值)進行處理,即圖(K1,V1) - >列表(K2,V2),使用Job.setMapperClass進行設置。
相關文章
相關標籤/搜索