MapReduce是一种编程模型，用于处理和生成大数据集的并行算法，它由两个主要步骤组成：Map（映射）和Reduce（归约），下面是一个使用Python编写的简单MapReduce示例，用于计算文本中单词的出现次数。

1、Mapper函数

def mapper(text):
    words = text.split()
    word_count = {}
    for word in words:
        if word in word_count:
            word_count[word] += 1
        else:
            word_count[word] = 1
    return word_count

2、Reducer函数

from collections import defaultdict
def reducer(mapped_data):
    word_count = defaultdict(int)
    for data in mapped_data:
        for word, count in data.items():
            word_count[word] += count
    return dict(word_count)

3、MapReduce主函数

def map_reduce(texts):
    mapped_data = []
    for text in texts:
        mapped_data.append(mapper(text))
    reduced_data = reducer(mapped_data)
    return reduced_data

4、示例输入和输出

假设我们有以下文本列表：

texts = [
    "hello world",
    "hello python",
    "python is great",
    "hello again"
]

运行MapReduce函数：

result = map_reduce(texts)
print(result)

输出结果：

{'hello': 3, 'world': 1, 'python': 2, 'is': 1, 'great': 1, 'again': 1}

这个示例展示了如何使用MapReduce模型来计算文本中单词的出现次数，在实际应用中，MapReduce通常用于处理大量数据，例如分布式系统中的大规模数据处理任务。