Interface StateBackendFactory<T extends StateBackend>

    • Method Detail

      • createFromConfig

        T createFromConfig​(ReadableConfig config,
                           ClassLoader classLoader)
                    throws IllegalConfigurationException,
                           IOException
        Creates the state backend, optionally using the given configuration.
        Parameters:
        config - The Flink configuration (loaded by the TaskManager).
        classLoader - The class loader that should be used to load the state backend.
        Returns:
        The created state backend.
        Throws:
        IllegalConfigurationException - If the configuration misses critical values, or specifies invalid values
        IOException - If the state backend initialization failed due to an I/O exception