ChainMapper.addMapper(generalConf, Map1.class, ..., new JobConf(false));
ChainReducer.setReducer(generalConf, Reduce.class, ..., new JobConf(false));
ChainReducer.addMapper(generalConf, Map2.class, ..., true, new JobConf(false));
// execute the job with generalConf
1条答案
按热度按时间inn6fuwd1#
你应该做的是:
以上代码将保证
Map2
,仅在Reduce
已经完成了。