Added an hadoop streaming example

python/MapReduce/HadoopStreaming/mapper.py

@@ -0,0 +1,8 @@
+#!/usr/bin/python
+import sys
+
+for line in sys.stdin:
+   words = line.split()
+
+   for word in words:
+      print '{0}\t{1}'.format(word, 1)

python/MapReduce/HadoopStreaming/reducer.py

@@ -0,0 +1,21 @@
+#!/usr/bin/python
+import sys
+
+curr_word = None
+curr_count = 0
+
+for line in sys.stdin:
+   word, count = line.split('\t')
+
+   count = int(count)
+
+   if word == curr_word:
+      curr_count += count
+   else: 
+      if curr_word:
+         print '{0}\t{1}'.format(curr_word, curr_count)
+
+      curr_count = count
+      curr_word = word
+
+print '{0}\t{1}'.format(curr_word, curr_count)