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


上一篇:
下一篇:
切换中文