第1关:使用 java api 在 hdfs 上创建目录
时间: 2023-09-03 14:04:39 浏览: 632
熟练掌握HDFS的Java API接口访问
在HDFS上创建目录可以使用Java API进行操作。下面是一个示例代码:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class CreateDirectory {
public static void main(String[] args) {
String hdfsUri = "hdfs://localhost:9000"; // HDFS的地址
String directoryPath = "/user/mydirectory"; // 需要创建的目录路径
try {
// 创建一个配置对象
Configuration conf = new Configuration();
conf.set("fs.defaultFS", hdfsUri);
// 根据配置对象创建一个文件系统实例
FileSystem fs = FileSystem.get(conf);
// 创建目录
boolean success = fs.mkdirs(new Path(directoryPath));
if (success) {
System.out.println("目录创建成功!");
} else {
System.out.println("目录创建失败!");
}
// 关闭文件系统连接
fs.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
以上代码中,首先通过设置配置对象来指定HDFS的地址,然后根据配置对象创建一个文件系统实例。接着调用`mkdirs`方法创建目录,并根据返回值判断目录创建是否成功。
需要注意的是,为了运行该代码,需要事先配置好Hadoop和相关的依赖。
阅读全文