0

Hadoop 的 ChainMapper.addMapper、ChainReducer.setReducer 和 ChainReducer.addMapper 方法中的第二个 JobConf 参数是什么?

我假设这将是仅与我添加的 Mapper 或 Reducer 相关的设置的位置,但是当调用 Mapper 或 Reducer 时,我在第二个 JobConf 上设置的参数不存在。

JobConf overall = new JobConf( Driver.class );
JobConf mapAConf = new JobConf( false );
mapAConf.setInt( "min.word.length", 10 );
ChainMapper.addMapper( overall, Mapper.class, LongWritable.class, Text.class, Text.class, IntWritable.class, false, mapAConf );
ChainReducer.setReducer( overall, Reducer.class, Text.class, IntWritable.class, Text.class, IntWritable.class, false, new JobConf( false ) );

在此示例中,映射器类中未设置 min.word.length 值。

提前致谢!

4

0 回答 0