BigtableIO是如何实现exactly once write的呢?
How does BigtableIO achieves exactly once writes?
Dataflow同样保证exactly once processing and delivery。这是否通过不允许对现有记录进行突变并且只允许幂等覆盖来保证在接收器处?
你是对的。 BigtableIO Dataflow/Beam 连接器将只写入 Put 和 Delete 变更,忽略 Append 和 Increment 变更。请参阅 documentation for the class 中的注释。
Dataflow同样保证exactly once processing and delivery。这是否通过不允许对现有记录进行突变并且只允许幂等覆盖来保证在接收器处?
你是对的。 BigtableIO Dataflow/Beam 连接器将只写入 Put 和 Delete 变更,忽略 Append 和 Increment 变更。请参阅 documentation for the class 中的注释。