MapReduce 統計手機用戶的上行流量,下行流量,總流量,並對輸出的結果進行倒序排序。(二),劃分省份,輸出到不同的文件

在(一)的基礎上,寫一個自己的partitioner就好了。   分區的默認實現HashPartitioner,它根據key的hashcode和Interger.  在Reduce過程中,可以根據實際需求(比如按某個維度進行歸檔,類似於數據庫的分組),把Map完的數據Reduce到不同的文件中。分區的設置需要與ReduceTaskNum配合使用。比如想要得到5個分區的數據結果。那麼就得設置5個Re
相關文章
相關標籤/搜索