java - 无法解析导入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 表。

当我尝试导入时导入静态 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 中.