如何在Spark Java中使用StructType模式从JavaRDD<String>中读取csv格式的数据

import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.*;
import org.apache.spark.sql.types.*;

SparkConf conf = new SparkConf().setAppName("CSVReader").setMaster("local");
JavaSparkContext sc = new JavaSparkContext(conf);

SparkSession spark = SparkSession.builder().config(conf).getOrCreate();

StructType schema = new StructType()
    .add("column1", DataTypes.StringType)
    .add("column2", DataTypes.IntegerType)
    .add("column3", DataTypes.DoubleType);

JavaRDD<String> csvData = sc.textFile("path/to/csv/file.csv");

Dataset<Row> csvDataFrame = spark.read()
    .option("header", "true")
    .schema(schema)
    .csv(csvData);

csvDataFrame.show();  // 显示DataFrame的内容
csvDataFrame.printSchema();  // 打印DataFrame的结构
// 其他DataFrame操作和分析