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

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

DoFn and SDF definitions to process Google Cloud Spanner Change Streams.

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
CleanUpReadChangeStreamDoFn
DetectNewPartitionsDoFn	A SplittableDoFn (SDF) that is responsible for scheduling partitions to be queried.
InitializeDoFn	A DoFn responsible for initializing the change stream Connector.
PostProcessingMetricsDoFn	A DoFn class to gather metrics about the emitted DataChangeRecords.
ReadChangeStreamPartitionDoFn	A SDF (Splittable DoFn) class which is responsible for performing a change stream query for a given partition.