【发布时间】:2019-01-24 13:44:56
【问题描述】:
每次使用 java 的 datastax 添加时,如何从 cassandra 数据库中获取记录?也就是说,我怎样才能“监听”cassandra 数据库?谢谢
【问题讨论】:
标签: java apache-spark cassandra listener datastax
每次使用 java 的 datastax 添加时,如何从 cassandra 数据库中获取记录?也就是说,我怎样才能“监听”cassandra 数据库?谢谢
【问题讨论】:
标签: java apache-spark cassandra listener datastax
没有简单的方法可以做到这一点。 Cassandra 具有Change Data Capture 功能,但它的级别非常低(可能取决于Cassandra 的版本),并且使用起来并不容易。您可以编写自己的实现(上面链接中的指针),或使用this 之类的东西,但它已经很老了。而且您需要自己处理重复数据删除,因为当您的 RF > 1 时,每个节点都会接收和写入数据。
【讨论】: