Question

python编写mapreduce如何输入输出

看了python编的wordcount程序，输入和输出用的是sys.stdin和sys.stdout，适用于文本文件，若读取csv文件，是否适用？

Answer 1

使用python写MapReduce的“诀窍”是利用Hadoop流的API，通过STDIN(标准输入)、STDOUT(标准输出)在Map函数和Reduce函数之间传递数据。
我们唯一需要做的是利用Python的sys.stdin读取输入数据，并把我们的输出传送给sys.stdout。Hadoop流将会帮助我们处理别的任何事情。