Hadoop の ChainMapper.addMapper、ChainReducer.setReducer、および ChainReducer.addMapper メソッドの 2 番目の JobConf 引数は何ですか?
追加するMapperまたはReducerのみに関連する設定の場所になると思いましたが、2番目のJobConfで設定したパラメーターはMapperまたはReducerが呼び出されたときに存在しません。
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 値が設定されていません。
前もって感謝します!