Package org.apache.flink.runtime.state
Interface SharedStateRegistryFactory
-
public interface SharedStateRegistryFactory
Simple factory to produceSharedStateRegistry
objects.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description SharedStateRegistry
create(Executor deleteExecutor, Collection<CompletedCheckpoint> checkpoints, RecoveryClaimMode recoveryClaimMode)
Factory method forSharedStateRegistry
.
-
-
-
Method Detail
-
create
SharedStateRegistry create(Executor deleteExecutor, Collection<CompletedCheckpoint> checkpoints, RecoveryClaimMode recoveryClaimMode)
Factory method forSharedStateRegistry
.- Parameters:
deleteExecutor
- executor used to run (async) deletes.checkpoints
- whose shared state will be registered.recoveryClaimMode
- the mode in which the given checkpoints were restored- Returns:
- a SharedStateRegistry object
-
-