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 * */ } }