public static class UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter.Checkpoint<T> extends java.lang.Object implements UnboundedSource.CheckpointMark
UnboundedReadFromBoundedSource.BoundedToUnboundedSourceAdapter
.UnboundedSource.CheckpointMark.NoopCheckpointMark
NOOP_CHECKPOINT_MARK
Constructor and Description |
---|
Checkpoint(@Nullable java.util.List<TimestampedValue<T>> residualElements,
@Nullable BoundedSource<T> residualSource) |
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. |
public Checkpoint(@Nullable java.util.List<TimestampedValue<T>> residualElements, @Nullable BoundedSource<T> residualSource)
public void finalizeCheckpoint()
UnboundedSource.CheckpointMark
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.
finalizeCheckpoint
in interface UnboundedSource.CheckpointMark