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