MapReduce中的mapper和reducer以及context

關於MapReduce中的mapper Mapper有setup(),map(),cleanup()和run()四個方法。其中setup()一般是用來進行一些map()前的準備工作,map()則一般承擔主要的處理工作,cleanup()則是收尾工作如關閉文件或者執行map()後的K-V分發等。run()方法提供了setup->map->cleanup()的執行模板。     在MapReduce中
相關文章
相關標籤/搜索