如何使用spark Dataset将cassandra的set<text>字段映射到java中的POJO

import java.util.Set;

public class MyPojo {
    private Set<String> mySetField;

    public Set<String> getMySetField() {
        return mySetField;
    }

    public void setMySetField(Set<String> mySetField) {
        this.mySetField = mySetField;
    }
}

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

public class SparkCassandraExample {
    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder()
                .appName("Spark Cassandra Example")
                .config("spark.cassandra.connection.host", "your_cassandra_host")
                .config("spark.cassandra.connection.port", "your_cassandra_port")
                .getOrCreate();

        // 读取Cassandra表中的数据
        Dataset<Row> cassandraData = spark.read()
                .format("org.apache.spark.sql.cassandra")
                .option("keyspace", "your_keyspace")
                .option("table", "your_table")
                .load();

        // 将数据映射到POJO对象
        Dataset<MyPojo> myPojoData = cassandraData.as(Encoders.bean(MyPojo.class));

        // 打印数据
        myPojoData.show();

        spark.stop();
    }
}