我希望我的MapReduce程序从标准输入流(System.in)中读取
例如,在run()方法中,如何使我的程序从System.in而不是像这样的文件中读取。FileInputFormat.addInputPath(job,new Path(“dummy.txt”));

另外我应该为job设置什么类。setInputFormat(...)

最佳答案

使用Hadoop流执行此操作:

http://wiki.apache.org/hadoop/HadoopStreaming

支持标准输入,标准输出

关于hadoop - 从标准输入流读取Hadoop,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/6840884/

10-11 04:52