这个类维护了一个<name, OutputCollector>的map。我们可以在job配置里添加collector,然后在reduce方法中,取得对应的collector并调用collector.write即可。
Hadoop:mapreduce程序reduce输出控制(4)
内容版权声明:除非注明,否则皆为本站原创文章。
转载注明出处:http://www.heiqu.com/560e462818f4132993e4df7b47a2ec31.html
这个类维护了一个<name, OutputCollector>的map。我们可以在job配置里添加collector,然后在reduce方法中,取得对应的collector并调用collector.write即可。
内容版权声明:除非注明,否则皆为本站原创文章。
转载注明出处:http://www.heiqu.com/560e462818f4132993e4df7b47a2ec31.html