Я хочу получать данные из bigtable в поток данных неограниченным образом, чтобы обработка запускалась на основе непрерывных вставок в таблицу. Документ (https://cloud.google.com/bigtable/docs/dataflow-hbase) говорит только об ограниченном чтении с использованием сканирования. Разъем или большой стол вообще поддерживает эту модель?
Триггер данных Bigtable / часы
Ответы (1)
Текущий коннектор BigtableIO не поддерживает эту модель непрерывного мониторинга обновлений, но, безусловно, будет полезен. Он отслеживается как запрос функции BEAM-45.
person
Kenn Knowles
schedule
12.05.2016
