Package org.apache.beam.sdk.io.gcp.spanner.changestreams.dao

package org.apache.beam.sdk.io.gcp.spanner.changestreams.dao

Database Access Objects for querying change streams and modifying the Connector's metadata tables.

Related Packages

Package	Description
org.apache.beam.sdk.io.gcp.spanner.changestreams	Provides an API for reading change stream data from Google Cloud Spanner.

Classes

Class	Description
ChangeStreamDao	Responsible for making change stream queries for a given partition.
ChangeStreamResultSet	Decorator class over a ResultSet that provides telemetry for the streamed records.
ChangeStreamResultSetMetadata	Represents telemetry metadata gathered during the consumption of a change stream query.
DaoFactory	Factory class to create data access objects to perform change stream queries and access the metadata tables.
PartitionMetadataAdminDao	Data access object for creating and dropping the partition metadata table.
PartitionMetadataDao	Data access object for the Connector metadata tables.
PartitionMetadataDao.InTransactionContext	Represents the execution of a read / write transaction in Cloud Spanner.
PartitionMetadataDao.TransactionResult<T>	Represents a result from executing a Cloud Spanner read / write transaction.
PartitionMetadataTableNames	Configuration for a partition metadata table.