2016-02-29 27 views
5

Gerçek zamanlı olarak güncellenen bir cassandra tablosundan veri akışı yapmak istiyorum. Evet, bir veri tabanı ama bunu yapmanın bir yolu var mı? Eğer öyleyse, bir ofset tutmak veya hangi CQL sorgularını kullanabilirim?Bir cassandra tablosundan veri akışı nasıl yapılır?

+0

herkes kıvılcım-cassandra-konnektör bu kullanılabilen konusunda bazı fikir var mı? kendi başına ofset ile ilgilenir ve veriyi gerçek zamanlı olarak yürütür mü? –

cevap

5

Kısa cevap yok.

Uzun cevap, birçok zorluk ve akıllı kümeleme tuşları ile bunu yapabilirsiniz. Temel olarak, her zaman artan bir küme anahtarıyla veri eklerseniz, daima yeni bir zaman aralığı içinde kümeleme anahtarlarını tarayabilirsiniz. Bu elbette pencerenizin dışındaki siparişleri ekleyecektir. Bu kullanım durumunuz için yeterince iyi olabilir veya olmayabilir.

gelecekte

En cevaptır Değiştir veri yakalama: https://issues.apache.org/jira/browse/CASSANDRA-8844

+0

Belki de tetikler? –

+0

@RussS Link için teşekkürler iyi bilgi –

+0

Spark-cassandra-konektörünün bunun içinde nasıl kullanılabileceği konusunda bir fikri var mı? kendi başına ofset ile ilgilenir ve veriyi gerçek zamanlı olarak yürütür mü? –

İlgili konular