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

Class DaoFactory

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, java.lang.AutoCloseable

@Internal
public class DaoFactory
extends java.lang.Object
implements java.io.Serializable, java.lang.AutoCloseable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DaoFactory(BigtableConfig changeStreamConfig, BigtableConfig metadataTableConfig, java.lang.String tableId, java.lang.String metadataTableId, java.lang.String changeStreamName)

Method Summary

Modifier and Type	Method and Description
void	close()
ChangeStreamDao	getChangeStreamDao()
java.lang.String	getChangeStreamName()
MetadataTableAdminDao	getMetadataTableAdminDao()
MetadataTableDao	getMetadataTableDao()
java.lang.String	getMetadataTableDebugString()
java.lang.String	getStreamTableDebugString()
void	setReadChangeStreamTimeout(@Nullable Duration readChangeStreamTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

DaoFactory

public DaoFactory(BigtableConfig changeStreamConfig,
                  BigtableConfig metadataTableConfig,
                  java.lang.String tableId,
                  java.lang.String metadataTableId,
                  java.lang.String changeStreamName)

Method Detail

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

setReadChangeStreamTimeout

public void setReadChangeStreamTimeout(@Nullable Duration readChangeStreamTimeout)

getChangeStreamName

public java.lang.String getChangeStreamName()

getStreamTableDebugString

public java.lang.String getStreamTableDebugString()

getMetadataTableDebugString

public java.lang.String getMetadataTableDebugString()

getChangeStreamDao

public ChangeStreamDao getChangeStreamDao()
                                   throws java.io.IOException

Throws:

java.io.IOException

getMetadataTableDao

public MetadataTableDao getMetadataTableDao()
                                     throws java.io.IOException

Throws:

java.io.IOException

getMetadataTableAdminDao

public MetadataTableAdminDao getMetadataTableAdminDao()
                                               throws java.io.IOException

Throws:

java.io.IOException