@Experimental(value=SOURCE_SINK)

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

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

See: Description

Class Summary

Class	Description
ChangeStreamMetrics	Class to aggregate metrics related functionality.
ChangeStreamsConstants	Single place for defining the constants used in the Spanner.readChangeStreams() connector.
NameGenerator	This class generates a unique name for the partition metadata table, which is created when the Connector is initialized.

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

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