public class OperatorCheckpointStats extends CheckpointStats
Constructor and Description |
---|
OperatorCheckpointStats(long checkpointId,
long triggerTimestamp,
long duration,
long stateSize,
long[][] subTaskStats)
Creates a checkpoint statistic for an operator.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
getNumberOfSubTasks()
Returns the number of sub tasks.
|
long |
getSubTaskDuration(int index)
Returns the duration of a specific sub task.
|
long |
getSubTaskStateSize(int index)
Returns the state size of a specific sub task.
|
int |
hashCode() |
String |
toString() |
getCheckpointId, getDuration, getStateSize, getTriggerTimestamp
public OperatorCheckpointStats(long checkpointId, long triggerTimestamp, long duration, long stateSize, long[][] subTaskStats)
checkpointId
- Checkpoint ID this statistic belongs totriggerTimestamp
- Timestamp when the corresponding checkpoint was triggeredduration
- Duration (in milliseconds) to complete this statisticstateSize
- State size (in bytes)subTaskStats
- Stats per subtask ([i][0] and [i][1] encode the duration and state
size for sub task i respectively).public int getNumberOfSubTasks()
public long getSubTaskDuration(int index)
public long getSubTaskStateSize(int index)
public String toString()
toString
in class CheckpointStats
public boolean equals(Object o)
equals
in class CheckpointStats
public int hashCode()
hashCode
in class CheckpointStats
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.