Chciałbym przesyłać strumieniowo dane z tabeli kassandra, która jest aktualizowana w czasie rzeczywistym. Tak, jest to baza danych, ale czy istnieje sposób, aby to zrobić? Jeśli tak, to zachowując przesunięcie lub pytania, które mogę używać zapytań CQL?jak przesyłać strumieniowo dane ze stołu z kassandra?
Krótka odpowiedź brzmi: nie.
Długa odpowiedź to wiele trudności i inteligentne klucze do klastrowania, które możesz zrobić. Zasadniczo, jeśli wstawiasz dane za pomocą klucza klastrowania, który zawsze się zwiększa, zawsze możesz po prostu skanować klucze grupowania w ostatniej luce czasowej. To oczywiście zabraknie wkładek poza kolejnością poza twoim oknem. To może, ale nie musi być wystarczająco dobre dla twojego przypadku użycia.
Najlepsza odpowiedź w przyszłości jest Change Data Capture: https://issues.apache.org/jira/browse/CASSANDRA-8844
Może również wyzwalacze? –
@RussS Dzięki za link dobre informacje –
Czy ktoś ma jakiś pomysł, w jaki sposób można użyć w tym celu złącza iskrobassandra? czy samodzielnie zajmuje się offsetem i czy przesyła dane strumieniowo w czasie zbliżonym do rzeczywistego? –
Czy ktoś ma jakiś pomysł, jak iskra-Cassandra Złącze można stosować w tym? czy samodzielnie zajmuje się offsetem i czy przesyła dane strumieniowo w czasie zbliżonym do rzeczywistego? –