Apache Spark + cassandra+Java +Spark session显示所有记录

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
        SparkSession spark = SparkSession.builder()
                .appName("Spark Cassandra Example")
                .config("spark.cassandra.connection.host", "cassandra_host")
                .config("spark.cassandra.connection.port", "cassandra_port")
                .getOrCreate();

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

        // 显示所有记录
        dataset.show();

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