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 specific CheckpointStorage. 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

Modifier and Type	Method and 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