Uses of Class
org.apache.flink.configuration.Configuration

Packages that use Configuration

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.cache
org.apache.flink.api.common.externalresource
org.apache.flink.api.common.functions
org.apache.flink.api.common.io
org.apache.flink.api.common.operators
org.apache.flink.api.common.serialization
org.apache.flink.api.common.typeutils
org.apache.flink.api.connector.source
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.configuration
org.apache.flink.core.execution
org.apache.flink.core.failure
org.apache.flink.core.fs
org.apache.flink.core.plugin
org.apache.flink.core.security
org.apache.flink.core.security.token
org.apache.flink.util

Uses of Configuration in org.apache.flink.api.common

Methods in org.apache.flink.api.common that return Configuration

Modifier and Type	Method	Description
Configuration	Plan.getJobConfiguration()
Configuration	ExecutionConfig.toConfiguration()

Methods in org.apache.flink.api.common with parameters of type Configuration

Modifier and Type	Method	Description
static String	RestartStrategyDescriptionUtils.getRestartStrategyDescription(Configuration configuration)	Returns a descriptive string of the restart strategy configured in the given Configuration object.
void	Plan.setJobConfiguration(Configuration jobConfiguration)

Constructors in org.apache.flink.api.common with parameters of type Configuration

Constructor	Description
ExecutionConfig(Configuration configuration)

Uses of Configuration in org.apache.flink.api.common.cache

Methods in org.apache.flink.api.common.cache with parameters of type Configuration

Modifier and Type	Method	Description
static Set<Map.Entry<String,DistributedCache.DistributedCacheEntry>>	DistributedCache.readFileInfoFromConfig(Configuration conf)
static void	DistributedCache.writeFileInfoToConfig(String name, DistributedCache.DistributedCacheEntry e, Configuration conf)

Uses of Configuration in org.apache.flink.api.common.externalresource

Methods in org.apache.flink.api.common.externalresource with parameters of type Configuration

Modifier and Type	Method	Description
ExternalResourceDriver	ExternalResourceDriverFactory.createExternalResourceDriver(Configuration config)	Construct the ExternalResourceDriver from configuration.

Uses of Configuration in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return Configuration

Modifier and Type	Method	Description
Configuration	WithConfigurationOpenContext.getConfiguration()

Constructors in org.apache.flink.api.common.functions with parameters of type Configuration

Constructor	Description
WithConfigurationOpenContext(Configuration configuration)

Uses of Configuration in org.apache.flink.api.common.io

Methods in org.apache.flink.api.common.io with parameters of type Configuration

Modifier and Type	Method	Description
void	BinaryInputFormat.configure(Configuration parameters)
void	BinaryOutputFormat.configure(Configuration parameters)
void	DelimitedInputFormat.configure(Configuration parameters)	Configures this input format by reading the path to the file from the configuration and the string that defines the record delimiter.
void	FileInputFormat.configure(Configuration parameters)	Configures the file input format by reading the file path from the configuration.
void	FileOutputFormat.configure(Configuration parameters)
void	GenericInputFormat.configure(Configuration parameters)
void	InputFormat.configure(Configuration parameters)	Configures this input format.
void	OutputFormat.configure(Configuration parameters)	Configures this output format.
void	ReplicatingInputFormat.configure(Configuration parameters)
static void	FileOutputFormat.initDefaultsFromConfiguration(Configuration configuration)	Initialize defaults for output format.
protected static void	DelimitedInputFormat.loadConfigParameters(Configuration parameters)

Constructors in org.apache.flink.api.common.io with parameters of type Configuration

Constructor	Description
DelimitedInputFormat(Path filePath, Configuration configuration)

Uses of Configuration in org.apache.flink.api.common.operators

Fields in org.apache.flink.api.common.operators declared as Configuration

Modifier and Type	Field	Description
protected Configuration	Operator.parameters

Methods in org.apache.flink.api.common.operators that return Configuration

Modifier and Type	Method	Description
Configuration	Operator.getParameters()	Gets the stub parameters of this contract.

Uses of Configuration in org.apache.flink.api.common.serialization

Constructors in org.apache.flink.api.common.serialization with parameters of type Configuration

Constructor	Description
SerializerConfigImpl(Configuration configuration)

