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?
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.
gelecekteEn cevaptır Değiştir veri yakalama: https://issues.apache.org/jira/browse/CASSANDRA-8844
Belki de tetikler? –
@RussS Link için teşekkürler iyi bilgi –
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ü? –
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ü? –