Package org.apache.flink.runtime.checkpoint

Class CompletedCheckpointStats

java.lang.Object

org.apache.flink.runtime.checkpoint.AbstractCheckpointStats

org.apache.flink.runtime.checkpoint.CompletedCheckpointStats

All Implemented Interfaces:

Serializable

public class CompletedCheckpointStats
extends AbstractCheckpointStats

Statistics for a successfully completed checkpoint.

The reported statistics are immutable except for the discarded flag, which is updated via the DiscardCallback and the CompletedCheckpoint after an instance of this class has been created.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
long	getCheckpointedSize()	Returns the checkpointed size during that checkpoint.
String	getExternalPath()	Returns the external pointer of this 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	isDiscarded()	Returns whether the checkpoint has been discarded.
boolean	isUnalignedCheckpoint()
String	toString()

Methods inherited from class org.apache.flink.runtime.checkpoint.AbstractCheckpointStats

getAllTaskStateStats, getCheckpointId, getEndToEndDuration, getLatestAckTimestamp, getNumberOfSubtasks, getProperties, getTaskStateStats, getTriggerTimestamp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getStatus

public CheckpointStatsStatus getStatus()

Description copied from class: AbstractCheckpointStats

Returns the status of this checkpoint.

Specified by:

getStatus in class AbstractCheckpointStats

Returns:

Status of this checkpoint

getNumberOfAcknowledgedSubtasks

public int getNumberOfAcknowledgedSubtasks()

Description copied from class: AbstractCheckpointStats

Returns the number of acknowledged subtasks.

Specified by:

getNumberOfAcknowledgedSubtasks in class AbstractCheckpointStats

Returns:

The number of acknowledged subtasks.

getStateSize

public long getStateSize()

Description copied from class: AbstractCheckpointStats

Returns the total checkpoint state size over all subtasks.

Specified by:

getStateSize in class AbstractCheckpointStats

Returns:

Total checkpoint state size over all subtasks.

getCheckpointedSize

public long getCheckpointedSize()

Description copied from class: AbstractCheckpointStats

Returns the checkpointed size during that checkpoint.

Specified by:

getCheckpointedSize in class AbstractCheckpointStats

Returns:

The checkpointed size during that checkpoint.

getProcessedData

public long getProcessedData()

Specified by:

getProcessedData in class AbstractCheckpointStats

Returns:

the total number of processed bytes during the checkpoint.

getPersistedData

public long getPersistedData()

Specified by:

getPersistedData in class AbstractCheckpointStats

Returns:

the total number of persisted bytes during the checkpoint.

isUnalignedCheckpoint

public boolean isUnalignedCheckpoint()

Specified by:

isUnalignedCheckpoint in class AbstractCheckpointStats

Returns:

whether the checkpoint is unaligned.

getLatestAcknowledgedSubtaskStats

@Nullable
public SubtaskStateStats getLatestAcknowledgedSubtaskStats()

Description copied from class: AbstractCheckpointStats

Returns the latest acknowledged subtask stats or null if none was acknowledged yet.

Specified by:

getLatestAcknowledgedSubtaskStats in class AbstractCheckpointStats

Returns:

Latest acknowledged subtask stats or null

getExternalPath

public String getExternalPath()

Returns the external pointer of this checkpoint.

isDiscarded

public boolean isDiscarded()

Returns whether the checkpoint has been discarded.

Returns:

true if the checkpoint has been discarded, false otherwise.

toString

public String toString()

Overrides:

toString in class Object