org.apache.samza.checkpoint

Class CheckpointId

java.lang.Object

org.apache.samza.checkpoint.CheckpointId

All Implemented Interfaces:

java.lang.Comparable<CheckpointId>

@InterfaceStability.Unstable
public class CheckpointId
extends java.lang.Object
implements java.lang.Comparable<CheckpointId>

Checkpoint ID has the format: [currentTimeMillis, last 6 digits of nanotime], separated by a dash. This is to avoid conflicts, e.g when requesting frequent manual commits. It is expected that persistent stores use the serialize() representation of the checkpoint id as the store checkpoint directory name.

Field Summary

Fields

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

Method Summary

Modifier and Type	Method and Description
int	compareTo(CheckpointId that)
static CheckpointId	create()
static CheckpointId	deserialize(java.lang.String checkpointId)
boolean	equals(java.lang.Object o)
long	getMillis()
long	getNanoId()
int	hashCode()
java.lang.String	serialize() Serialization of CheckpointId as part of task checkpoints, in conjunction with deserialize(String).
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

Method Detail

create

public static CheckpointId create()

deserialize

public static CheckpointId deserialize(java.lang.String checkpointId)

getMillis

public long getMillis()

getNanoId

public long getNanoId()

serialize

public java.lang.String serialize()

Serialization of CheckpointId as part of task checkpoints, in conjunction with deserialize(String).

Returns:

the String representation of this CheckpointId.

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

compareTo

public int compareTo(CheckpointId that)

Specified by:

compareTo in interface java.lang.Comparable<CheckpointId>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object