使用 spark-cassandra-connector 查询时出现“缺少 EOF”错误消息

Question

我想通过以下语句使用 spark-cassandra-connector 查询 cassandra 表：

sc.cassandraTable("citizens","records")
  .select("identifier","name")
  .where( "name='Alice' or name='Bob' ")

我收到此错误消息：

org.apache.spark.SparkException: Job aborted due to stage failure: 
Task 0 in stage 81.0 failed 4 times, most recent failure: 
Lost task 0.3 in stage 81.0 (TID 9199, mydomain): 
java.io.IOException: Exception during preparation of 
SELECT "identifier", "name" FROM "citizens"."records" WHERE token("id") > ? AND token("id") <= ? AND name='Alice' or name='Bob'   LIMIT 10 ALLOW FILTERING:
line 1:127 missing EOF at 'or' (...<= ? AND name='Alice' [or] name...)

我在这里做错了什么以及如何使用连接器的where 子句进行or 查询？

Answer 1

您的 OR 子句不是有效的 CQL。对于这几个键值（我假设name 是一个键），您可以使用IN 子句。

.where( "name in ('Alice', 'Bob') ")

where 子句用于将 CQL 下推到 Cassandra，因此只有有效的 CQL 可以进入其中。如果您希望使用 Spark Side Sql-Like 语法，请查看 SparkSql 和数据集。