java - Spark-将 JavaRDD 保存到 Cassandra

Question

这个link展示了一种将 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 的代码吗？

Answer 1

遵循 documentation ，应该是这样的:

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