java - 使用 Datastax Spark Cassandra 连接器将 PairDStram 写入 cassandra

Question

我需要使用 Java 和 Datastax Spark Cassandra Connector 将过滤流的数据写入 cassandra。

我关注了 datastax java documentation .

文档解释了如何将 RDD 写入 cassandra，但没有说明如何写入 Dstream。

我需要能够保存一个 PairDStream，但我不知道该怎么做，因为所有示例都是用 scala 编写的。

我需要把下面用scala写的代码转成java的代码:

val wc = stream.flatMap(_.split("\\s+"))
    .map(x => (x, 1))
    .reduceByKey(_ + _)
    .saveToCassandra("streaming_test", "words", SomeColumns("word", "count")) 

基本上我必须保存一个JavaPairDStream<String, Integer>

Answer 1

解决方案，以防万一有人在寻找答案

要将DStream或JavaDStream写入Cassandra，需要导入:

import static com.datastax.spark.connector.japi.CassandraStreamingJavaUtil.*;

并使用javaFunctions(DStream<T> arg0)或 javaFunctions(JavaDStream<T> arg0)