Modifier and Type | Method and Description |
---|---|
Collection<MasterState> |
CompletedCheckpoint.getMasterHookStates() |
List<MasterState> |
PendingCheckpoint.getMasterStates() |
Modifier and Type | Method and Description |
---|---|
void |
PendingCheckpoint.acknowledgeMasterState(String identifier,
MasterState state)
Acknowledges a master state (state generated on the checkpoint coordinator) to the pending
checkpoint.
|
Constructor and Description |
---|
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats) |
CompletedCheckpoint(JobID job,
long checkpointID,
long timestamp,
long completionTimestamp,
Map<OperatorID,OperatorState> operatorStates,
Collection<MasterState> masterHookStates,
CheckpointProperties props,
CompletedCheckpointStorageLocation storageLocation,
CompletedCheckpointStats completedCheckpointStats,
CheckpointProperties restoredProps) |
Modifier and Type | Method and Description |
---|---|
static <T> CompletableFuture<MasterState> |
MasterHooks.triggerHook(MasterTriggerRestoreHook<T> hook,
long checkpointId,
long timestamp,
Executor executor)
Trigger master hook and return a completable future with state.
|
Modifier and Type | Method and Description |
---|---|
static void |
MasterHooks.restoreMasterHooks(Map<String,MasterTriggerRestoreHook<?>> masterHooks,
Collection<MasterState> states,
long checkpointId,
boolean allowUnmatchedState,
org.slf4j.Logger log)
Calls the restore method given checkpoint master hooks and passes the given master state to
them where state with a matching name is found.
|
Modifier and Type | Method and Description |
---|---|
protected MasterState |
MetadataV2V3SerializerBase.deserializeMasterState(DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
Collection<MasterState> |
CheckpointMetadata.getMasterStates() |
Modifier and Type | Method and Description |
---|---|
protected void |
MetadataV2V3SerializerBase.serializeMasterState(MasterState state,
DataOutputStream dos) |
Constructor and Description |
---|
CheckpointMetadata(long checkpointId,
Collection<OperatorState> operatorStates,
Collection<MasterState> masterStates) |
CheckpointMetadata(long checkpointId,
Collection<OperatorState> operatorStates,
Collection<MasterState> masterStates,
CheckpointProperties properties) |
Constructor and Description |
---|
MergeOperatorStates(Collection<MasterState> masterStates) |
Modifier and Type | Method and Description |
---|---|
Collection<MasterState> |
SavepointMetadataV2.getMasterStates() |
Collection<MasterState> |
SavepointMetadata.getMasterStates()
Deprecated.
|
Constructor and Description |
---|
SavepointMetadata(int maxParallelism,
Collection<MasterState> masterStates,
Collection<OperatorState> initialStates)
Deprecated.
|
SavepointMetadataV2(int maxParallelism,
Collection<MasterState> masterStates,
Collection<OperatorState> initialStates) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.