上传本地文件到HDFS

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<files.length;i++)
{
System.out.println(files[i].getPath());
}
}
}