How do I delete rows from Cassandra table from spark streaming using deleteFromCassandra?

Question

I have a RDD containing the primary keys of a table. I need to delete the rows in Cassandra table which matches the values in RDD.

I see that there is deleteFromCassandra in spark-cassandra-connector, but unable to use it, deleteFromCassandra is unresolved.

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

Thanks for your help.

Answer 1

if i understand your use case, you can follow this question, maybe it will help you: Delete from cassandra Table in Spark