@Experimental

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

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

See: Description

Class Summary

Class	Description
DetectNewPartitionsDoFn	A SplittableDoFn (SDF) that is responsible for scheduling partitions to be queried.

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

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