使用 Java API 在 HDFS 上创建/user/hadoop/test目录
时间: 2023-10-29 10:06:08 浏览: 175
可以使用以下代码在 HDFS 上创建/user/hadoop/test目录:
```
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 {
// 创建配置对象
Configuration conf = new Configuration();
// 获取文件系统对象
FileSystem fs = FileSystem.get(conf);
// 创建目录
Path path = new Path("/user/hadoop/test");
boolean success = fs.mkdirs(path);
if (success) {
System.out.println("目录创建成功!");
} else {
System.out.println("目录创建失败!");
}
// 关闭文件系统对象
fs.close();
}
}
```
在执行代码之前,需要保证 Hadoop 集群已经启动,并且配置文件正确。如果需要指定 NameNode 的地址,可以在配置对象中设置:
```
conf.set("fs.defaultFS", "hdfs://namenode:9000");
```
其中,namenode:9000 是 NameNode 的地址和端口号。如果使用默认端口号,可以省略端口号部分。