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()
java.util.List<Partition>	getPartitions()
long	getSkipFromFirst()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

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

getOffsetLimit

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getPartitions

public java.util.List<Partition> getPartitions()

getSkipFromFirst

public long getSkipFromFirst()