public class CheckpointV1 extends java.lang.Object implements Checkpoint
StreamTask
, either as part of a job restart or as part
of restarting a failed container within a running job.Modifier and Type | Field and Description |
---|---|
static short |
CHECKPOINT_VERSION |
Constructor and Description |
---|
CheckpointV1(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
Constructs a new checkpoint based off a map of Samza stream offsets.
|
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() |
public static final short CHECKPOINT_VERSION
public CheckpointV1(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
offsets
- Map of Samza streams to their current offset.public short getVersion()
Checkpoint
getVersion
in interface Checkpoint
public java.util.Map<SystemStreamPartition,java.lang.String> getOffsets()
getOffsets
in interface Checkpoint
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object