Modifier and Type | Class and Description |
---|---|
static class |
IterationRecord.Type
The type of iteration records.
|
Modifier and Type | Method and Description |
---|---|
IterationRecord<T> |
clone() |
boolean |
equals(Object o) |
long |
getCheckpointId() |
int |
getEpoch() |
String |
getSender() |
IterationRecord.Type |
getType() |
T |
getValue() |
int |
hashCode() |
void |
incrementEpoch() |
static <T> IterationRecord<T> |
newBarrier(long checkpointId) |
static <T> IterationRecord<T> |
newEpochWatermark(int epoch,
String sender) |
static <T> IterationRecord<T> |
newRecord(T value,
int epoch) |
void |
setCheckpointId(long checkpointId) |
void |
setEpoch(int epoch) |
void |
setSender(String sender) |
void |
setType(IterationRecord.Type type) |
void |
setValue(T value) |
String |
toString() |
public static <T> IterationRecord<T> newRecord(T value, int epoch)
public static <T> IterationRecord<T> newEpochWatermark(int epoch, String sender)
public static <T> IterationRecord<T> newBarrier(long checkpointId)
public IterationRecord.Type getType()
public void setType(IterationRecord.Type type)
public int getEpoch()
public void setEpoch(int epoch)
public void incrementEpoch()
public T getValue()
public void setValue(T value)
public String getSender()
public void setSender(String sender)
public long getCheckpointId()
public void setCheckpointId(long checkpointId)
public IterationRecord<T> clone()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.