在spark java中另存为Parquet文件

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

public class SaveAsParquetExample {
    public static void main(String[] args) {
        // 创建SparkSession
        SparkSession spark = SparkSession.builder()
                .appName("SaveAsParquetExample")
                .getOrCreate();

        // 读取数据源
        Dataset<Row> sourceData = spark.read().format("csv").load("source.csv");

        // 对数据进行处理和转换
        Dataset<Row> processedData = sourceData.select("column1", "column2", "column3");

        // 将数据另存为Parquet文件
        processedData.write().parquet("output.parquet");

        // 关闭SparkSession
        spark.close();
    }
}