Google Cloud Dataflow SDK for Java, version 1.9.1
- All Known Implementing Classes:
public static interface UnboundedSource.CheckpointMarkA marker representing the progress and state of an
For example, this could be offsets in a set of files being read.
void finalizeCheckpoint() throws IOExceptionPerform any finalization that needs to happen after a bundle of data read from the source has been processed and committed.
For example, this could be sending acknowledgement requests to an external data source such as Pub/Sub.
This may be called from any thread, potentially at the same time as calls to the
UnboundedReaderthat created it.