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) |
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 |
---|---|
Collection<MasterState> |
SavepointV2.getMasterStates() |
Collection<MasterState> |
SavepointV1.getMasterStates() |
Collection<MasterState> |
Savepoint.getMasterStates()
Gets the checkpointed states generated by the master.
|
Constructor and Description |
---|
SavepointV2(long checkpointId,
Collection<OperatorState> operatorStates,
Collection<MasterState> masterStates) |
Constructor and Description |
---|
MergeOperatorStates(Collection<MasterState> masterStates) |
Modifier and Type | Method and Description |
---|---|
Collection<MasterState> |
SavepointMetadata.getMasterStates() |
Constructor and Description |
---|
SavepointMetadata(int maxParallelism,
Collection<MasterState> masterStates,
Collection<OperatorState> initialStates) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.