public class EmptyCheckpointMark extends java.lang.Object implements UnboundedSource.CheckpointMark, java.io.Serializable
JavaUtils.optionToOptional(scala.Option<T>)
UnboundedSource.CheckpointMark.NoopCheckpointMark
NOOP_CHECKPOINT_MARK
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
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 EmptyCheckpointMark |
get() |
int |
hashCode() |
public static EmptyCheckpointMark get()
public void finalizeCheckpoint() throws java.io.IOException
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
java.io.IOException
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object