Package cz.o2.proxima.beam.core.direct.io

Class DirectBatchUnboundedSource.Checkpoint

java.lang.Object

cz.o2.proxima.beam.core.direct.io.DirectBatchUnboundedSource.Checkpoint

All Implemented Interfaces:

java.io.Serializable, org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

Enclosing class:

DirectBatchUnboundedSource

public static class DirectBatchUnboundedSource.Checkpoint
extends java.lang.Object
implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

org.apache.beam.sdk.io.UnboundedSource.CheckpointMark.NoopCheckpointMark

Field Summary

Fields inherited from interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

NOOP_CHECKPOINT_MARK

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
void	finalizeCheckpoint()
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Method Detail

finalizeCheckpoint

public void finalizeCheckpoint()

Specified by:

finalizeCheckpoint in interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object