使用 Java API 在 HDFS 上创建文件并写入内容
时间: 2024-05-02 13:21:32 浏览: 17
以下是使用 Java API 在 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 HdfsWriter {
public static void main(String[] args) throws Exception {
String uri = "hdfs://localhost:9000";
Configuration conf = new Configuration();
FileSystem fs = FileSystem.get(conf);
Path path = new Path("/example.txt");
OutputStream os = fs.create(path);
BufferedWriter br = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));
String content = "Hello, World!";
br.write(content);
br.close();
fs.close();
}
}
```
在此示例代码中,我们使用 Hadoop 的 Configuration 类和 FileSystem 类来建立与 HDFS 的连接。我们创建了一个名为 /example.txt 的新文件,并使用 BufferedWriter 类将文本内容写入文件中。最后,我们关闭 BufferedWriter 和 FileSystem。