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

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

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
ChangeStreamDao	getChangeStreamDao()
java.lang.String	getChangeStreamName()
MetadataTableAdminDao	getMetadataTableAdminDao()
MetadataTableDao	getMetadataTableDao()
java.lang.String	getMetadataTableDebugString()
java.lang.String	getStreamTableDebugString()

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 changeStreamName)

Method Detail

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