mapper_test1.py « streaming « hadoop - snippets - Various snippets for personal use

summary refs log tree commit diff

path: root/hadoop/streaming/mapper_test1.py

blob: 79c8aa644509663410583463a6ca3e8cdc140710 (plain)

#!/usr/bin/env python2

import sys


if __name__ == "__main__":
  for line in sys.stdin:
    print "MYKEY\t%s"%line.upper()