0

私の減速機:

public static class CustomReducer extends Reducer<Int256Writable, ByteWritable, IntWritable, Int256Writable>

結果の IntWritable が > 1 であるかどうかに基づいて、Hadoop の出力をフィルタリングして、条件が適用される出力にすべての KV ペアが書き込まれないようにします。

今までは単純な TextOutputFormat を使用していましたが、近々バイナリに変更する予定です。

出力する前に KV ペアをフィルタリングするにはどうすればよいですか?

4

1 に答える 1