@Internal public class StreamProgress extends java.lang.Object implements java.io.Serializable
ReadChangeStreamPartitionProgressTracker
. This represents contains
information that allows a stream, along with the PartitionRecord
to resume from a
checkpoint.
It should contain either a continuation token which represents a position in the stream, or it can contain a close stream message which represents an end to the stream and the DoFn needs to stop.
Constructor and Description |
---|
StreamProgress() |