public class CompletedCheckpoint extends Object implements Serializable
Externalized checkpoints have an external pointer, which points to the metadata. For example when externalizing to a file system, that pointer is the file path to the checkpoint's folder or the metadata file. For a state backend that stores metadata in database tables, the pointer could be the table name and row key. The pointer is encoded as a String.
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
StreamStateHandle externalizedMetadata,
String externalPointer) |
Modifier and Type | Method and Description |
---|---|
static boolean |
checkpointsMatch(Collection<CompletedCheckpoint> first,
Collection<CompletedCheckpoint> second) |
void |
discardOnFailedStoring() |
boolean |
discardOnShutdown(JobStatus jobStatus) |
boolean |
discardOnSubsume() |
boolean |
equals(Object o) |
long |
getCheckpointID() |
long |
getDuration() |
StreamStateHandle |
getExternalizedMetadata() |
String |
getExternalPointer() |
JobID |
getJobId() |
Collection<MasterState> |
getMasterHookStates() |
Map<OperatorID,OperatorState> |
getOperatorStates() |
CheckpointProperties |
getProperties() |
long |
getStateSize() |
long |
getTimestamp() |
int |
hashCode() |
boolean |
isExternalized() |
void |
registerSharedStatesAfterRestored(SharedStateRegistry sharedStateRegistry)
Register all shared states in the given registry.
|
String |
toString() |
public CompletedCheckpoint(JobID job, long checkpointID, long timestamp, long completionTimestamp, Map<OperatorID,OperatorState> operatorStates, @Nullable Collection<MasterState> masterHookStates, CheckpointProperties props, @Nullable StreamStateHandle externalizedMetadata, @Nullable String externalPointer)
public JobID getJobId()
public long getCheckpointID()
public long getTimestamp()
public long getDuration()
public CheckpointProperties getProperties()
public boolean discardOnShutdown(JobStatus jobStatus) throws Exception
Exception
public long getStateSize()
public Map<OperatorID,OperatorState> getOperatorStates()
public Collection<MasterState> getMasterHookStates()
public boolean isExternalized()
@Nullable public StreamStateHandle getExternalizedMetadata()
public static boolean checkpointsMatch(Collection<CompletedCheckpoint> first, Collection<CompletedCheckpoint> second)
public void registerSharedStatesAfterRestored(SharedStateRegistry sharedStateRegistry)
sharedStateRegistry
- The registry where shared states are registeredCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.