@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.
NameGenerator	This class generates a unique name for the partition metadata table, which is created when the Connector is initialized.
TimestampConverter	Util class to manage timestamp conversions.

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

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