map.py for lines in sys.stdin: try: decoded = json.loads(lines) id = values[0] genkey = values[2] value = values[4] for v in value: try: indexV = statment.index(str(v)) values[indexV] = 1 except: pass #print out the information we need print '%s-%s\t%s' % (id, genkey, values) except: passand my reducer.pyfor line in sys.stdin: try: keys, display = line.split('\t', 1) values = literal_eval(display) put = "" if current_keys == keys: pass else: if current_keys: for key in current_values: put += str(key) put += ',' print '%s' % put current_keys = keys current_values = values except: passif current_keys == keys: put = "" for key in current_values: put += str(key) outputString += ',' print '%s' % put