本文介绍了火花保存JavaRDD卡桑德拉的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
上面的链接显示的方式保存 JavaRDD 到卡桑德拉是这样的：
The link above shows a way to save a JavaRDD to cassandra in this way:
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。* 好像去precated。更新后的API应该是：
But the com.datastax.spark.connector.CassandraJavaUtil.* seems deprecated. The updated API should be:
import static com.datastax.spark.connector.japi.CassandraJavaUtil.*;
能否有人告诉我一些codeS使用上述更新的API来存储 JavaRDD 到卡桑德拉？
推荐答案
继documentation,应该是这样的：
javaFunctions(rdd).writerBuilder("ks", "people", mapToRow(Person.class)).saveToCassandra();
这篇关于火花保存JavaRDD卡桑德拉的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！