用hadoop api在hdfs中创建目录
时间: 2024-05-01 12:16:21 浏览: 101
使用hadoop api在hdfs中创建目录的代码示例如下:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HdfsCreateDir {
public static void main(String[] args) throws Exception {
// 创建配置对象
Configuration conf = new Configuration();
// 获取文件系统对象
FileSystem fs = FileSystem.get(conf);
// 创建目录
Path path = new Path("/user/hadoop/dir");
boolean isSuccess = fs.mkdirs(path);
if (isSuccess) {
System.out.println("目录创建成功!");
} else {
System.out.println("目录创建失败!");
}
// 关闭文件系统对象
fs.close();
}
}
```
运行该程序即可在hdfs中创建一个名为“dir”的目录。其中,需要注意以下几点:
1. 需要在代码中指定hadoop的配置文件路径,可以通过设置环境变量`HADOOP_CONF_DIR`或者在代码中调用`conf.addResource(new Path("hadoop配置文件路径"))`来指定;
2. 需要确保程序运行的用户对要创建的目录有写权限;
3. 需要在程序结束时关闭文件系统对象,以释放资源。
阅读全文