这个链接展示了一种将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
中吗?