python from tehuti import MapReduce class WordCountMapper(MapReduce.Mapper): def map(self, key, value): words = value.split() for word in words: self.emit_intermediate(word, 1) class WordCountReducer(MapReduce.Reducer): def reduce(self, key, values): count = sum(values) self.emit(key, count) if __name__ == '__main__': job = MapReduce.Job(input_data, output_data) job.set_mapper(WordCountMapper) job.set_reducer(WordCountReducer) job.run()