org.apache.samza.checkpoint

Class CheckpointV1

java.lang.Object

org.apache.samza.checkpoint.CheckpointV1

All Implemented Interfaces:

Checkpoint

public class CheckpointV1
extends java.lang.Object
implements Checkpoint

A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each. It is used to restore a StreamTask, either as part of a job restart or as part of restarting a failed container within a running job.

Field Summary

Fields

Modifier and Type	Field and Description
static short	CHECKPOINT_VERSION

Constructor Summary

Constructors

Constructor and Description
CheckpointV1(java.util.Map<SystemStreamPartition,java.lang.String> offsets) Constructs a new checkpoint based off a map of Samza stream offsets.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.util.Map<SystemStreamPartition,java.lang.String>	getOffsets() Gets a unmodifiable view of the current Samza input stream offsets.
short	getVersion() Gets the version number of the Checkpoint
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

CHECKPOINT_VERSION

public static final short CHECKPOINT_VERSION

See Also:

Constant Field Values

Constructor Detail

CheckpointV1

public CheckpointV1(java.util.Map<SystemStreamPartition,java.lang.String> offsets)

Constructs a new checkpoint based off a map of Samza stream offsets.

Parameters:

offsets - Map of Samza streams to their current offset.

Method Detail

getVersion

public short getVersion()

Description copied from interface: Checkpoint

Gets the version number of the Checkpoint

Specified by:

getVersion in interface Checkpoint

Returns:

Short indicating the version number

getOffsets

public java.util.Map<SystemStreamPartition,java.lang.String> getOffsets()

Gets a unmodifiable view of the current Samza input stream offsets.

Specified by:

getOffsets in interface Checkpoint

Returns:

a unmodifiable view of a Map of Samza streams to their recorded offsets.

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object