org.apache.flink.runtime.checkpoint

Class SubtaskStateStats

java.lang.Object

org.apache.flink.runtime.checkpoint.SubtaskStateStats

All Implemented Interfaces:

Serializable

public class SubtaskStateStats
extends Object
implements Serializable

Statistics for a single subtask that is part of a checkpoint.

Collects data that is spread over different close places: CheckpointMetaData, SubtaskState, and PendingCheckpoint.

This is the smallest immutable unit of the stats.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
long	getAckTimestamp() Returns the timestamp when the acknowledgement of this subtask was received at the coordinator.
long	getAlignmentDuration()
long	getAsyncCheckpointDuration()
long	getCheckpointedSize() Returns the incremental state size.
long	getCheckpointStartDelay()
long	getEndToEndDuration(long triggerTimestamp) Computes the duration since the given trigger timestamp.
long	getPersistedData()
long	getProcessedData()
long	getStateSize() Returns the size of the checkpointed state at this subtask.
int	getSubtaskIndex()
long	getSyncCheckpointDuration()
boolean	getUnalignedCheckpoint()
boolean	isCompleted()

Methods inherited from class java.lang.Object

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

Method Detail

getSubtaskIndex

public int getSubtaskIndex()

getStateSize

public long getStateSize()

Returns the size of the checkpointed state at this subtask.

Returns:

Checkpoint state size of the sub task.

getCheckpointedSize

public long getCheckpointedSize()

Returns the incremental state size.

Returns:

The incremental state size.

getAckTimestamp

public long getAckTimestamp()

Returns the timestamp when the acknowledgement of this subtask was received at the coordinator.

Returns:

ACK timestamp at the coordinator.

getEndToEndDuration

public long getEndToEndDuration(long triggerTimestamp)

Computes the duration since the given trigger timestamp.

If the trigger timestamp is greater than the ACK timestamp, this returns 0.

Parameters:

triggerTimestamp - Trigger timestamp of the checkpoint.

Returns:

Duration since the given trigger timestamp.

getSyncCheckpointDuration

public long getSyncCheckpointDuration()

Returns:

Duration of the synchronous part of the checkpoint or -1 if the runtime did not report this.

getAsyncCheckpointDuration

public long getAsyncCheckpointDuration()

Returns:

Duration of the asynchronous part of the checkpoint or -1 if the runtime did not report this.

getProcessedData

public long getProcessedData()

Returns:

the total number of processed bytes during the checkpoint.

getPersistedData

public long getPersistedData()

Returns:

the total number of persisted bytes during the checkpoint.

getAlignmentDuration

public long getAlignmentDuration()

Returns:

Duration of the stream alignment (for exactly-once only) or -1 if the runtime did not report this.

getCheckpointStartDelay

public long getCheckpointStartDelay()

getUnalignedCheckpoint

public boolean getUnalignedCheckpoint()

isCompleted

public boolean isCompleted()