google-cloud-dataflow - Bigtable data trigger/watch

Question

I am looking to get data from bigtable into dataflow in an unbounded fashion such that the processing is triggered based on continuos inserts into the table. The document (https://cloud.google.com/bigtable/docs/dataflow-hbase) only talks about bounded read using scans. Does the connector or big table support this model at all?

Answer 1

当前的BigtableIO连接器不支持这种持续更新监控的模型，但它肯定会很有用。它被跟踪为功能请求BEAM-45。