Package 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:

Serializable, AutoCloseable

@Internal
public class DaoFactory
extends Object
implements Serializable, AutoCloseable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DaoFactory(BigtableConfig changeStreamConfig, BigtableConfig metadataTableConfig, String tableId, String metadataTableId, String changeStreamName)

Method Summary

Modifier and Type	Method	Description
void	close()
ChangeStreamDao	getChangeStreamDao()
String	getChangeStreamName()
MetadataTableAdminDao	getMetadataTableAdminDao()
MetadataTableDao	getMetadataTableDao()
String	getMetadataTableDebugString()
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 Details

DaoFactory

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

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

setReadChangeStreamTimeout

public void setReadChangeStreamTimeout(@Nullable Duration readChangeStreamTimeout)

getChangeStreamName

public String getChangeStreamName()

getStreamTableDebugString

public String getStreamTableDebugString()

getMetadataTableDebugString

public String getMetadataTableDebugString()

getChangeStreamDao

public ChangeStreamDao getChangeStreamDao()
                                   throws IOException

Throws:

IOException

getMetadataTableDao

public MetadataTableDao getMetadataTableDao()
                                     throws IOException

Throws:

IOException

getMetadataTableAdminDao

public MetadataTableAdminDao getMetadataTableAdminDao()
                                               throws IOException

Throws:

IOException