スロースタート減速

Question

た後、私はマップ2ステップだけステップの削減の完了後に開始する次のパターン

Map1 --> Reduce --> Map2 

を構築するためにChainReducerを使用しています。 hadoopマップにこれを設定するプロパティがありますか？あなたは何をすべき

Answer 1

は次のとおりです。

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 

上記のコードは、Map2の実行というReduceが終了したときに、唯一の起動を保証します。