Апач зависимости Cassandra выпуск

Question

я слежу учебник, чтобы понять, как работает Кассандры, но у меня есть проблема с импортом

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

этот импорт не распознается, особенно в этом ряду:

javaFunctions(productsRDD, Product.class).saveToCassandra("java_api", "products"); 

мой pom.xml это:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
    <modelVersion>4.0.0</modelVersion> 

    <groupId>org.sparkexamples</groupId> 
    <artifactId>cassandraExample</artifactId> 
    <version>0.0.1-SNAPSHOT</version> 
    <packaging>jar</packaging> 

    <name>cassandraExample</name> 
    <url>http://maven.apache.org</url> 

    <properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    </properties> 

    <dependencies> 
    <dependency> 
     <groupId>junit</groupId> 
     <artifactId>junit</artifactId> 
     <version>3.8.1</version> 
     <scope>test</scope> 
    </dependency> 
    <dependency> 
     <groupId>com.datastax.spark</groupId> 
     <artifactId>spark-cassandra-connector_2.10</artifactId> 
     <version>1.3.0-M1</version> 
    </dependency> 
    <dependency> 
     <groupId>com.datastax.spark</groupId> 
     <artifactId>spark-cassandra-connector-java_2.10</artifactId> 
     <version>1.3.0-M1</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.spark</groupId> 
     <artifactId>spark-core_2.10</artifactId> 
     <version>1.3.1</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.spark</groupId> 
     <artifactId>spark-streaming_2.10</artifactId> 
     <version>1.3.1</version> 
    </dependency> 
    </dependencies> 
</project> 

, как я могу это исправить?

благодарит заранее.

Answer 1

Используйте этот импорт, вы следуете за старым API.

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

Answer 2

Проверьте каталог /.m2/ для файла jar-файла искрового контура. Если его нет, сделайте mvn -U, который заставит обновлять зависимости. Если он есть, удалите этот каталог из .m2 (только каталог коннектора Spark) и выполните mvn clean compile>, который должен снова загрузить файл jar.

Если вы работаете с Eclipse, а не с CLI, вы можете щелкнуть правой кнопкой мыши по проекту в проекте Eclipse -> Maven -> Update. Не уверен, как это работает в Netbeans/IntelliJ, но там также должны быть аналогичные варианты.

Также проверьте, может ли ваш mvn подключиться к Интернету из вашей системы. Надеюсь, это не так, но может быть, ваш mvn может работать в автономном режиме.

Пожалуйста, проверьте POM:

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

и

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

Пожалуйста, проверьте, если это вызывает дубликаты и есть противоречивую банка.