MapReduce Partitioner 二次分類

Partitioner:   二次分類,我的理解是:如果不加Partitioner組件,Reduce會將輸入的所有類型數據整合在一個文件,如果加了,可以讓reduce根據類型再做一次分類,分出多個Reduce,輸出多個文件   圖:   代碼: /** * 自定義的Partitioner * 二次分類 */ public static class MyPartitioner extends
相關文章
相關標籤/搜索