java - 将JavaRDD节省为Cassandra

此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的代码吗？

最佳答案

遵循documentation，应如下所示:

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

关于java - 将JavaRDD节省为Cassandra，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/27323426/