在java中使用Apache-Spark在Dataset<Row>中使用空字符串填充空值

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
import org.apache.spark.sql.functions;

SparkSession spark = SparkSession.builder()
        .appName("Java Spark Example")
        .config("spark.master", "local")
        .getOrCreate();

Dataset<Row> dataset = spark.read().format("csv")
        .option("header", "true")
        .load("path/to/input/file.csv");

Dataset<Row> filledDataset = dataset.na().fill("");

filledDataset.write().format("csv")
        .option("header", "true")
        .save("path/to/output/file.csv");