Разъем искры Casssandra Составные первичные ключи. JoinWithCassandraTable - PullRequest
Новая
       85

Разъем искры Casssandra Составные первичные ключи. JoinWithCassandraTable

0 голосов
/ 01 августа 2020

У меня есть таблица 

create tableA (
   pk1 String,
   pk2 int,
   col3 int
   ...
   PRIMARY((pk1,pk2),col3)) .....

Я получаю CSV с pk1, pk2 

case class PrimaryKey(pk1:String,pk2:int)

Я читаю csv для создания RDD [PrimaryKey] Теперь я хочу присоединиться к этому RDD с таблицей cassandraA

Вот мой код (https://github.com/datastax/spark-cassandra-connector/blob/master/doc/2_loading.md) 

RDD[PrimaryKey] df = /** created by reading csv **/
df.joinWithCassandraTable("keyspace", "tableA")

Это всегда возвращает пустой результат. Нужно ли мне упоминать какое-либо дополнительное сопоставление между классом PrimaryKey и фактическим PrimaryKey tableA?

...