利用HDFS JAVA API 完成创建Test1.java, 判断HDFS 上是否存在目录 /test,若存在此目录,先将它删除,再重新创建,若不存在,则直接创建此目录
时间: 2024-12-13 15:27:16 浏览: 3
在Java中,你可以使用Hadoop HDFS API来操作分布式文件系统(HDFS)。首先,你需要添加Hadoop的相关依赖到你的项目中。以下是一个简单的`Test1.java`示例,它会完成你描述的任务:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class Test1 {
public static void main(String[] args) throws Exception {
// 初始化HDFS配置
Configuration conf = new Configuration();
String hdfsUrl = "hdfs://your_hdfs_cluster_url"; // 替换为你的HDFS集群地址
FileSystem fs = FileSystem.get(conf);
// 检查目录是否存在
Path testDirPath = new Path("/test");
if (fs.exists(testDirPath)) {
System.out.println("Directory exists. Deleting it...");
// 删除目录
fs.delete(testDirPath, true); // recursive=true表示递归删除
}
// 如果不存在,则创建目录
if (!fs.exists(testDirPath)) {
System.out.println("Creating directory...");
fs.mkdirs(testDirPath);
}
// 关闭连接
fs.close();
System.out.println("Directory operation completed.");
}
}
```
阅读全文