Spark 1.6向Cassandra插入数据框架

Question

我正在尝试将其插入cassandra a数据框架。

我写rdd.tosavetocasssandra（" Keyspace"，" Table"）

不是问题，但我不能用这个功能写

myDataFrame.tosaveToCassandra("keyspace","table")

我也尝试过但没有保存。

myDataFrame.write.format("org.apache.spark.sql.cassandra").mode('append').options(table="mytable", keyspace="mykeyspace").save()

除了Spark 2.0

的新API外，您是否有任何想法

谢谢

Answer 1

python当前没有Cassandra在Spark Cassandra Connector中的流式接收器，您将不得不实现自己的。