将少量数据写入Spark的Cassandra表中

Question

我需要在spark应用程序中向cassandra表中写入少量数据。数据不是RDD，它只是一个双重值。如何在使用Java API的Spark应用程序中执行此操作？

感谢您的任何提示。

Answer 1

作为一种快速解决方案，您可以像平常一样使用sc.parallelize并将RDD保存到Cassandra。

如果你需要运行一个查询，你可以在文档使用CassandraConnector池，如：

val connector = CassandraConnector(sc.getConf) 
    connector.withSessionDo(session => ...) 

https://github.com/datastax/spark-cassandra-connector/blob/master/doc/1_connecting.md