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

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

Custom restriction tracker related classes.

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
DetectNewPartitionsRangeTracker	This restriction tracker delegates most of its behavior to an internal TimestampRangeTracker.
ReadChangeStreamPartitionRangeTracker	This restriction tracker delegates most of its behavior to an internal TimestampRangeTracker.
RestrictionInterrupter<T>	An interrupter for restriction tracker of type T.
TimestampRange	A restriction represented by a range of timestamps [from, to).
TimestampRangeTracker	A RestrictionTracker for claiming positions in a TimestampRange in a monotonically increasing fashion.
TimestampUtils	Provides methods in order to convert timestamp to nanoseconds representation and back.