Uses of Configuration in org.apache.flink.api.common.typeutils

Methods in org.apache.flink.api.common.typeutils with parameters of type Configuration

Modifier and Type	Method	Description
void	TypeComparatorFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	TypeSerializerFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	TypeComparatorFactory.writeParametersToConfig(Configuration config)
void	TypeSerializerFactory.writeParametersToConfig(Configuration config)

Uses of Configuration in org.apache.flink.api.connector.source

Methods in org.apache.flink.api.connector.source that return Configuration

Modifier and Type	Method	Description
Configuration	SourceReaderContext.getConfiguration()	Gets the configuration with which Flink was started.

Uses of Configuration in org.apache.flink.api.java.typeutils.runtime

Methods in org.apache.flink.api.java.typeutils.runtime with parameters of type Configuration

Modifier and Type	Method	Description
void	RuntimeComparatorFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	RuntimeSerializerFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	RuntimeComparatorFactory.writeParametersToConfig(Configuration config)
void	RuntimeSerializerFactory.writeParametersToConfig(Configuration config)

Uses of Configuration in org.apache.flink.configuration

Subclasses of Configuration in org.apache.flink.configuration

Modifier and Type	Class	Description
class	DelegatingConfiguration	A configuration that manages a subset of keys with a common prefix from a given configuration.
class	UnmodifiableConfiguration	Unmodifiable version of the Configuration class.

Methods in org.apache.flink.configuration that return Configuration

Modifier and Type	Method	Description
Configuration	Configuration.clone()
Configuration	DelegatingConfiguration.clone()
static Configuration	ConfigurationUtils.createConfiguration(Properties properties)	Creates a new Configuration from the given Properties.
static Configuration	EventOptions.forEventReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static Configuration	SecurityOptions.forProvider(Configuration configuration, String providerName)	Returns a view over the given configuration via which options can be set/retrieved for the given provider.
static Configuration	EventOptions.forReporter(Configuration configuration, String reporterName)
static Configuration	MetricOptions.forReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static Configuration	TraceOptions.forReporter(Configuration configuration, String reporterName)
static Configuration	TraceOptions.forTraceReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static Configuration	Configuration.fromMap(Map<String,String> map)	Creates a new configuration that is initialized with the options of the given map.
static Configuration	GlobalConfiguration.loadConfiguration()	Loads the global configuration from the environment.
static Configuration	GlobalConfiguration.loadConfiguration(String configDir)	Loads the configuration files from the specified directory.
static Configuration	GlobalConfiguration.loadConfiguration(String configDir, Configuration dynamicProperties)	Loads the configuration files from the specified directory.
static Configuration	GlobalConfiguration.loadConfiguration(Configuration dynamicProperties)	Loads the global configuration and adds the given dynamic properties configuration.
static Configuration	ConfigurationFileMigrationUtils.migrateLegacyToStandardYamlConfig(String configDir)	Migrates the legacy Flink configuration from the specified directory to a standard YAML format representation.
<T> Configuration	Configuration.set(ConfigOption<T> option, T value)
<T> Configuration	DelegatingConfiguration.set(ConfigOption<T> option, T value)

Methods in org.apache.flink.configuration with parameters of type Configuration

