我有一个包含表主键的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 表中删除