Я хотел бы передать данные из таблицы cassandra, которая обновляется в реальном времени. Да, это база данных, но есть ли способ сделать это? Если это так, сохраняя смещение или какие CQL-запросы я могу использовать?Как вывести данные из таблицы cassandra?
Короткий ответ - нет.
Долгий ответ с большой сложностью и умными клавишами кластеризации, вы можете это сделать. В принципе, если вы вставляете данные с ключом кластеризации, который всегда увеличивается, вы всегда можете просто сканировать ключи кластеризации в недавнем временном промежутке. Это, конечно, пропустит нестандартные вставки за пределами вашего окна. Это может быть или не быть достаточно хорошим для вашего случая использования.
Лучший ответ в будущем Change Data Capture: https://issues.apache.org/jira/browse/CASSANDRA-8844
Может быть, также триггеры? –
@RussS Спасибо за ссылку хорошая информация –
Есть ли у кого-нибудь представление о том, как можно использовать в этом случае искро-кассандра-коннектор? берет ли он заботу о смещении самостоятельно и передает данные в ближайшее время? –
Кто-нибудь есть некоторое представление о том, как с искровым Кассандры разъем может быть использован в этом? берет ли он заботу о смещении самостоятельно и передает данные в ближайшее время? –