Modifier and Type	Method	Description
void	Configuration.addAll(Configuration other)
void	Configuration.addAll(Configuration other, String prefix)	Adds all entries from the given configuration into this configuration.
void	DelegatingConfiguration.addAll(Configuration other)
void	DelegatingConfiguration.addAll(Configuration other, String prefix)
void	UnmodifiableConfiguration.addAll(Configuration other)
void	UnmodifiableConfiguration.addAll(Configuration other, String prefix)
static List<String>	ConfigurationUtils.convertConfigToWritableLines(Configuration configuration, boolean flattenYaml)	Converts the provided configuration data into a format suitable for writing to a file, based on the flattenYaml flag and the standardYaml attribute of the configuration object.
static Configuration	EventOptions.forEventReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static Configuration	SecurityOptions.forProvider(Configuration configuration, String providerName)	Returns a view over the given configuration via which options can be set/retrieved for the given provider.
static Configuration	EventOptions.forReporter(Configuration configuration, String reporterName)
static Configuration	MetricOptions.forReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static Configuration	TraceOptions.forReporter(Configuration configuration, String reporterName)
static Configuration	TraceOptions.forTraceReporter(Configuration configuration, String reporterName)	Returns a view over the given configuration via which options can be set/retrieved for the given reporter.
static MetricOptions.JobStatusMetricsSettings	MetricOptions.JobStatusMetricsSettings.fromConfiguration(Configuration configuration)
static CheckpointingMode	CheckpointingOptions.getCheckpointingMode(Configuration config)	Gets the checkpointing mode from the configuration.
static String[]	CoreOptions.getPluginParentFirstLoaderPatterns(Configuration config)
static Map<String,String>	ConfigurationUtils.getPrefixedKeyValuePairs(String prefix, Configuration configuration)	Extract and parse Flink configuration properties with a given name prefix and return the result as a Map.
static File	ConfigurationUtils.getRandomTempDirectory(Configuration configuration)	Picks a temporary directory randomly from the given configuration.
static JobManagerOptions.SchedulerType	ClusterOptions.getSchedulerType(Configuration configuration)
static Duration	ConfigurationUtils.getStandaloneClusterStartupPeriodTime(Configuration configuration)
static Optional<Duration>	ConfigurationUtils.getSystemResourceMetricsProbingInterval(Configuration configuration)
static boolean	ClusterOptions.isAdaptiveSchedulerEnabled(Configuration configuration)
static boolean	CheckpointingOptions.isCheckpointingEnabled(Configuration config)	Determines whether checkpointing is enabled based on the configuration.
static boolean	RpcOptions.isForceRpcInvocationSerializationEnabled(Configuration config)
static boolean	SecurityOptions.isInternalSSLEnabled(Configuration sslConfig)	Checks whether SSL for internal communication (rpc, data transport, blob server) is enabled.
static boolean	ClusterOptions.isReactiveModeEnabled(Configuration configuration)
static boolean	SecurityOptions.isRestSSLAuthenticationEnabled(Configuration sslConfig)	Checks whether mutual SSL authentication for the external REST endpoint is enabled.
static boolean	SecurityOptions.isRestSSLEnabled(Configuration sslConfig)	Checks whether SSL for the external REST endpoint is enabled.
static boolean	CheckpointingOptions.isUnalignedCheckpointEnabled(Configuration config)	Determines whether unaligned checkpoints are enabled based on the configuration.
static boolean	CheckpointingOptions.isUnalignedCheckpointInterruptibleTimersEnabled(Configuration config)	Determines whether unaligned checkpoints with interruptible timers are enabled based on the configuration.
static Configuration	GlobalConfiguration.loadConfiguration(String configDir, Configuration dynamicProperties)	Loads the configuration files from the specified directory.
static Configuration	GlobalConfiguration.loadConfiguration(Configuration dynamicProperties)	Loads the global configuration and adds the given dynamic properties configuration.
static String[]	ConfigurationUtils.parseLocalStateDirectories(Configuration configuration)	Extracts the local state directories as defined by CheckpointingOptions.LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS.
static String[]	ConfigurationUtils.parseTempDirectories(Configuration configuration)	Extracts the task manager directories for temporary files as defined by CoreOptions.TMP_DIRS.

Constructors in org.apache.flink.configuration with parameters of type Configuration

Constructor	Description
Configuration(Configuration other)	Creates a new configuration with the copy of the given configuration.
DelegatingConfiguration(Configuration backingConfig, String prefix)	Creates a new delegating configuration which stores its key/value pairs in the given configuration using the specifies key prefix.
UnmodifiableConfiguration(Configuration config)	Creates a new UnmodifiableConfiguration, which holds a copy of the given configuration that cannot be altered.

Uses of Configuration in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution that return Configuration

Modifier and Type	Method	Description
Configuration	JobStatusChangedListenerFactory.Context.getConfiguration()

Methods in org.apache.flink.core.execution with parameters of type Configuration

