Интеграция 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

Другие вопросы по тегам