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

【问题标题】：How do I delete rows from Cassandra table from spark streaming using deleteFromCassandra?如何使用 deleteFromCassandra 从火花流中删除 Cassandra 表中的行？
【发布时间】：2017-08-12 11:06:22
【问题描述】：

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

感谢您的帮助。

【问题讨论】：

“未解决？”

标签： apache-spark cassandra spark-streaming datastax spark-cassandra-connector

【解决方案1】：

如果我了解您的用例，您可以关注这个问题，也许它会对您有所帮助： Delete from cassandra Table in Spark

【讨论】：

是的，这是一种解决方法。但是，如果您查看此datastax-oss.atlassian.net/browse/SPARKC-349，您会发现使用 deleteFromCassandra 删除行有一种更新更好的方法。

猜你喜欢

2016-02-07
2019-06-01
2023-03-11
2018-02-11
1970-01-01
2017-01-01
2022-08-23
2018-08-09
1970-01-01

相关资源

下载 2023-03-28
下载 2023-02-17
下载 2023-02-15

最近更新更多

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode