|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
public void finalizeCheckpoint()
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.