org.apache.beam.sdk.io.gcp.bigtable.changestreams.dao

Class MetadataTableDao

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.dao.MetadataTableDao

@Internal
public class MetadataTableDao
extends java.lang.Object

Data access object for managing the state of the metadata Bigtable table.

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 Summary

Constructors

Constructor and Description
MetadataTableDao(java.lang.String tableId, com.google.protobuf.ByteString changeStreamNamePrefix)

Method Summary

Modifier and Type	Method and Description
com.google.protobuf.ByteString	getChangeStreamNamePrefix()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetadataTableDao

public MetadataTableDao(java.lang.String tableId,
                        com.google.protobuf.ByteString changeStreamNamePrefix)

Method Detail

getChangeStreamNamePrefix

public com.google.protobuf.ByteString getChangeStreamNamePrefix()

Returns:

the prefix that is prepended to every row belonging to this beam job.