标签：hdfs Configuration java 创建 FileSystem hadoop fileSystem new configuration

前言

api文档
为了方便，我先在test下新建

文件编写

创建文件

编写文件

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

import java.io.IOException;

public class HdfsOperate {
    /**
     * 创建目录
     */
    @Test
    public void mkDirOnHdfs() throws IOException {
        // configuration
        Configuration configuration = new Configuration();
        // 设置namenode
        configuration.set("fs.defaultFS","hdfs://node001:8020");
        // filesystem
        FileSystem fileSystem = FileSystem.get(configuration);
        // 通过filesystem对象创建目录
        boolean ans = fileSystem.mkdirs(new Path("/sjj/test"));
        System.out.println("创建结果："+ans);
        // 释放资源
        fileSystem.close();
    }
}

    @Test
    public void mkDirOnHdfs_2() throws IOException, URISyntaxException, InterruptedException {
        // configuration
        Configuration configuration = new Configuration();
        // filesystem
        FileSystem fileSystem = FileSystem.get(new URI("hdfs://node001:8020"), configuration, "sjj");
        // 通过filesystem对象创建目录
        boolean ans = fileSystem.mkdirs(new Path("/sjj/test_2"));
        System.out.println("创建结果："+ans);
        // 释放资源
        fileSystem.close();
    }

运行文件

运行文件之前确保你的hadoop集群是打开的

创建目录时指定权限

    // 创建目录时指定权限
    @Test
    public void mkDirOnHdfs_3() throws IOException, URISyntaxException, InterruptedException {
        // configuration
        Configuration configuration = new Configuration();
        // filesystem对象、设置namenode
        FileSystem fileSystem = FileSystem.get(new URI("hdfs://node001:8020"), configuration, "sjj");
        // 设置权限(当前用户拥有读写权限，当前用户组其它用户拥有读权限，其它用户组用户拥有读权限)
        FsPermission fsPermission = new FsPermission(FsAction.READ_WRITE, FsAction.READ, FsAction.READ);
        // 通过filesystem对象创建目录
        boolean ans = fileSystem.mkdirs(new Path("/sjj/test_3"),fsPermission);
        System.out.println("创建结果："+ans);
        // 释放资源
        fileSystem.close();
    }

标签：hdfs,Configuration,java,创建,FileSystem,hadoop,fileSystem,new,configuration
来源： https://www.cnblogs.com/S2Jgogo/p/15919584.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。