用Java语言编写DataFrame到Cassandra表

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

public class DataFrameToCassandra {
    public static void main(String[] args) {
        // 创建SparkSession
        SparkSession spark = SparkSession.builder()
                .appName("DataFrameToCassandra")
                .config("spark.cassandra.connection.host", "cassandra_host")
                .config("spark.cassandra.connection.port", "cassandra_port")
                .getOrCreate();

        // 读取DataFrame数据
        Dataset<Row> dataFrame = spark.read()
                .format("csv")
                .option("header", "true")
                .load("data.csv");

        // 将DataFrame数据写入Cassandra表
        dataFrame.write()
                .format("org.apache.spark.sql.cassandra")
                .option("keyspace", "keyspace_name")
                .option("table", "table_name")
                .mode("append")
                .save();

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