reducer.py

gistfile1.txt

import sys

def reducer():
  sales_total = 0
  old_key = None

  for line in sys.stdin:
    data = line.strip().split("\t")
    if len(data) !=2
      continue
    key, sales = data
    if (key and key != old_key):
      print "{0}\t{1}".format(old_key, sales_total)
      sales_total = 0
      old_key = key
    sales_total += float(sales)
  print "{0}\t{1}".format(key, sales_total)