Class DaoFactory
java.lang.Object
org.apache.beam.sdk.io.gcp.bigtable.changestreams.dao.DaoFactory
- All Implemented Interfaces:
Serializable,AutoCloseable
- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionDaoFactory(BigtableConfig changeStreamConfig, BigtableConfig metadataTableConfig, String tableId, String metadataTableId, String changeStreamName) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidsetReadChangeStreamTimeout(@Nullable Duration readChangeStreamTimeout)
-
Constructor Details
-
DaoFactory
public DaoFactory(BigtableConfig changeStreamConfig, BigtableConfig metadataTableConfig, String tableId, String metadataTableId, String changeStreamName)
-
-
Method Details
-
close
public void close()- Specified by:
closein interfaceAutoCloseable
-
setReadChangeStreamTimeout
-
getChangeStreamName
-
getStreamTableDebugString
-
getMetadataTableDebugString
-
getChangeStreamDao
- Throws:
IOException
-
getMetadataTableDao
- Throws:
IOException
-
getMetadataTableAdminDao
- Throws:
IOException
-