CassandraTableScanRDD [CassandraRow] with RDD [String]

Question

私はRDD [String]とCassandraTableScanRDDがあるプログラムを作成しています。それらの間で左結合を行いたいと思います。

これは可能ですか？私がオンラインで見たものから、結合はCassandraTableScanRDDの間だけであった。

Answer 1

joinPairRDDオブジェクト（hereを参照）の機能を利用できます。

PairRDDオブジェクトは、例えば、キーと値のペアのRDDある：

RDD[(Int, String)]は通常、あなたが使用するキーを指定することを可能にするkeyBy関数を用いて正規RDDからPairRDDオブジェクトを作成します。次に、joinを実行すると、キーが等しい要素が結合されます。