如何从cassandra表中流式传输数据?

kri*_* at 6 streaming bigdata cassandra spring-xd spark-streaming

我想从一个实时更新的cassandra表中流式传输数据.是的,它是一个数据库但是有办法做到这一点吗?如果是这样,保留偏移或我可以使用哪些CQL查询?

Rus*_*ssS 6

简短的回答是否定的.

很长的答案是有很多困难和智能群集键,你可以做到这一点.基本上,如果使用始终增加的聚类键插入数据,则始终只能在最近的时间间隔内扫描聚类键.这当然会错过窗外的无序插入.对于您的用例,这可能或可能不够好.

未来的最佳答案是变更数据捕获:https://issues.apache.org/jira/browse/CASSANDRA-8844