public static interface UnboundedSource.CheckpointMark
For example, this could be offsets in a set of files being read.
Note that: The implementations of this interface should be encodable (have an associated Coder).
|Modifier and Type||Interface and Description|
A checkpoint mark that does nothing when finalized.
|Modifier and Type||Field and Description|
|Modifier and Type||Method and Description|
Called by the system to signal that this checkpoint mark has been committed along with all the records which have been read from the
static final UnboundedSource.CheckpointMark.NoopCheckpointMark NOOP_CHECKPOINT_MARK
void finalizeCheckpoint() throws java.io.IOException
UnboundedSource.UnboundedReadersince the previous checkpoint was taken.
For example, this method could send acknowledgements to an external data source such as Pubsub.
UnboundedSource.UnboundedReaderit was created from.
UnboundedSource.UnboundedReaderhas not yet be finalized.
UnboundedSource.UnboundedReaderfrom which this checkpoint was created still exists at the time this method is called.