私の減速機:
public static class CustomReducer extends Reducer<Int256Writable, ByteWritable, IntWritable, Int256Writable>
結果の IntWritable が > 1 であるかどうかに基づいて、Hadoop の出力をフィルタリングして、条件が適用される出力にすべての KV ペアが書き込まれないようにします。
今までは単純な TextOutputFormat を使用していましたが、近々バイナリに変更する予定です。
出力する前に KV ペアをフィルタリングするにはどうすればよいですか?