CODEWITHSUNDEEP
javaapache-sparkcassandrarddspark-cassandra-connector
chrisTina
chrisTina

Reputation: 2368

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?

Upvotes: 5

Views: 4850

Answers (2)

HELLO
HELLO

Reputation: 41

replace

JavaRDD<Product> productsRDD = sc.parallelize(products);
javaFunctions(productsRDD, Product.class).saveToCassandra("java_api", "products »);

by

JavaRDD<Product> productsRDD = javaFunctions(sc).cassandraTable("java_api", "products", mapRowTo(Product.class));

Upvotes: 0

maasg
maasg

Reputation: 37435

Following the documentation, should be like this:

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

Upvotes: 6

Related Questions