2013-03-04 43 views
2

我Hadoop的DFS通過如何通過URL訪問Hadoop的HDFS,並在程序中使用

http://localhost:50075/browseDirectory.jsp?dir=%2Fuser%2Fhdone%2Ftext&namenodeInfoPort=50070

在我的計劃是訪問我不得不更換參考輸入到我的HDFS

FileInputFormat.addInputPath(conf, new Path("input"));

我的core-site.xml的值爲 hdfs://localhost:54310我無法使用URL訪問。

我的實際hdfs路徑是/users/hdone/text2其中所有文件都位於適當的權限。

那我該怎麼寫input

+0

你可以嘗試更改端口t 9000並檢查?所以它會是'hdfs:// localhost:9000/users/hdone/text2' – aa8y 2013-03-04 06:49:23

回答

2

你應該給出你的輸入的dfs相對路徑,它應該被正確讀取。

例如,您如下創建輸入路徑:現在

$ hadoop fs -mkdir my_input_directory 
$ hadoop fs -put /home/user/my-test-file.csv my_input_directory/my-test-file.csv 

,以運行Hadoop的工作,你可以像執行如下的內容:

$ hadoop jar my_test_program.jar **my_input_directory** my_output_directory 

而在你的Java代碼,你可以通過args[0]訪問它,像這樣:

FileInputFormat.addInputPath(conf, new Path(args[0])); 
相關問題