火花保存JavaRDD卡桑德拉 [英] Spark- Saving JavaRDD to Cassandra
本文介绍了火花保存JavaRDD卡桑德拉的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
http://www.datastax.com/开发/博客/访问-卡桑德拉从 - 火花在Java的
上面的链接显示的方式保存 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 到卡桑德拉？
推荐答案
继<一个href=\"https://github.com/datastax/spark-cassandra-connector/blob/master/doc/7_java_api.md\">documentation,应该是这样的：
javaFunctions(rdd).writerBuilder("ks", "people", mapToRow(Person.class)).saveToCassandra();
这篇关于火花保存JavaRDD卡桑德拉的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
