我希望我的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/