Package | Description |
---|---|
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
static StateBackend |
StateBackendLoader.fromApplicationOrConfigOrDefault(StateBackend fromApplication,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
This is the state backend loader that loads a
DelegatingStateBackend wrapping the
state backend loaded from StateBackendLoader.loadFromApplicationOrConfigOrDefaultInternal(org.apache.flink.runtime.state.StateBackend, org.apache.flink.configuration.Configuration, java.lang.ClassLoader, org.slf4j.Logger) when delegation is enabled. |
static Optional<CheckpointStorage> |
CheckpointStorageLoader.fromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the checkpoint storage from the configuration, from the parameter
'state.checkpoint-storage', as defined in
CheckpointingOptions.CHECKPOINT_STORAGE . |
static CheckpointStorage |
CheckpointStorageLoader.load(CheckpointStorage fromApplication,
Path defaultSavepointDirectory,
StateBackend configuredStateBackend,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the configured
CheckpointStorage for the job based on the following precedent
rules: |
static StateBackend |
StateBackendLoader.loadStateBackendFromConfig(ReadableConfig config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.