public class FailedCheckpointStats extends AbstractCheckpointStats
The reported statistics are immutable.
Modifier and Type | Method and Description |
---|---|
long |
getEndToEndDuration()
Returns the end to end duration until the checkpoint failure.
|
String |
getFailureMessage()
Returns the failure message or
null if no cause was provided. |
long |
getFailureTimestamp()
Returns the timestamp when this checkpoint failed.
|
SubtaskStateStats |
getLatestAcknowledgedSubtaskStats()
Returns the latest acknowledged subtask stats or
null if none was acknowledged
yet. |
int |
getNumberOfAcknowledgedSubtasks()
Returns the number of acknowledged subtasks.
|
long |
getPersistedData() |
long |
getProcessedData() |
long |
getStateSize()
Returns the total checkpoint state size over all subtasks.
|
CheckpointStatsStatus |
getStatus()
Returns the status of this checkpoint.
|
getAllTaskStateStats, getCheckpointId, getLatestAckTimestamp, getNumberOfSubtasks, getProperties, getTaskStateStats, getTriggerTimestamp
public CheckpointStatsStatus getStatus()
AbstractCheckpointStats
getStatus
in class AbstractCheckpointStats
public int getNumberOfAcknowledgedSubtasks()
AbstractCheckpointStats
getNumberOfAcknowledgedSubtasks
in class AbstractCheckpointStats
public long getStateSize()
AbstractCheckpointStats
getStateSize
in class AbstractCheckpointStats
public long getProcessedData()
getProcessedData
in class AbstractCheckpointStats
public long getPersistedData()
getPersistedData
in class AbstractCheckpointStats
@Nullable public SubtaskStateStats getLatestAcknowledgedSubtaskStats()
AbstractCheckpointStats
null
if none was acknowledged
yet.getLatestAcknowledgedSubtaskStats
in class AbstractCheckpointStats
null
public long getEndToEndDuration()
getEndToEndDuration
in class AbstractCheckpointStats
-1
if no subtask was acknowledged yet.public long getFailureTimestamp()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.