上传文件到HDFS

上传文件到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