Hadoop建立(上傳)檔案
阿新 • • 發佈:2018-12-27
1、本地建立檔案(shell)
備註:
1) 該檔案第一行有誤,故此報錯(command not found),應該是:#my first shell test
2) shell的 if 語法比較坑,不像java中可以隨意換行
2、上傳到Hadoop
將本地檔案myfirst.sh上傳到已建立的hadoop目錄中
/**
* 本地檔案上傳到hadoop目錄
*/
public void upload(){
String srcFile = "/home/cent/Desktop/myfirst.sh";
String dstFile = "/user/test" ;
try {
fs.copyFromLocalFile(new Path(srcFile), new Path(dstFile));
} catch (IllegalArgumentException e) {
e.printStackTrace();
} catch (IOException e) {
System.out.println("-- IOException --");
e.printStackTrace();
}
}
3、執行、檢視結果
首先在eclipse執行測試類;然後在Terminal中檢視hadoop目錄檔案
hadoop fs -ls /user/test