如何使用 spark 保存 cassandra table 的输出

Question

我想将从 cassandra table 读取的 output/rows 保存到 csv 或 json 格式的文件中。使用，Spark 1.6.3：

scala>val results.sqlContext.sql("select * from myks.mytable")
scala>val.write.option("header","true").save("/tmp/xx.csv") -- writes to cfs:// filesystem

我找不到以 csv 或 json 格式文件写入 OS 的选项。

感谢任何帮助！

Answer 1

使用 spark Cassandra 连接器将数据从 Cassandra table 读取到 spark

https://github.com/datastax/spark-cassandra-connector/blob/master/doc/0_quick_start.md