Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.checkpoint.hooks | |
org.apache.flink.runtime.checkpoint.savepoint |
Modifier and Type | Method and Description |
---|---|
Collection<MasterState> |
CompletedCheckpoint.getMasterHookStates() |
Modifier and Type | Method and Description |
---|---|
void |
PendingCheckpoint.addMasterState(MasterState state)
Adds 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 List<MasterState> |
MasterHooks.triggerMasterHooks(Collection<MasterTriggerRestoreHook<?>> hooks,
long checkpointId,
long timestamp,
Executor executor,
Time timeout)
Triggers all given master hooks and returns state objects for each hook that
produced a 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) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.