如何使用 deleteFromCassandra 从火花流中删除 Cassandra 表中的行



我有一个包含表主键的RDD。我需要删除 Cassandra 表中与 RDD 中的值匹配的行。

我看到 spark-cassandra-connector 中有 deleteFromCassandra,但无法使用它,deleteFromCassandra 未解决。

https://github.com/datastax/spark-cassandra-connector/blob/master/spark-cassandra-connector/src/main/scala/com/datastax/spark/connector/streaming/DStreamFunctions.scala

感谢您的帮助。

如果我了解您的用例,您可以遵循此问题,也许它会对您有所帮助:从 Spark 中的 cassandra 表中删除

最新更新