Cassandra 和 Spark Thrift 服务器集成

Question

我正在尝试集成Cassandra和Spark Thrift服务器。我按照这里的步骤

在直线控制台中注册卡桑达拉表时出现以下错误。

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');

我错过了什么吗？

Answer 1

将Cassandra连接器添加为Hive-site中的aux jar.xml