資源簡介
上傳文件到HDFS的java代碼實現。已經測試了,可以直接運行。

代碼片段和文件信息
import?java.io.IOException;
import?org.apache.hadoop.conf.Configuration;
import?org.apache.hadoop.fs.FileStatus;
import?org.apache.hadoop.fs.FileSystem;
import?org.apache.hadoop.fs.Path;
public?class?UploadFile?{
public?static?void?main(String[]?args)?throws?IOException?{
Configuration?conf?=?new?Configuration();
//conf.addResource(new?Path(“conf/hadoop-default.xml“));
//conf.addResource(new?Path(“conf/hadoop-site.xml“));
//通過conf來指定要操作的HDFS
FileSystem?hdfs?=?FileSystem.get(conf);
//要上傳的源文件所在路徑
Path?src?=?new?Path(“D:\\v.txt“);
//hadoop文件系統的跟目錄
Path?dst?=?new?Path(“/“);
//將源文件copy到hadoop文件系統
hdfs.copyFromLocalFile(src?dst);
System.out.println(“上傳到“+conf.get(“fs.default.name“));
FileStatus?files[]?=?hdfs.listStatus(dst);
for(int?i=0;i {
System.out.println(files[i].getPath());
}
}
}
?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件????????454??2015-10-30?19:32??HDFSAPITest\.classpath
?????文件????????387??2015-10-30?19:11??HDFSAPITest\.project
?????文件????????598??2015-10-30?19:30??HDFSAPITest\.settings\org.eclipse.jdt.core.prefs
?????文件???????1717??2015-10-30?19:40??HDFSAPITest\bin\UploadFile.class
?????文件??????52915??2015-10-30?19:32??HDFSAPITest\commons-logging.jar
?????文件????2689741??2015-10-30?19:20??HDFSAPITest\hadoop-0.20.2-core.jar
?????文件????????916??2015-10-30?19:40??HDFSAPITest\src\UploadFile.java
?????目錄??????????0??2015-10-30?19:42??HDFSAPITest\.settings
?????目錄??????????0??2015-10-30?19:42??HDFSAPITest\bin
?????目錄??????????0??2015-10-30?19:42??HDFSAPITest\src
?????目錄??????????0??2015-10-30?19:42??HDFSAPITest
-----------?---------??----------?-----??----
??????????????2746728????????????????????11
評論
共有 條評論