pip install dumbo 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) [python] env=/usr/bin/python3 dumbo start <hadoop_jar> <python_file> [-c <config_file>] [other_arguments]