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 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