HDFSAPI编程源码-java创建文件夹

1. package hdfsapi;
2. 
3. import java.io.IOException;
4. import java.net.URI;
5. 
6. import org.apache.hadoop.conf.Configuration;
7. import org.apache.hadoop.fs.FileSystem;
8. import org.apache.hadoop.fs.Path;
9. 
10. public class E2_MkdirsAPI {
11. 
12.   public static void main(String[] args) throws IOException, InterruptedException {
13.     //获取配置
14.     Configuration conf = new Configuration();
15.     //获得文件系统对象，由于只有root用户才有写权限，因此用root用户去获取文件系统对象
16.     FileSystem fs = FileSystem.get(URI.create("hdfs://master:8020"), conf, "root");
17.     //创建文件夹
18.     fs.mkdirs(new Path("/user/root/mytest"));
19.     System.out.println("mkdir OK!");
20.     fs.close();
21.   }
22. }