按分区键的Spark Cassandra连接器查询

Question

使用Spark连接器通过分区键查询cassandra的理想方法是什么。我使用where传入键，但这导致cassandra在引擎盖下添加Allaow filtering，从而导致超时。

当前设置：

csc.cassandraTable[DATA]("schema", "table").where("id =?", "xyz").map(     x=> print(x))

这里id是分区（不是主）键，我有一个复合主键，只使用分区键进行查询

更新：是的，我得到了一个异常：

Answer 1

如果对整个分区键使用where子句，ALLOW筛选不会影响查询。如果查询超时，这可能意味着您的分区非常大，或者没有指定完整的分区键

编辑：

Cassandra failure during read query at consistency LOCAL_ONE (1 responses were required but only 0 replica responded, 1 failed)

意味着您的查询被发送到没有您要查找的数据副本的计算机。通常，这意味着密钥空间的复制设置不正确，或者连接主机不正确。local_one的local部分意味着只有在local_dc上有可用的数据时，才允许查询成功。

null