hadoop hdfs api 测试代码
时间: 2023-07-06 08:37:29 浏览: 105
以下是一个简单的 HDFS API 测试代码,可以用来操作 HDFS 文件系统:
```
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HdfsApiTest {
private static final String HDFS_URI = "hdfs://localhost:9000";
private static final String FILE_PATH = "/test.txt";
private static final String CONTENT = "Hello, Hadoop!";
public static void main(String[] args) {
try {
// 获取 Hadoop 配置对象
Configuration conf = new Configuration();
// 获取 HDFS 文件系统对象
FileSystem fs = FileSystem.get(URI.create(HDFS_URI), conf);
// 创建文件路径对象
Path filePath = new Path(FILE_PATH);
// 判断文件是否存在
if (fs.exists(filePath)) {
System.out.println("文件已经存在,删除文件...");
fs
阅读全文