public abstract class AbstractCheckpointStats extends Object implements Serializable
Modifier and Type | Method and Description |
---|---|
abstract long |
getAlignmentBuffered()
Returns the total buffered bytes during alignment over all subtasks.
|
Collection<TaskStateStats> |
getAllTaskStateStats()
Returns all task state stats instances.
|
long |
getCheckpointId()
Returns the ID of this checkpoint.
|
long |
getEndToEndDuration()
Returns the duration of this checkpoint calculated as the time since
triggering until the latest acknowledged subtask or
-1 if
no subtask was acknowledged yet. |
abstract SubtaskStateStats |
getLatestAcknowledgedSubtaskStats()
Returns the latest acknowledged subtask stats or
null if
none was acknowledged yet. |
long |
getLatestAckTimestamp()
Returns the ack timestamp of the latest acknowledged subtask or
-1 if none was acknowledged yet. |
abstract int |
getNumberOfAcknowledgedSubtasks()
Returns the number of acknowledged subtasks.
|
int |
getNumberOfSubtasks()
Returns the total number of subtasks involved in this checkpoint.
|
CheckpointProperties |
getProperties()
Returns the properties of this checkpoint.
|
abstract long |
getStateSize()
Returns the total checkpoint state size over all subtasks.
|
abstract CheckpointStatsStatus |
getStatus()
Returns the status of this checkpoint.
|
TaskStateStats |
getTaskStateStats(JobVertexID jobVertexId)
Returns the task state stats for the given job vertex ID or
null if no task with such an ID is available. |
long |
getTriggerTimestamp()
Returns the timestamp when the checkpoint was triggered.
|
public abstract CheckpointStatsStatus getStatus()
public abstract int getNumberOfAcknowledgedSubtasks()
public abstract long getStateSize()
public abstract long getAlignmentBuffered()
Can return -1
if the runtime did not report this.
@Nullable public abstract SubtaskStateStats getLatestAcknowledgedSubtaskStats()
null
if
none was acknowledged yet.null
public long getCheckpointId()
public long getTriggerTimestamp()
public CheckpointProperties getProperties()
public int getNumberOfSubtasks()
public TaskStateStats getTaskStateStats(JobVertexID jobVertexId)
null
if no task with such an ID is available.jobVertexId
- Job vertex ID of the task stats to look up.null
.public Collection<TaskStateStats> getAllTaskStateStats()
public long getLatestAckTimestamp()
-1
if none was acknowledged yet.-1
.public long getEndToEndDuration()
-1
if
no subtask was acknowledged yet.-1
if no subtask was acknowledged yet.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.