5

このリンクJavaRDDは、次の方法でtoを保存する方法を示しています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.*;

上記の更新された APIJavaRDDを使用して を保存するためのコードを誰か教えてもらえますか?Cassandra

4

2 に答える 2

6

ドキュメントに従うと、次のようになります。

javaFunctions(rdd).writerBuilder("ks", "people", mapToRow(Person.class)).saveToCassandra();
于 2014-12-06T12:59:33.307 に答える
0

交換

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

に

JavaRDD<Product> productsRDD = javaFunctions(sc).cassandraTable("java_api", "products", mapRowTo(Product.class));
于 2015-04-29T12:03:29.243 に答える