CreateFile

---

---

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

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
/***
 * 注意：文件創建時，可能會報Permission denied錯誤，其中一個解決辦法是
給要寫入的文件所在目錄增加其他人寫的權限， 在Linix下輸入命令 $ hdfs dfs -chmod o+w /user/ud16
 * @author 
 *
 */

public class CreateFile {

    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");
           //get()的第三個參數"hadoop"為Linux的用戶名，注意修改
           FileSystem fs=FileSystem.get(uri,conf,"hadoop");
           //定義一個要創建文件的路徑
           Path dfs=new Path("/user/hadoop/myfile1");
           FSDataOutputStream newFile=fs.create(dfs,true);
           //寫入的內容
           newFile.writeBytes("20160216048 raodi");

    }

}