Modifier and Type	Method	Description
static List<JobStatusChangedListener>	JobStatusChangedListenerUtils.createJobStatusChangedListeners(ClassLoader userClassLoader, Configuration configuration, Executor ioExecutor)	Create job status changed listeners from configuration for job.
CompletableFuture<JobClient>	PipelineExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)	Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g. cancel it or take a savepoint.
PipelineExecutor	PipelineExecutorFactory.getExecutor(Configuration configuration)	Instantiates an PipelineExecutor compatible with the provided configuration.
PipelineExecutorFactory	DefaultExecutorServiceLoader.getExecutorFactory(Configuration configuration)
PipelineExecutorFactory	PipelineExecutorServiceLoader.getExecutorFactory(Configuration configuration)	Loads the PipelineExecutorFactory which is compatible with the provided configuration.
CompletableFuture<Void>	CacheSupportedPipelineExecutor.invalidateClusterDataset(AbstractID clusterDatasetId, Configuration configuration, ClassLoader userCodeClassloader)	Invalidate the cluster dataset with the given id.
boolean	PipelineExecutorFactory.isCompatibleWith(Configuration configuration)	Returns true if this factory is compatible with the options in the provided configuration, false otherwise.
CompletableFuture<Set<AbstractID>>	CacheSupportedPipelineExecutor.listCompletedClusterDatasetIds(Configuration configuration, ClassLoader userCodeClassloader)	Return a set of ids of the completed cluster dataset.

Uses of Configuration in org.apache.flink.core.failure

Methods in org.apache.flink.core.failure with parameters of type Configuration

Modifier and Type	Method	Description
FailureEnricher	FailureEnricherFactory.createFailureEnricher(Configuration conf)	Construct a FailureEnricher.

Uses of Configuration in org.apache.flink.core.fs

Methods in org.apache.flink.core.fs with parameters of type Configuration

Modifier and Type	Method	Description
void	ConnectionLimitingFactory.configure(Configuration config)
void	PluginFileSystemFactory.configure(Configuration config)
static FileSystemFactory	ConnectionLimitingFactory.decorateIfLimited(FileSystemFactory factory, String scheme, Configuration config)	Decorates the given factory for a ConnectionLimitingFactory, if the given configuration configured connection limiting for the given file system scheme.
static LimitedConnectionsFileSystem.ConnectionLimitingSettings	LimitedConnectionsFileSystem.ConnectionLimitingSettings.fromConfig(Configuration config, String fsScheme)	Parses and returns the settings for connection limiting, for the file system with the given file system scheme.
static void	FileSystem.initialize(Configuration config)	Deprecated. use FileSystem.initialize(Configuration, PluginManager) instead.
static void	FileSystem.initialize(Configuration config, PluginManager pluginManager)	Initializes the shared file system settings.

Uses of Configuration in org.apache.flink.core.plugin

Methods in org.apache.flink.core.plugin with parameters of type Configuration

Modifier and Type	Method	Description
default void	Plugin.configure(Configuration config)	Optional method for plugins to pick up settings from the configuration.
static PluginManager	PluginUtils.createPluginManagerFromRootFolder(Configuration configuration)
static PluginConfig	PluginConfig.fromConfiguration(Configuration configuration)

Uses of Configuration in org.apache.flink.core.security

Methods in org.apache.flink.core.security with parameters of type Configuration

Modifier and Type	Method	Description
static void	FlinkSecurityManager.setFromConfiguration(Configuration configuration)

Uses of Configuration in org.apache.flink.core.security.token

Methods in org.apache.flink.core.security.token with parameters of type Configuration

Modifier and Type	Method	Description
void	DelegationTokenProvider.init(Configuration configuration)	Called by DelegationTokenManager to initialize provider after construction.
void	DelegationTokenReceiver.init(Configuration configuration)	Called to initialize receiver after construction.

Uses of Configuration in org.apache.flink.util

Methods in org.apache.flink.util that return Configuration

Modifier and Type	Method	Description
Configuration	ParameterTool.getConfiguration()	Returns a Configuration object from this ParameterTool.

Methods in org.apache.flink.util with parameters of type Configuration

Modifier and Type	Method	Description
void	Utils.ChecksumHashCodeHelper.configure(Configuration parameters)
void	Utils.CollectHelper.configure(Configuration parameters)
void	Utils.CountHelper.configure(Configuration parameters)
static <T> T	InstantiationUtil.readObjectFromConfig(Configuration config, String key, ClassLoader cl)
static void	InstantiationUtil.writeObjectToConfig(Object o, Configuration config, String key)