キーに基づいてレデューサー出力を複数のファイルに送信することは可能ですか? お気に入り、
if(key1)
{
//output to file1 using context.write() or otherwise
}
else
{
//output to file2 using context.write() or otherwise
}
別の可能なアプローチは、カスタムPartitionerを実装することです。このようにして、キーの値に基づいて 2 つの (複数の) レデューサーを実行し、それに応じて分割することができます。