public class PendingCheckpoint extends Object
CompletedCheckpoint
.
Note that the pending checkpoint, as well as the successful checkpoint keep the state handles always as serialized values, never as actual values.
Modifier and Type | Class and Description |
---|---|
static class |
PendingCheckpoint.TaskAcknowledgeResult
Result of the
acknowledgedTasks method. |
Constructor and Description |
---|
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
PendingCheckpoint.TaskAcknowledgeResult |
acknowledgeTask(ExecutionAttemptID executionAttemptId,
SerializedValue<StateHandle<?>> state,
long stateSize,
Map<Integer,SerializedValue<StateHandle<?>>> kvState) |
void |
discard(ClassLoader userClassLoader)
Discards the pending checkpoint, releasing all held resources.
|
CompletedCheckpoint |
finalizeCheckpoint() |
long |
getCheckpointId() |
long |
getCheckpointTimestamp() |
JobID |
getJobId() |
int |
getNumberOfAcknowledgedTasks() |
int |
getNumberOfNonAcknowledgedTasks() |
Map<JobVertexID,TaskState> |
getTaskStates() |
boolean |
isDiscarded() |
boolean |
isFullyAcknowledged() |
String |
toString() |
public PendingCheckpoint(JobID jobId, long checkpointId, long checkpointTimestamp, Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm, Executor executor)
public JobID getJobId()
public long getCheckpointId()
public long getCheckpointTimestamp()
public int getNumberOfNonAcknowledgedTasks()
public int getNumberOfAcknowledgedTasks()
public Map<JobVertexID,TaskState> getTaskStates()
public boolean isFullyAcknowledged()
public boolean isDiscarded()
public CompletedCheckpoint finalizeCheckpoint()
public PendingCheckpoint.TaskAcknowledgeResult acknowledgeTask(ExecutionAttemptID executionAttemptId, SerializedValue<StateHandle<?>> state, long stateSize, Map<Integer,SerializedValue<StateHandle<?>>> kvState)
public void discard(ClassLoader userClassLoader)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.