使用 Java API 在 HDFS 上创建目录

以下是使用 Java API 在 HDFS 上创建目录的示例代码：

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

public class CreateDirectory {
    public static void main(String[] args) throws Exception {
        // 创建 Hadoop 配置对象
        Configuration conf = new Configuration();
        // 获取 HDFS 文件系统对象
        FileSystem fs = FileSystem.get(conf);
        // 定义要创建的目录路径
        Path dirPath = new Path("/test");
        // 创建目录
        boolean success = fs.mkdirs(dirPath);
        // 输出创建结果
        if (success) {
            System.out.println("创建目录成功！");
        } else {
            System.out.println("创建目录失败！");
        }
        // 关闭文件系统对象
        fs.close();
    }
}

在上面的示例代码中，首先创建了一个 `Configuration` 对象，该对象包含了 Hadoop 集群的配置信息。然后通过 `FileSystem.get(conf)` 方法获取了一个 HDFS 文件系统对象。接着定义了要创建的目录路径，并调用 `fs.mkdirs(dirPath)` 方法创建目录。最后根据创建结果输出相应的信息，并关闭文件系统对象。