Search code examples
javaapache-sparkcassandrarddspark-cassandra-connector

Spark- Saving JavaRDD to Cassandra

This link 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");

But the com.datastax.spark.connector.CassandraJavaUtil.* seems deprecated. The updated API should be:

import static com.datastax.spark.connector.japi.CassandraJavaUtil.*;

Can someone show me some codes to store a JavaRDD to Cassandra using the updated API above?

Solution

  • Following the documentation, should be like this:

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