public static interface UnboundedSource.CheckpointMark
UnboundedSource.UnboundedReader
.
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 |
---|---|
static class |
UnboundedSource.CheckpointMark.NoopCheckpointMark
A checkpoint mark that does nothing when finalized.
|
Modifier and Type | Field and Description |
---|---|
static UnboundedSource.CheckpointMark.NoopCheckpointMark |
NOOP_CHECKPOINT_MARK |
Modifier and Type | Method and Description |
---|---|
void |
finalizeCheckpoint()
Called by the system to signal that this checkpoint mark has been committed along with all
the records which have been read from the
UnboundedSource.UnboundedReader since the previous
checkpoint was taken. |
static final UnboundedSource.CheckpointMark.NoopCheckpointMark NOOP_CHECKPOINT_MARK
void finalizeCheckpoint() throws java.io.IOException
UnboundedSource.UnboundedReader
since the previous
checkpoint was taken.
For example, this method could send acknowledgements to an external data source such as Pubsub.
Note that:
UnboundedSource.UnboundedReader
it was created from.
UnboundedSource.UnboundedReader
has not
yet be finalized.
UnboundedSource.UnboundedReader
.
UnboundedSource.UnboundedReader
from which this checkpoint was
created still exists at the time this method is called.
java.io.IOException