问题

嗨，我正在使用Scala版本：2.11 Spark Cassandra连接器：2.3.0

我有一张桌子，像：

CREATE TABLE dcmapp (
    t text,
    p text,
    v double,
    d blob,
    f text,
    i tinyint,
    PRIMARY KEY ((t, p), v )
)

上面包含一个2列分区键。当我想基于列获取行时"t"这是分区键的一部分，例如：

sc.cassandraTable("kevin", "dcmapp").select("t", "p").where("t = ?", "A1").collect().foreach(println)

我收到以下错误：

java.lang.UnsupportedOperationException: Partition key predicate must include all partition key columns or partition key columns need to be indexed. Missing columns: p

如果我按i查询，则查询成功。

是否无法使用部分分区键在连接器中查询。

如果我通过cqlsh触发仅指定列的相同查询"t"在where子句和ALLOW FILTERING中，我得到结果