org.apache.flink.runtime.checkpoint

Class TaskStateStats.TaskStateStatsSummary

java.lang.Object

org.apache.flink.runtime.checkpoint.TaskStateStats.TaskStateStatsSummary

All Implemented Interfaces:

Serializable

Enclosing class:

TaskStateStats

public static class TaskStateStats.TaskStateStatsSummary
extends Object
implements Serializable

Summary of the subtask stats of a single task/operator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskStateStatsSummary()

Method Summary

Modifier and Type	Method and Description
MinMaxAvgStats	getAckTimestampStats() Returns the summary stats for the ACK timestamps.
MinMaxAvgStats	getAlignmentBufferedStats() Returns the summary stats for the buffered bytes during alignments.
MinMaxAvgStats	getAlignmentDurationStats() Returns the summary stats for the alignment duration.
MinMaxAvgStats	getAsyncCheckpointDurationStats() Returns the summary stats for the async checkpoint duration.
MinMaxAvgStats	getStateSizeStats() Returns the summary stats for the state size.
MinMaxAvgStats	getSyncCheckpointDurationStats() Returns the summary stats for the sync checkpoint duration.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskStateStatsSummary

public TaskStateStatsSummary()

Method Detail

getStateSizeStats

public MinMaxAvgStats getStateSizeStats()

Returns the summary stats for the state size.

Returns:

Summary stats for the state size.

getAckTimestampStats

public MinMaxAvgStats getAckTimestampStats()

Returns the summary stats for the ACK timestamps.

Returns:

Summary stats for the state size.

getSyncCheckpointDurationStats

public MinMaxAvgStats getSyncCheckpointDurationStats()

Returns the summary stats for the sync checkpoint duration.

Returns:

Summary stats for the sync checkpoint duration.

getAsyncCheckpointDurationStats

public MinMaxAvgStats getAsyncCheckpointDurationStats()

Returns the summary stats for the async checkpoint duration.

Returns:

Summary stats for the async checkpoint duration.

getAlignmentBufferedStats

public MinMaxAvgStats getAlignmentBufferedStats()

Returns the summary stats for the buffered bytes during alignments.

Returns:

Summary stats for the buffered state size during alignment.

getAlignmentDurationStats

public MinMaxAvgStats getAlignmentDurationStats()

Returns the summary stats for the alignment duration.

Returns:

Summary stats for the duration of the alignment.