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

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

Provides an API for reading change stream data from Google Cloud Spanner.

Related Packages

Package	Description
org.apache.beam.sdk.io.gcp.spanner	Provides an API for reading from and writing to Google Cloud Spanner.
org.apache.beam.sdk.io.gcp.spanner.changestreams.action	Action processors for each of the types of Change Stream records received.
org.apache.beam.sdk.io.gcp.spanner.changestreams.cache	Caching strategy for watermark.
org.apache.beam.sdk.io.gcp.spanner.changestreams.dao	Database Access Objects for querying change streams and modifying the Connector's metadata tables.
org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn	DoFn and SDF definitions to process Google Cloud Spanner Change Streams.
org.apache.beam.sdk.io.gcp.spanner.changestreams.encoder	User model for the Spanner change stream API.
org.apache.beam.sdk.io.gcp.spanner.changestreams.estimator	Classes related to estimating the throughput of the change streams SDFs.
org.apache.beam.sdk.io.gcp.spanner.changestreams.mapper	Mapping related functionality, such as from ResultSets to Change Stream models.
org.apache.beam.sdk.io.gcp.spanner.changestreams.model	User models for the Spanner change stream API.
org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction	Custom restriction tracker related classes.

Classes

Class	Description
ChangeStreamMetrics	Class to aggregate metrics related functionality.
ChangeStreamsConstants	Single place for defining the constants used in the Spanner.readChangeStreams() connector.
MetadataSpannerConfigFactory	This class generates a SpannerConfig for the change stream metadata database by copying only the necessary fields from the SpannerConfig of the primary database.
SpannerChangestreamsReadSchemaTransformProvider
SpannerChangestreamsReadSchemaTransformProvider.DataChangeRecordToRow
SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration
SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration.Builder