hadoop - カスケードでレデューサーを強制するにはどうすればよいですか?

Question

マッパーではなくレデューサーでのみ可能な利点の一部を得る。

Answer 1

Google グループで私の答えを見つけました:

GroupByグループ化を実行するときに、どの定数がレデューサーを使用するかを使用します。

previousPipe = new GroupBy(previousPipe); //this does a Group on Fields.All

ファイル数の削減 (カップリングの少ない別の方法)

previousPipe = new GroupBy(previousPipe, new Fields("rand"), 
               new RandonNumGen(Fields.Args));

new RandonNumGen(Fields.Args) は、Function一時的な乱数を作成する新しい Fields("rand") を作成するために作成する関数です (一時的な意味は、後でフィールドを削除することを意味します)。

詳細については、このGoogle グループのスレッドを確認してください。