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

Class CheckpointStatistics.FailedCheckpointStatistics

java.lang.Object

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

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

All Implemented Interfaces:

ResponseBody

Enclosing class:

CheckpointStatistics

public static final class CheckpointStatistics.FailedCheckpointStatistics
extends CheckpointStatistics

Statistics for a failed checkpoint.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics

CheckpointStatistics.CompletedCheckpointStatistics, CheckpointStatistics.FailedCheckpointStatistics, CheckpointStatistics.PendingCheckpointStatistics

Field Summary

Fields

Modifier and Type	Field	Description
static String	FIELD_NAME_FAILURE_MESSAGE
static String	FIELD_NAME_FAILURE_TIMESTAMP

Fields inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics

FIELD_NAME_ALIGNMENT_BUFFERED, FIELD_NAME_CHECKPOINT_TYPE, FIELD_NAME_CHECKPOINTED_SIZE, FIELD_NAME_DURATION, FIELD_NAME_ID, FIELD_NAME_IS_SAVEPOINT, FIELD_NAME_LATEST_ACK_TIMESTAMP, FIELD_NAME_NUM_ACK_SUBTASKS, FIELD_NAME_NUM_SUBTASKS, FIELD_NAME_PERSISTED_DATA, FIELD_NAME_PROCESSED_DATA, FIELD_NAME_SAVEPOINT_FORMAT, FIELD_NAME_STATE_SIZE, FIELD_NAME_STATUS, FIELD_NAME_TASKS, FIELD_NAME_TRIGGER_TIMESTAMP

Constructor Summary

Constructors

Constructor

Description

FailedCheckpointStatistics(long id, CheckpointStatsStatus status, boolean savepoint, String savepointFormat, long triggerTimestamp, long latestAckTimestamp, long checkpointedSize, long stateSize, long duration, long alignmentBuffered, long processedData, long persistedData, int numSubtasks, int numAckSubtasks, org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType, Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask, long failureTimestamp, String failureMessage)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getFailureMessage()
long	getFailureTimestamp()
int	hashCode()

Methods inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics

generateCheckpointStatistics, getCheckpointedSize, getCheckpointStatisticsPerTask, getCheckpointType, getDuration, getId, getLatestAckTimestamp, getNumAckSubtasks, getNumSubtasks, getStateSize, getStatus, getTriggerTimestamp, isSavepoint

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_FAILURE_TIMESTAMP

public static final String FIELD_NAME_FAILURE_TIMESTAMP

See Also:

Constant Field Values

FIELD_NAME_FAILURE_MESSAGE

public static final String FIELD_NAME_FAILURE_MESSAGE

See Also:

Constant Field Values

Constructor Detail

FailedCheckpointStatistics

public FailedCheckpointStatistics(long id,
                                  CheckpointStatsStatus status,
                                  boolean savepoint,
                                  String savepointFormat,
                                  long triggerTimestamp,
                                  long latestAckTimestamp,
                                  long checkpointedSize,
                                  long stateSize,
                                  long duration,
                                  long alignmentBuffered,
                                  long processedData,
                                  long persistedData,
                                  int numSubtasks,
                                  int numAckSubtasks,
                                  org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType checkpointType,
                                  Map<JobVertexID,TaskCheckpointStatistics> checkpointingStatisticsPerTask,
                                  long failureTimestamp,
                                  @Nullable
                                  String failureMessage)

Method Detail

getFailureTimestamp

public long getFailureTimestamp()

getFailureMessage

@Nullable
public String getFailureMessage()

equals

public boolean equals(Object o)

Overrides:

equals in class CheckpointStatistics

hashCode

public int hashCode()

Overrides:

hashCode in class CheckpointStatistics