hadoop創建目錄

package com.hadoop.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;

public class Client {
    public static void main(String[] args) throws IOException {
        Configuration conf=new Configuration();
        conf.set("fs.defaultFS","hdfs://localhost:9000");

        //修改用戶方法
        //1.vm arguments中添加后面的參數來修改用戶 -DHADOOP_USER_NAME=hadoop
        //2. conf.set使用重載方法修改用戶

        //1.獲取hdfs客戶端對象
        FileSystem fs=FileSystem.get(conf);

        //2.在hdfs上創建路徑
        fs.mkdirs(new Path("/hadoop/example/xy1"));

        //3.關閉資源
        fs.close();

        System.out.println("over");
    }
}