org.apache.flink.runtime.rest.messages.checkpoints

Class CheckpointingStatistics.Summary

java.lang.Object

org.apache.flink.runtime.rest.messages.checkpoints.CheckpointingStatistics.Summary

Enclosing class:

CheckpointingStatistics

public static final class CheckpointingStatistics.Summary
extends Object

Checkpoint summary.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_ALIGNMENT_BUFFERED
static String	FIELD_NAME_DURATION
static String	FIELD_NAME_PERSISTED_DATA
static String	FIELD_NAME_PROCESSED_DATA
static String	FIELD_NAME_STATE_SIZE The accurate name of this field should be 'checkpointed_data_size', keep it as before to not break backwards compatibility for old web UI.

Constructor Summary

Constructors

Constructor and Description
Summary(MinMaxAvgStatistics stateSize, MinMaxAvgStatistics duration, MinMaxAvgStatistics alignmentBuffered, MinMaxAvgStatistics processedData, MinMaxAvgStatistics persistedData)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
MinMaxAvgStatistics	getDuration()
MinMaxAvgStatistics	getStateSize()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_STATE_SIZE

public static final String FIELD_NAME_STATE_SIZE

The accurate name of this field should be 'checkpointed_data_size', keep it as before to not break backwards compatibility for old web UI.

See Also:

FLINK-13390, Constant Field Values

FIELD_NAME_DURATION

public static final String FIELD_NAME_DURATION

See Also:

Constant Field Values

FIELD_NAME_ALIGNMENT_BUFFERED

public static final String FIELD_NAME_ALIGNMENT_BUFFERED

See Also:

Constant Field Values

FIELD_NAME_PROCESSED_DATA

public static final String FIELD_NAME_PROCESSED_DATA

See Also:

Constant Field Values

FIELD_NAME_PERSISTED_DATA

public static final String FIELD_NAME_PERSISTED_DATA

See Also:

Constant Field Values

Constructor Detail

Summary

public Summary(MinMaxAvgStatistics stateSize,
               MinMaxAvgStatistics duration,
               MinMaxAvgStatistics alignmentBuffered,
               MinMaxAvgStatistics processedData,
               MinMaxAvgStatistics persistedData)

Method Detail

getStateSize

public MinMaxAvgStatistics getStateSize()

getDuration

public MinMaxAvgStatistics getDuration()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object