@Experimental

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

Action processors for each of the types of Change Stream records received.

See: Description

Class Summary

Class	Description
ActionFactory	Factory class for creating instances that will handle each type of record within a change stream query.
ChildPartitionsRecordAction	This class is part of the process for ReadChangeStreamPartitionDoFn SDF.
DataChangeRecordAction	This class is part of the process for ReadChangeStreamPartitionDoFn SDF.
DetectNewPartitionsAction	This class is responsible for scheduling partitions.
HeartbeatRecordAction	This class is part of the process for ReadChangeStreamPartitionDoFn SDF.
QueryChangeStreamAction	Main action class for querying a partition change stream.

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

Action processors for each of the types of Change Stream records received.