искрового Saving JavaRDD Кассандре

Question

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 выше?

Answer 1

После documentation, должно быть так:

javaFunctions(rdd).writerBuilder("ks", "people", mapToRow(Person.class)).saveToCassandra(); 

Answer 2

заменить

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

по

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