java 使用hdfs存储文件
时间: 2023-09-04 18:15:49 浏览: 121
Java 可以使用 Hadoop 提供的 HDFS API 来访问和操作 HDFS 上的文件。下面是一个简单的示例程序来演示如何在 HDFS 上存储一个文本文件:
```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import java.io.BufferedWriter;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
public class HDFSFileWriter {
public static void main(String[] args) throws Exception {
String uri = "hdfs://localhost:9000/user/hadoop/test.txt";
Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);
OutputStream os = fs.create(new Path(uri));
BufferedWriter br = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));
br.write("Hello, world!");
br.close();
fs.close();
}
}
```
这个程序会在 HDFS 的 `/user/hadoop/test.txt` 路径下创建一个文件,并向其中写入了一个字符串 "Hello, world!"。在运行程序之前,确保 Hadoop 集群已经启动并且 HDFS 服务可用。
阅读全文