Python中MapReduce实战
发布时间
阅读量：
阅读量
python中MapReduce实战代码演示
采用PyCharm开发工具，并配置Anaconda运行环境。创建一个新的Python文件，命名为命名为map.py。以下为具体实现代码
"""
wordcount单词统计
map阶段
"""
import sys
def map():
for line in sys.stdin: # 从标准输入里面读取的，是一个字符串格式
words = line.split("\t")
for word in words:
print("\t".join([word.strip(), "1"]))
if __name__ == "__main__":
map()
再次创建一个新的python.file文件，[命名为reduce.py](http://xn--reduce-vy7ir11
全部评论 (0)
还没有任何评论哟~