java连接hdfs创建目录示例

在Java中，我们可以使用Hadoop的API，特别是`org.apache.hadoop.fs.FileSystem`和`org.apache.hadoop.conf.Configuration`，来连接HDFS并创建目录。下面是一个简单的示例：

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

public class HdfsCreateDirectoryExample {
    public static void main(String[] args) throws Exception {
        // 创建配置对象
        Configuration conf = new Configuration();
        
        // 设置HDFS地址（通常是在集群环境中的名称节点地址）
        String hdfsUrl = "hdfs://your_cluster_name:9000"; // 替换为你实际的HDFS URL
        conf.set("fs.defaultFS", hdfsUrl);

        // 连接到HDFS
        FileSystem fs = FileSystem.get(conf);

        // 定义要在HDFS上创建的目录路径
        Path directoryPath = new Path("/path/to/your/directory");

        // 检查目录是否存在，如果不存在则创建
        if (!fs.exists(directoryPath)) {
            boolean created = fs.mkdirs(directoryPath);
            if (created) {
                System.out.println("Directory " + directoryPath + " created successfully.");
            } else {
                System.err.println("Failed to create directory " + directoryPath);
            }
        } else {
            System.out.println(directoryPath + " already exists.");
        }

        // 关闭FileSystem连接
        fs.close();
    }
}