org.apache.samza.checkpoint

Class Checkpoint

java.lang.Object

org.apache.samza.checkpoint.Checkpoint

public class Checkpoint
extends java.lang.Object

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.

Constructor Summary

Constructors

Constructor and Description
Checkpoint(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 stream offsets.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Checkpoint

public Checkpoint(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

getOffsets

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

Gets a unmodifiable view of the current Samza stream offsets.

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