Spark- 将JavaRDD保存到Cassandra

Question

这个链接展示了一种将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.*;

有人能给我展示一些代码，使用上面更新的API将JavaRDD存储到Cassandra中吗？

- chrisTina

Answer 1

按照文档所述，应该像这样实现：

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

- maasg

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));

- HELLO