public static final class CheckpointStatistics.CompletedCheckpointStatistics extends CheckpointStatistics
CheckpointStatistics.CompletedCheckpointStatistics, CheckpointStatistics.FailedCheckpointStatistics, CheckpointStatistics.PendingCheckpointStatistics
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_DISCARDED |
static String |
FIELD_NAME_EXTERNAL_PATH |
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 and Description |
---|
CompletedCheckpointStatistics(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,
String externalPath,
boolean discarded) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
getExternalPath() |
int |
hashCode() |
boolean |
isDiscarded() |
generateCheckpointStatistics, getCheckpointedSize, getCheckpointStatisticsPerTask, getCheckpointType, getDuration, getId, getLatestAckTimestamp, getNumAckSubtasks, getNumSubtasks, getStateSize, getStatus, getTriggerTimestamp, isSavepoint
public static final String FIELD_NAME_EXTERNAL_PATH
public static final String FIELD_NAME_DISCARDED
public CompletedCheckpointStatistics(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, @Nullable String externalPath, boolean discarded)
public boolean isDiscarded()
public boolean equals(Object o)
equals
in class CheckpointStatistics
public int hashCode()
hashCode
in class CheckpointStatistics
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.