如何使用Spark Cassandra连接器保存Java bean？

<dependency>
    <groupId>com.datastax.spark</groupId>
    <artifactId>spark-cassandra-connector_2.11</artifactId>
    <version>2.5.1</version>
</dependency>

import java.io.Serializable;

public class MyData implements Serializable {
    private String id;
    private String name;
    // 其他属性

    // 构造函数、getter和setter方法

    // toString方法
}

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", "localhost")
                .config("spark.cassandra.connection.port", "9042")
                .getOrCreate();

        // 其他Spark相关操作
    }
}

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

Dataset<MyData> myData = spark.createDataset(Arrays.asList(
        new MyData("1", "John"),
        new MyData("2", "Jane")), Encoders.bean(MyData.class));

Dataset<Row> myDataFrame = spark.createDataFrame(myData, MyData.class);

myDataFrame.write()
    .format("org.apache.spark.sql.cassandra")
    .option("keyspace", "mykeyspace")
    .option("table", "mytable")
    .mode("append")
    .save();