cassandra依赖项问题：找不到CassandraJavaUtil

Question

我尝试启动一个只从cassandra数据库读取表的小应用程序。

null

我创建了一个maven java应用程序，然后将pom.xml与必要的依赖关系放在一起：

Spark Spark-Core2.10 1.6.0

    <dependency>
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector_2.10</artifactId>
<version>1.6.0-M1</version>
    </dependency>


    <dependency>
<groupId>com.datastax.cassandra</groupId>
<artifactId>cassandra-driver-core</artifactId>
<version>3.0.0</version>
    </dependency>

    <dependency>
<groupId>com.datastax.spark</groupId>
<artifactId>spark-cassandra-connector-java_2.10</artifactId>
<version>1.5.0</version>
    </dependency>
</dependencies>

进口：

null

System.out.println("Data as CassandraRows \n"+ StringUtils.join(cassandraRowsRDD.toArray(),"\n"));

Answer 1

确保导入语句中包含以下内容：

import static com.datastax.spark.connector.japi.CassandraJavaUtil.*;

如果使用任何自定义类运行此代码，则需要将jar文件路径添加到spark-defaults.conf文件中，参数如下：

spark.driver.extraClassPath     /whateverpath/to/file/