使用hdfs Java api在hdfs的/user/hadoop目录上创建一个目录test

在Hadoop分布式文件系统 (HDFS) 上使用Java API 创建目录，你需要先获取到Hadoop FileSystem的实例，然后调用其`mkdirs()`方法。下面是一个简单的示例，假设你已经设置了Hadoop环境变量和配置：

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

public class HdfsCreateDirectory {
    public static void main(String[] args) throws Exception {
        // 初始化HDFS配置
        Configuration conf = new Configuration();
        
        // 设置HDFS地址（默认通常为localhost:9000）
        String hdfsUrl = "hdfs://localhost:9000";
        Path dirPath = new Path("/user/hadoop/test");

        // 创建FileSystem实例
        FileSystem fs = FileSystem.get(conf);

        // 在/user/hadoop目录下创建test目录
        if (!fs.exists(dirPath)) {
            boolean success = fs.mkdirs(dirPath);
            if (success) {
                System.out.println("Directory created successfully at: " + dirPath.toUri());
            } else {
                System.err.println("Failed to create directory: " + dirPath.toUri());
            }
        } else {
            System.out.println("Directory already exists at: " + dirPath.toUri());
        }

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

在这个例子中，如果目录不存在，它会尝试创建；如果目录已存在，则直接返回。