无法解析导入com.datastax.spark.connector.CassandraJavaUtil

Question

我正在尝试使用spark-sql java API来连接cassandra。下面是我正在使用的jar

<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>spark-cassandra-connector_2.11</artifactId>
    <version>2.3.1</version>
</dependency>

试图将rdd保存到Cassandra表中。

当我尝试导入import static com.datastax.spark.connector.CassandraJavaUtil.javaFunctions;

它给出了一个错误“导入com.datastax.spark.connector.CassandraJavaUtil无法解析”

我还需要在pom.xml中添加什么？是否有针对Java 8 API的spark-cassandra-connector文档？

我指的是这个样本，用Java继续

https://gist.github.com/jacek-lewandowski/278bfc936ca990bee35a

Answer 1

你需要使用following dependency代替：

<dependency>
    <groupId>com.datastax.spark</groupId>
    <artifactId>spark-cassandra-connector_2.11</artifactId>
    <version>2.3.1</version>
</dependency>

在您的示例中，groupId不正确...

Spark Connector的所有文档都在repository中。