我有一张table

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

我用pk1，pk2得到csv

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

我正在阅读csv来创建rdd[primarykey]，现在我想加入这个带有cassandra tablea的rdd
这是我的密码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之间的任何额外Map吗？