使用 Java API 在 HDFS 上创建文件并写入内容

可以使用以下代码在 HDFS 上创建文件并写入内容：

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.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;

public class HDFSFileWriter {
    public static void main(String[] args) throws IOException {
        Configuration conf = new Configuration();
        conf.set("fs.defaultFS", "hdfs://localhost:9000"); // HDFS 地址
        FileSystem fs = FileSystem.get(conf);

        Path file = new Path("/path/to/newfile.txt");
        if (fs.exists(file)) {
            System.out.println("File already exists");
            return;
        }

        OutputStream os = fs.create(file);
        BufferedWriter br = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));
        br.write("Hello, World!");
        br.newLine();
        br.write("This is a new file on HDFS.");
        br.close();
        fs.close();
    }
}

这个程序首先指定了 HDFS 的地址，然后创建了一个新的文件，并将数据写入该文件。注意，这个程序需要 Hadoop 的依赖库才能运行。