public static interface UnboundedSource.CheckpointMark
For example, this could be offsets in a set of files being read.
|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
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.