我有一个包含表的主键的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
谢谢你的帮助 .
如果我理解你的用例，你可以按照这个问题，也许它会帮助你：Delete from cassandra Table in Spark
1 回答
如果我理解你的用例，你可以按照这个问题，也许它会帮助你：Delete from cassandra Table in Spark