@Internal public class MetadataTableDao extends java.lang.Object
Metadata table is shared across many beam jobs. Each beam job uses a specific prefix to identify itself which is used as the row prefix.
Constructor and Description |
---|
MetadataTableDao(java.lang.String tableId,
com.google.protobuf.ByteString changeStreamNamePrefix) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.ByteString |
getChangeStreamNamePrefix() |