Simple Map Reduce Example

mapmywords.py

from collections import Counter
import re
from functools import reduce

def reduce_line(line):
    words = re.findall('\w+',line.lower())
    return Counter(words)

maps = map(reduce_line, open('time_machine.txt').readlines())
z = reduce(lambda x,y: x+y, maps)
print(z)