使用HDFS api操作创建/user/briup/test2目录
时间: 2023-08-02 15:10:38 浏览: 143
可以使用以下Java代码创建HDFS上的/user/briup/test2目录:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
public class HDFSMakeDir {
public static void main(String[] args) throws IOException, URISyntaxException {
// 创建Configuration对象,用于加载Hadoop配置文件
Configuration conf = new Configuration();
// 指定HDFS的地址
URI uri = new URI("hdfs://localhost:9000");
// 创建FileSystem对象,用于操作HDFS
FileSystem fs = FileSystem.get(uri, conf);
// 指定HDFS目录路径
Path hdfsPath = new Path("/user/briup/test2");
// 使用FileSystem对象创建HDFS目录
fs.mkdirs(hdfsPath);
// 关闭FileSystem对象
fs.close();
System.out.println("目录创建成功!");
}
}
```
需要注意的是,上述代码中的HDFS地址是本地单机模式下的地址,如果你的Hadoop集群是分布式的,需要将HDFS地址改为集群中的地址。
阅读全文