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

Class CheckpointStatistics

java.lang.Object

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

All Implemented Interfaces:

ResponseBody

Direct Known Subclasses:

CheckpointStatistics.CompletedCheckpointStatistics, CheckpointStatistics.FailedCheckpointStatistics, CheckpointStatistics.PendingCheckpointStatistics

public class CheckpointStatistics
extends Object
implements ResponseBody

Statistics for a checkpoint.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CheckpointStatistics.CompletedCheckpointStatistics Statistics for a completed checkpoint.
static class	CheckpointStatistics.FailedCheckpointStatistics Statistics for a failed checkpoint.
static class	CheckpointStatistics.PendingCheckpointStatistics Statistics for a pending checkpoint.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_ALIGNMENT_BUFFERED
static String	FIELD_NAME_CHECKPOINT_TYPE
static String	FIELD_NAME_DURATION
static String	FIELD_NAME_ID
static String	FIELD_NAME_IS_SAVEPOINT
static String	FIELD_NAME_LATEST_ACK_TIMESTAMP
static String	FIELD_NAME_NUM_ACK_SUBTASKS
static String	FIELD_NAME_NUM_SUBTASKS
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.
static String	FIELD_NAME_STATUS
static String	FIELD_NAME_TASKS
static String	FIELD_NAME_TRIGGER_TIMESTAMP

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static CheckpointStatistics	generateCheckpointStatistics(AbstractCheckpointStats checkpointStats, boolean includeTaskCheckpointStatistics)
Map<JobVertexID,TaskCheckpointStatistics>	getCheckpointStatisticsPerTask()
org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType	getCheckpointType()
long	getDuration()
long	getId()
long	getLatestAckTimestamp()
int	getNumAckSubtasks()
int	getNumSubtasks()
long	getStateSize()
CheckpointStatsStatus	getStatus()
long	getTriggerTimestamp()
int	hashCode()
boolean	isSavepoint()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_ID

public static final String FIELD_NAME_ID

See Also:

Constant Field Values

FIELD_NAME_STATUS

public static final String FIELD_NAME_STATUS

See Also:

Constant Field Values

FIELD_NAME_IS_SAVEPOINT

public static final String FIELD_NAME_IS_SAVEPOINT

See Also:

Constant Field Values

FIELD_NAME_TRIGGER_TIMESTAMP

public static final String FIELD_NAME_TRIGGER_TIMESTAMP

See Also:

Constant Field Values

FIELD_NAME_LATEST_ACK_TIMESTAMP

public static final String FIELD_NAME_LATEST_ACK_TIMESTAMP

See Also:

Constant Field Values

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

FIELD_NAME_NUM_SUBTASKS

public static final String FIELD_NAME_NUM_SUBTASKS

See Also:

Constant Field Values

FIELD_NAME_NUM_ACK_SUBTASKS

public static final String FIELD_NAME_NUM_ACK_SUBTASKS

See Also:

Constant Field Values

FIELD_NAME_TASKS

public static final String FIELD_NAME_TASKS

See Also:

Constant Field Values

FIELD_NAME_CHECKPOINT_TYPE

public static final String FIELD_NAME_CHECKPOINT_TYPE

See Also:

Constant Field Values

Method Detail

getId

public long getId()

getStatus

public CheckpointStatsStatus getStatus()

isSavepoint

public boolean isSavepoint()

getTriggerTimestamp

public long getTriggerTimestamp()

getLatestAckTimestamp

public long getLatestAckTimestamp()

getStateSize

public long getStateSize()

getDuration

public long getDuration()

getNumSubtasks

public int getNumSubtasks()

getNumAckSubtasks

public int getNumAckSubtasks()

getCheckpointType

public org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType getCheckpointType()

getCheckpointStatisticsPerTask

@Nullable
public Map<JobVertexID,TaskCheckpointStatistics> getCheckpointStatisticsPerTask()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

generateCheckpointStatistics

public static CheckpointStatistics generateCheckpointStatistics(AbstractCheckpointStats checkpointStats,
                                                                boolean includeTaskCheckpointStatistics)