レコードを整列して集計を行っていた処理はReduceタスクで処理することができます。以下の例では、マスタファイルを商品IDで整列した後、商品IDごとに個数を合計して、商品ごとの出荷数ファイルを出力しています。
図1.5 レコードの集計処理の例