如何将csv映射bean类传递给Dataset

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

public class CSVToDatasetExample {
    public static void main(String[] args) {
        // 创建SparkSession
        SparkSession spark = SparkSession.builder()
                .appName("CSV to Dataset Example")
                .master("local")
                .getOrCreate();

        // 读取CSV文件内容
        Dataset<String> csvData = spark.read().textFile("path/to/csv/file.csv");

        // 将CSV数据映射为Bean类
        Dataset<BeanClass> dataset = csvData.map(line -> {
            String[] fields = line.split(","); // 假设CSV文件以逗号分隔
            BeanClass bean = new BeanClass();
            bean.setField1(fields[0]); // 设置Bean类的属性值
            bean.setField2(fields[1]);
            // ...
            return bean;
        }, Encoders.bean(BeanClass.class));

        // 打印Dataset内容
        dataset.show();

        // 其他数据处理操作...
    }
}

// BeanClass定义
class BeanClass {
    private String field1;
    private String field2;
    // ...

    // getter和setter方法
}