为示例wordcount编写map和reduce

假设我们有一个文本文件，需要统计其中每个单词出现的次数，以下是map和reduce的示例代码：

Map函数：

def mapper(document):
    # 将文档中的每个单词拆分出来
    words = document.split()
    result = []
    for word in words:
        # 将每个单词作为key，value为1，发送给reduce函数进行聚合
        result.append((word, 1))
    return result

Reduce函数：

def reducer(word, counts):
    # 对于每个单词，将其出现次数进行累加
    return word, sum(counts)

在以上示例中，mapper函数将每个单词作为key，value为1发送给reducer函数进行聚合，而reducer函数则对于每个单词，对其出现次数进行累加并返回结果。最终得到的结果是每个单词及其出现次数的键值对。