我的hadoop dfs可以通过 http://localhost:50075/browseDirectory.jsp?dir=%2Fuser%2Fhdone%2Ftext&namenodeInfoPort=50070
在我的程序中,我必须用我的hdfs替换输入 FileInputFormat.addInputPath(conf, new Path("input"));
my core-site.xml具有 hdfs://localhost:54310
我无法使用url访问。
我实际的hdfs路径是 /users/hdone/text2
所有文件都位于具有适当权限的位置。
那我写什么呢 input
?
1条答案
按热度按时间raogr8fs1#
您只需给出dfs与输入的相对路径,就可以正确读取。
例如,您正在创建一个输入路径,如下所示:
现在,为了运行hadoop作业,可以执行如下操作:
在java代码中,您可以通过
args[0]
,如下所示: