java - 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.*;

有人可以告诉我一些代码来存储JavaRDD使用Cassandra上面更新的 API 吗？

Answer 1

按照文档，应该是这样的：

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