Class FsStateBackendFactory

    • Constructor Detail

      • FsStateBackendFactory

        public FsStateBackendFactory()
    • Method Detail

      • createFromConfig

        public FsStateBackend createFromConfig​(org.apache.flink.configuration.ReadableConfig config,
                                               ClassLoader classLoader)
                                        throws org.apache.flink.configuration.IllegalConfigurationException
        Description copied from interface: StateBackendFactory
        Creates the state backend, optionally using the given configuration.
        Specified by:
        createFromConfig in interface StateBackendFactory<FsStateBackend>
        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:
        org.apache.flink.configuration.IllegalConfigurationException - If the configuration misses critical values, or specifies invalid values