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.
Constructor and Description |
---|
PendingCheckpoint(JobID jobId,
long checkpointId,
long checkpointTimestamp,
Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm) |
Modifier and Type | Method and Description |
---|---|
boolean |
acknowledgeTask(ExecutionAttemptID attemptID,
SerializedValue<StateHandle<?>> state,
long stateSize) |
void |
discard(ClassLoader userClassLoader)
Discards the pending checkpoint, releasing all held resources.
|
long |
getCheckpointId() |
long |
getCheckpointTimestamp() |
List<StateForTask> |
getCollectedStates() |
JobID |
getJobId() |
int |
getNumberOfAcknowledgedTasks() |
int |
getNumberOfNonAcknowledgedTasks() |
boolean |
isDiscarded() |
boolean |
isFullyAcknowledged() |
CompletedCheckpoint |
toCompletedCheckpoint() |
String |
toString() |
public PendingCheckpoint(JobID jobId, long checkpointId, long checkpointTimestamp, Map<ExecutionAttemptID,ExecutionVertex> verticesToConfirm)
public JobID getJobId()
public long getCheckpointId()
public long getCheckpointTimestamp()
public int getNumberOfNonAcknowledgedTasks()
public int getNumberOfAcknowledgedTasks()
public boolean isFullyAcknowledged()
public boolean isDiscarded()
public List<StateForTask> getCollectedStates()
public CompletedCheckpoint toCompletedCheckpoint()
public boolean acknowledgeTask(ExecutionAttemptID attemptID, SerializedValue<StateHandle<?>> state, long stateSize)
public void discard(ClassLoader userClassLoader)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.