public class Checkpoint
extends java.lang.Object
StreamTask
, either as part of a job restart or as part
of restarting a failed container within a running job.Constructor and Description |
---|
Checkpoint(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 stream offsets.
|
int |
hashCode() |
java.lang.String |
toString() |
public Checkpoint(java.util.Map<SystemStreamPartition,java.lang.String> offsets)
offsets
- Map of Samza streams to their current offset.public java.util.Map<SystemStreamPartition,java.lang.String> getOffsets()
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