python
import dumbo
python
def mapper(key, value):
for word in value.split():
yield word, 1
def reducer(key, values):
yield key, sum(values)
python
if __name__ == "__main__":
dumbo.run(mapper, reducer)
bash
$ dumbo start word_count.py -hadoop /path/to/hadoop
python
import dumbo
def mapper(key, value):
for word in value.split():
yield word, 1
def reducer(key, values):
yield key, sum(values)
if __name__ == "__main__":
dumbo.run(mapper, reducer)
bash
$ dumbo start word_count.py -hadoop /path/to/hadoop