"누락 EOF"오류 메시지

Question

내가 다음 문 사용하여 스파크 카산드라 커넥터를 사용하여 카산드라 테이블을 조회 할 스파크 카산드라 커넥터 사용하여 쿼리 :

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이 그 안에 갈 수 아래로 CQL 카산드라에 밀어하는 데 사용됩니다. Spark Side Sql-Like 구문을 수행하려는 경우 SparkSql 및 Datasets를 확인하십시오.