org.apache.samza.checkpoint

Class CheckpointId

java.lang.Object

org.apache.samza.checkpoint.CheckpointId

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

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 toString() 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

Constructor Summary

Constructors

Constructor and Description
CheckpointId(long millis, long nanos)

Method Summary

Modifier and Type	Method and Description
static CheckpointId	create()
boolean	equals(java.lang.Object o)
static CheckpointId	fromString(java.lang.String checkpointId)
long	getMillis()
long	getNanos()
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

CheckpointId

public CheckpointId(long millis,
                    long nanos)

Method Detail

create

public static CheckpointId create()

fromString

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

getMillis

public long getMillis()

getNanos

public long getNanos()

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