Bigtable Daten trigger/watch

Question

Ich bin auf der Suche nach Daten aus BigTable in Datenfluss auf eine unbegrenzte Weise, so dass die Verarbeitung basierend auf kontinuierliche Inserts in die Tabelle ausgelöst wird. Das Dokument (https://cloud.google.com/bigtable/docs/dataflow-hbase) spricht nur über beschränktes Lesen unter Verwendung von Scans. Unterstützt der Connector oder der große Tisch dieses Modell überhaupt?

Answer 1

Der aktuelle BigtableIO Connector unterstützt dieses Modell der kontinuierlichen Updateüberwachung nicht, wäre aber sicherlich nützlich. Es wird als Feature-Anforderung BEAM-45 verfolgt.