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

Class CheckpointStatistics.PendingCheckpointStatistics

java.lang.Object

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

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

All Implemented Interfaces:

ResponseBody

Enclosing class:

CheckpointStatistics

public static final class CheckpointStatistics.PendingCheckpointStatistics
extends CheckpointStatistics

Statistics for a pending 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 inherited from class org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics

FIELD_NAME_ALIGNMENT_BUFFERED, FIELD_NAME_CHECKPOINT_TYPE, 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_STATE_SIZE, FIELD_NAME_STATUS, FIELD_NAME_TASKS, FIELD_NAME_TRIGGER_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description

PendingCheckpointStatistics(long id, CheckpointStatsStatus status, boolean savepoint, long triggerTimestamp, long latestAckTimestamp, 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)

Method Summary

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

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

generateCheckpointStatistics, 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

Constructor Detail

PendingCheckpointStatistics

public PendingCheckpointStatistics(long id,
                                   CheckpointStatsStatus status,
                                   boolean savepoint,
                                   long triggerTimestamp,
                                   long latestAckTimestamp,
                                   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)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class CheckpointStatistics

hashCode

public int hashCode()

Overrides:

hashCode in class CheckpointStatistics