org.apache.flink.runtime.checkpoint

Class CompletedCheckpointStatsSummary

java.lang.Object

org.apache.flink.runtime.checkpoint.CompletedCheckpointStatsSummary

All Implemented Interfaces:

Serializable

public class CompletedCheckpointStatsSummary
extends Object
implements Serializable

Summary over all completed checkpoints.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
MinMaxAvgStats	getAlignmentBufferedStats() Returns the summary stats for the bytes buffered during alignment.
MinMaxAvgStats	getEndToEndDurationStats() Returns the summary stats for the duration of completed checkpoints.
MinMaxAvgStats	getStateSizeStats() Returns the summary stats for the state size of completed checkpoints.

Methods inherited from class java.lang.Object

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

Method Detail

getStateSizeStats

public MinMaxAvgStats getStateSizeStats()

Returns the summary stats for the state size of completed checkpoints.

Returns:

Summary stats for the state size.

getEndToEndDurationStats

public MinMaxAvgStats getEndToEndDurationStats()

Returns the summary stats for the duration of completed checkpoints.

Returns:

Summary stats for the duration.

getAlignmentBufferedStats

public MinMaxAvgStats getAlignmentBufferedStats()

Returns the summary stats for the bytes buffered during alignment.

If no alignments are reported or happen (at least once mode), the returned stats are in their initial state.

Returns:

Summary stats for the bytes buffered during alignment.