相关疑难解决方法(0)

http://www.datastax.com/dev/blog/accessing-cassandra-from-spark-in-java

上面的链接显示了JavaRDD以cassandra这种方式保存到的方法:

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

JavaRDD<Product> productsRDD = sc.parallelize(products);
javaFunctions(productsRDD, Product.class).saveToCassandra("java_api", "products");

但com.datastax.spark.connector.CassandraJavaUtil.*似乎已经弃用了.更新的API应为:

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

有人能告诉我一些代码来存储JavaRDD到Cassandra使用上述更新API？