org.apache.samza.checkpoint

Class CheckpointedChangelogOffset

java.lang.Object

org.apache.samza.checkpoint.CheckpointedChangelogOffset

@InterfaceStability.Unstable
public class CheckpointedChangelogOffset
extends java.lang.Object

Checkpointed changelog offset has the format: [checkpointId, offset], separated by a colon.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SEPARATOR

Constructor Summary

Constructors

Constructor and Description
CheckpointedChangelogOffset(CheckpointId checkpointId, java.lang.String offset)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
static CheckpointedChangelogOffset	fromString(java.lang.String message)
CheckpointId	getCheckpointId()
java.lang.String	getOffset()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

SEPARATOR

public static final java.lang.String SEPARATOR

See Also:

Constant Field Values

Constructor Detail

CheckpointedChangelogOffset

public CheckpointedChangelogOffset(CheckpointId checkpointId,
                                   java.lang.String offset)

Method Detail

fromString

public static CheckpointedChangelogOffset fromString(java.lang.String message)

getCheckpointId

public CheckpointId getCheckpointId()

getOffset

public java.lang.String getOffset()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object