Package org.apache.beam.sdk.io.gcp.spanner.changestreams.action
package org.apache.beam.sdk.io.gcp.spanner.changestreams.action
Action processors for each of the types of Change Stream records received.
-
ClassesClassDescriptionFactory class for creating instances that will handle each type of record within a change stream query.This class is part of the process for
ReadChangeStreamPartitionDoFnSDF.This class is part of the process forReadChangeStreamPartitionDoFnSDF.This class is responsible for scheduling partitions.This class is part of the process forReadChangeStreamPartitionDoFnSDF.This class is part of the process forReadChangeStreamPartitionDoFnSDF.This class is part of the process forReadChangeStreamPartitionDoFnSDF.This class is part of the process for invalid input: '{@link org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn..ReadChangeStreamPartitionDoFn'} SDF.Main action class for querying a partition change stream.