1、WordCountCombinerLocalApp.java
添加:
//添加Combiner的设置即可 job.setCombinerClass(WordCountReducer.class);
2、原理
在map中,将相同key值的结果进行一次操作。
逻辑上和reduce相同。
3、运行
2024-03-14 16:04:52
1、WordCountCombinerLocalApp.java
添加:
//添加Combiner的设置即可 job.setCombinerClass(WordCountReducer.class);
2、原理
在map中,将相同key值的结果进行一次操作。
逻辑上和reduce相同。
3、运行