JavaPairRDDをCassandraに保存

Question

Sparkで作成したJavaPairRDDをCassandraに配置しようとしています。 JavaRDDの例はたくさんありますが、PairRDDの例はあまりありません。

マイJavaPairRDDは次のようになります。

JavaPairRDD<String, List<Tuple<String, Long>>> pairs 

そして、私は次のように定義された列とカサンドラ表に保存しようとしています：

name TEXT PRIMARY KEY, 
list LIST<TUPLE<STRING, LONG>> 

私はおそらくjavaFunctionsを使用する必要があります知っていますしかし、私は構文についてはわかりませんし、RowWriterFactoryが何をすべきか理解していません。

Answer 1

JavaPairRDDにはTuple2が含まれています。以下のコードを試してみることができますが、RowWriterFactoryを返すCassandraJavaUtil.mapTupleToRow関数のクラス型としてジェネリックコレクション型がサポートされているとは思いません。 mapTupleToRowの詳細は、https://github.com/datastax/spark-cassandra-connector/blob/master/doc/7_java_api.md

javaFunctions(javaPairRDD).writerBuilder("cassandrakeyspace", "cassandratable", CassandraJavaUtil.mapTupleToRow(A.class, B.class)).saveToCassandra(); 

です。