public class CheckpointStatistics extends Object implements ResponseBody
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.
|
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_ALIGNMENT_BUFFERED |
static String |
FIELD_NAME_CHECKPOINT_TYPE |
static String |
FIELD_NAME_CHECKPOINTED_SIZE |
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_SAVEPOINT_FORMAT |
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 |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
static CheckpointStatistics |
generateCheckpointStatistics(AbstractCheckpointStats checkpointStats,
boolean includeTaskCheckpointStatistics) |
long |
getCheckpointedSize() |
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() |
public static final String FIELD_NAME_ID
public static final String FIELD_NAME_STATUS
public static final String FIELD_NAME_IS_SAVEPOINT
public static final String FIELD_NAME_SAVEPOINT_FORMAT
public static final String FIELD_NAME_TRIGGER_TIMESTAMP
public static final String FIELD_NAME_LATEST_ACK_TIMESTAMP
public static final String FIELD_NAME_CHECKPOINTED_SIZE
public static final String FIELD_NAME_STATE_SIZE
public static final String FIELD_NAME_DURATION
public static final String FIELD_NAME_ALIGNMENT_BUFFERED
public static final String FIELD_NAME_PROCESSED_DATA
public static final String FIELD_NAME_PERSISTED_DATA
public static final String FIELD_NAME_NUM_SUBTASKS
public static final String FIELD_NAME_NUM_ACK_SUBTASKS
public static final String FIELD_NAME_TASKS
public static final String FIELD_NAME_CHECKPOINT_TYPE
public long getId()
public CheckpointStatsStatus getStatus()
public boolean isSavepoint()
public long getTriggerTimestamp()
public long getLatestAckTimestamp()
public long getCheckpointedSize()
public long getStateSize()
public long getDuration()
public int getNumSubtasks()
public int getNumAckSubtasks()
public org.apache.flink.runtime.rest.messages.checkpoints.CheckpointStatistics.RestAPICheckpointType getCheckpointType()
@Nullable public Map<JobVertexID,TaskCheckpointStatistics> getCheckpointStatisticsPerTask()
public static CheckpointStatistics generateCheckpointStatistics(AbstractCheckpointStats checkpointStats, boolean includeTaskCheckpointStatistics)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.