Package org.apache.flink.runtime.state
Interface CheckpointStorageFactory<T extends CheckpointStorage>
-
- Type Parameters:
T
- The type of the checkpoint storage created.
@PublicEvolving public interface CheckpointStorageFactory<T extends CheckpointStorage>
A factory to create a specificCheckpointStorage
. The storage creation gets a configuration object that can be used to read further config values.The checkpoint storage factory is typically specified in the configuration to produce a configured storage backend.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description T
createFromConfig(ReadableConfig config, ClassLoader classLoader)
Creates the checkpoint storage, optionally using the given configuration.
-
-
-
Method Detail
-
createFromConfig
T createFromConfig(ReadableConfig config, ClassLoader classLoader) throws IllegalConfigurationException
Creates the checkpoint storage, optionally using the given configuration.- Parameters:
config
- The Flink configuration (loaded by the TaskManager).classLoader
- The clsas loader that should be used to load the checkpoint storage.- Returns:
- The created checkpoint storage.
- Throws:
IllegalConfigurationException
- If the configuration misses critical values, or specifies invalid values
-
-