Напишите PairDStram для casssandra, используя Datastax Spark Cassandra Connector

Question

Мне нужно записать данные моего потока фильтров в casssandra с помощью Java и Datastax Spark Cassandra Connector.

Я следовал за datastax java documentation.

В документации объясняется, как написать RDD в cassandra, но не как написать Dstream.

Мне нужно сохранить PairDStream, и я не знаю, как это сделать, потому что все примеры написаны на 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 к Кассандре, необходимо импортировать:

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

и использовать javaFunctions(DStream<T> arg0) или javaFunctions(JavaDStream<T> arg0)