Интеграция Cassandra и Spark Thrift Server
Я пытаюсь интегрировать сервер Cassandra и Spark Thrift. Я следовал за шагами отсюда
При регистрации таблиц cassandara в консоли beeline я получаю следующую ошибку.
Error: Error while compiling statement: FAILED: ParseException line 1:23 cannot recognize input near 'USING' 'org' '.' in create table statement (state=42000,code=40000)
Ниже приведен запрос, который я запускаю
CREATE TABLE test_data USING org.apache.spark.sql.cassandra OPTIONS (keyspace 'abc', table 'def');
Я что-то пропустил?
1 ответ
Добавить коннектор cassandra в качестве вспомогательного фляги в hive-site.xml