@Internal public class DaoFactory extends java.lang.Object implements java.io.Serializable, java.lang.AutoCloseable
Constructor and Description |
---|
DaoFactory(BigtableConfig changeStreamConfig,
BigtableConfig metadataTableConfig,
java.lang.String tableId,
java.lang.String metadataTableId,
java.lang.String changeStreamName) |
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) |
public DaoFactory(BigtableConfig changeStreamConfig, BigtableConfig metadataTableConfig, java.lang.String tableId, java.lang.String metadataTableId, java.lang.String changeStreamName)
public void close()
close
in interface java.lang.AutoCloseable
public void setReadChangeStreamTimeout(@Nullable Duration readChangeStreamTimeout)
public java.lang.String getChangeStreamName()
public java.lang.String getStreamTableDebugString()
public java.lang.String getMetadataTableDebugString()
public ChangeStreamDao getChangeStreamDao() throws java.io.IOException
java.io.IOException
public MetadataTableDao getMetadataTableDao() throws java.io.IOException
java.io.IOException
public MetadataTableAdminDao getMetadataTableAdminDao() throws java.io.IOException
java.io.IOException