public class PendingCheckpointStats extends AbstractCheckpointStats
This is the starting point for all checkpoint tracking. The life cycle of instances of this
class is tightly coupled to a PendingCheckpoint
instance, which forwards statistics about
acknowledged subtasks via reportSubtaskStats(JobVertexID, SubtaskStateStats)
.
Depending on whether the PendingCheckpoint
is finalized successfully or aborted, we
replace ourselves with a CompletedCheckpointStats
or FailedCheckpointStats
and
notify the CheckpointStatsTracker
.
The statistics gathered here are all live updated.
Modifier and Type | Method and Description |
---|---|
long |
getCheckpointedSize()
Returns the checkpointed size during that checkpoint.
|
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.
|
boolean |
isUnalignedCheckpoint() |
String |
toString() |
getAllTaskStateStats, getCheckpointId, getEndToEndDuration, 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 getCheckpointedSize()
AbstractCheckpointStats
getCheckpointedSize
in class AbstractCheckpointStats
public long getProcessedData()
getProcessedData
in class AbstractCheckpointStats
public long getPersistedData()
getPersistedData
in class AbstractCheckpointStats
public boolean isUnalignedCheckpoint()
isUnalignedCheckpoint
in class AbstractCheckpointStats
public SubtaskStateStats getLatestAcknowledgedSubtaskStats()
AbstractCheckpointStats
null
if none was acknowledged
yet.getLatestAcknowledgedSubtaskStats
in class AbstractCheckpointStats
null
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.