[大数据]在IDEA中使用Hadoop的HDFS的API

1. 创建一个Maven项目
2. 配置依赖环境
3. 创建包和类

package com.atguigu.hdfs;

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

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

/**
 * 1.获取客户端对象
 * 2.执行相关命令操作
 * 3.关闭资源
 *
 * @author yijin
 * @create 2022-04-16-9:16 PM
 */
public class HdfsClient {
    private FileSystem fs;

    @Before
    public void init() throws URISyntaxException, IOException, InterruptedException {
        // 连接的集群nn地址
        URI uri = new URI("hdfs://hadoop102:8020");
        // 创建一个配置文件
        Configuration configuration = new Configuration();
        // 用户private
        String user = "atguigu";
        // 1.获取客户端对象
        fs = FileSystem.get(uri, configuration, user);

    }

    @After
    public void close() throws IOException {
        fs.close();

    }
    @Test
    public void testmkdir() throws URISyntaxException, IOException, InterruptedException {



        // 2.创建文件夹
        fs.mkdirs(new Path("/xiyou/huaguoshan1"));

        // 3.关闭资源



    }


}

创作挑战赛

新人创作奖励来咯，坚持创作打卡瓜分现金大奖