使用 Java API 操作 HDFS,并创建一个 /user/hadoop/test 目录。
时间: 2023-12-30 21:05:07 浏览: 50
以下是使用 Java API 操作 HDFS 并创建 /user/hadoop/test 目录的示例代码:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HdfsExample {
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
conf.set("fs.defaultFS", "hdfs://localhost:9000"); // 设置 HDFS 地址
FileSystem fs = FileSystem.get(conf); // 获取 HDFS 文件系统对象
Path path = new Path("/user/hadoop/test");
if (!fs.exists(path)) { // 判断目录是否存在
fs.mkdirs(path); // 创建目录
System.out.println("创建目录成功:" + path);
} else {
System.out.println("目录已存在:" + path);
}
fs.close(); // 关闭文件系统对象
}
}
```
注意:需要添加 Hadoop 依赖包到项目中。