首页使用HDFS JavaAPI在HDFS的/user/hadoop目录上创建一个目录test

使用HDFS JavaAPI在HDFS的/user/hadoop目录上创建一个目录test

时间: 2024-12-15 10:22:33 浏览: 54

在HDFS上使用Java API创建目录，你可以使用`org.apache.hadoop.fs.FileSystem`和`org.apache.hadoop.fs.Path`这两个核心类。首先，你需要通过`FileSystem.get()`获取到HDFS文件系统实例，然后使用`mkdirs()`方法创建目录。以下是一个简单的示例： ```java import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; public class HdfsDirectoryCreation { public static void main(String[] args) throws Exception { // 创建配置对象 Configuration conf = new Configuration(); // 设置HDFS地址（如果你的Hadoop集群在本地运行，可以省略） String hdfsUrl = "hdfs://localhost:9000"; // 如果在远程Hadoop，替换为实际URL FileSystem fs = FileSystem.get(conf); // 指定要创建的路径，这里是在/user/hadoop/test目录下 Path directoryPath = new Path("/user/hadoop/test"); // 调用mkdirs()方法创建目录，如果不存在则会自动创建 boolean success = fs.mkdirs(directoryPath); if (success) { System.out.println("Directory created successfully."); } else { System.out.println("Failed to create the directory."); } // 关闭文件系统连接 fs.close(); } } ```

阅读全文