UploadFile




import org.apache.hadoop.conf.*;
import org.apache.hadoop.fs.*;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
public class UploadFile {

    public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
        Configuration conf=new Configuration();
           //注意修改为自己的IP
           URI uri=new URI("hdfs://192.168.1.100:9000");
           FileSystem fs=FileSystem.get(uri,conf,"hadoop");
           //local file
          //Path:要上传文件的路径,如果是在windows下的eclipse写程序,本地文件(src)应该写windows系统下的文件路径,如果是在Linux下的eclipse编程,本地文件(src)应该写Linux系统下的文件路径
           Path src=new Path("C:\\Users\\Raodi\\Desktop\\BCtest\\hadoop-2.7.6-src\\hadoop-2.7.6-src.zip");//这里写的是Windows系统下的文件路径,注意按实际修改。
           //HDFS file                                
           //上传到目的地路径,可以自定义 
           Path dst=new Path("/user/hadoop/");
           fs.copyFromLocalFile(src,dst);
           /**
            * /user/hadoop/              文件上传到/user/hadoop目录下
            * /user/hadoop/UploadFile    文件上传到/user/hadoop目录下并改名UploadFile
            * 
            */

    }

}


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM