如何在spark streaming测试中使用spark cassandra连接器模拟cassandra的数据？

<dependency>
    <groupId>com.datastax.spark</groupId>
    <artifactId>spark-cassandra-connector_2.11</artifactId>
    <version>2.5.1</version>
</dependency>
<dependency>
    <groupId>com.datastax.spark</groupId>
    <artifactId>spark-cassandra-connector-java_2.11</artifactId>
    <version>2.5.1</version>
</dependency>
<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>cassandra-driver-core</artifactId>
    <version>3.11.0</version>
</dependency>

SparkConf conf = new SparkConf()
    .setAppName("Spark Streaming with Cassandra")
    .setMaster("local[*]")
    .set("spark.cassandra.connection.host", "localhost")
    .set("spark.cassandra.connection.port", "9042")
    .set("spark.cassandra.auth.username", "your_username")
    .set("spark.cassandra.auth.password", "your_password");

StreamingContext streamingContext = new StreamingContext(conf, Durations.seconds(1));

JavaDStream<CassandraRow> cassandraDStream = CassandraStreamingJavaUtil
    .javaFunctions(streamingContext)
    .cassandraTable("keyspace", "table");

cassandraDStream.foreachRDD(rdd -> {
    rdd.foreach(row -> System.out.println(row));
});

streamingContext.start();
streamingContext.awaitTermination();