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

Packages that use Configuration

Package	Description
org.apache.flink.api.common.cache
org.apache.flink.api.common.externalresource
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.io
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.typeutils
org.apache.flink.api.connector.source
org.apache.flink.api.java
org.apache.flink.api.java.hadoop.mapred
org.apache.flink.api.java.hadoop.mapred.utils
org.apache.flink.api.java.hadoop.mapreduce
org.apache.flink.api.java.io
org.apache.flink.api.java.operators
org.apache.flink.api.java.operators.translation
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.api.java.utils
org.apache.flink.batch.connectors.cassandra
org.apache.flink.batch.tests
org.apache.flink.cep.functions.adaptors
org.apache.flink.cep.nfa
org.apache.flink.cep.pattern.conditions
org.apache.flink.client
org.apache.flink.client.cli
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.application.cli
org.apache.flink.client.deployment.application.executors
org.apache.flink.client.deployment.executors
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.configuration
org.apache.flink.connector.base.source.reader
org.apache.flink.connector.file.src.impl
org.apache.flink.connector.file.src.reader
org.apache.flink.connector.hbase.sink
org.apache.flink.connector.hbase1.source
org.apache.flink.connector.hbase2.source
org.apache.flink.connector.jdbc
org.apache.flink.connector.jdbc.internal
org.apache.flink.connector.jdbc.table
org.apache.flink.connector.jdbc.xa	Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
org.apache.flink.connector.kafka.source.reader
org.apache.flink.connector.testutils.source.reader
org.apache.flink.connectors.hive
org.apache.flink.connectors.hive.read
org.apache.flink.core.execution
org.apache.flink.core.fs
org.apache.flink.core.plugin
org.apache.flink.examples.java.clustering
org.apache.flink.examples.java.distcp
org.apache.flink.examples.java.relational
org.apache.flink.externalresource.gpu
org.apache.flink.formats.parquet
org.apache.flink.fs.azurefs
org.apache.flink.fs.osshadoop
org.apache.flink.fs.s3.common
org.apache.flink.graph
org.apache.flink.hadoopcompatibility.mapred
org.apache.flink.hcatalog
org.apache.flink.kubernetes
org.apache.flink.kubernetes.cli
org.apache.flink.kubernetes.configuration
org.apache.flink.kubernetes.entrypoint
org.apache.flink.kubernetes.executors
org.apache.flink.kubernetes.highavailability
org.apache.flink.kubernetes.kubeclient
org.apache.flink.kubernetes.kubeclient.parameters
org.apache.flink.kubernetes.utils
org.apache.flink.mesos.entrypoint
org.apache.flink.mesos.runtime.clusterframework
org.apache.flink.mesos.runtime.clusterframework.services
org.apache.flink.mesos.util
org.apache.flink.optimizer
org.apache.flink.optimizer.plantranslate
org.apache.flink.orc
org.apache.flink.python
org.apache.flink.python.util
org.apache.flink.runtime.blob
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.clusterframework.overlays
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.entrypoint
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease
org.apache.flink.runtime.externalresource
org.apache.flink.runtime.fs.hdfs
org.apache.flink.runtime.heartbeat
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.metrics
org.apache.flink.runtime.metrics.scope
org.apache.flink.runtime.metrics.util
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.net
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.operators.util
org.apache.flink.runtime.registration
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.resourcemanager.active
org.apache.flink.runtime.resourcemanager.slotmanager
org.apache.flink.runtime.rest
org.apache.flink.runtime.rest.handler
org.apache.flink.runtime.rest.handler.cluster
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.legacy.metrics
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.rpc.akka
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptive.scalingpolicy
org.apache.flink.runtime.security
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.state
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.util
org.apache.flink.runtime.util.bash
org.apache.flink.runtime.util.config.memory
org.apache.flink.runtime.util.config.memory.jobmanager
org.apache.flink.runtime.util.config.memory.taskmanager
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.handlers.utils
org.apache.flink.runtime.webmonitor.history
org.apache.flink.runtime.webmonitor.utils
org.apache.flink.runtime.zookeeper
org.apache.flink.state.api.functions
org.apache.flink.state.api.input
org.apache.flink.state.api.input.operator.window
org.apache.flink.state.api.output
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.source.datagen
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.operators.python
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.connectors.cassandra
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.gcp.pubsub
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.connectors.rabbitmq
org.apache.flink.streaming.connectors.twitter
org.apache.flink.streaming.experimental	This package holds classes that are experimental.
org.apache.flink.streaming.kafka.test.base
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.operators.windowing.functions
org.apache.flink.streaming.tests
org.apache.flink.streaming.util
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.client.cli
org.apache.flink.table.client.config
org.apache.flink.table.client.gateway.context
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.filesystem
org.apache.flink.table.filesystem.stream
org.apache.flink.table.filesystem.stream.compact
org.apache.flink.table.functions
org.apache.flink.table.planner.plan.abilities.source
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.processor.utils
org.apache.flink.table.planner.plan.nodes.exec.serde
org.apache.flink.table.planner.plan.nodes.exec.utils
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.table.runtime.functions.python
org.apache.flink.table.runtime.functions.python.arrow
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.join.interval
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.runtime.operators.match
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.python
org.apache.flink.table.runtime.operators.python.aggregate
org.apache.flink.table.runtime.operators.python.aggregate.arrow
org.apache.flink.table.runtime.operators.python.aggregate.arrow.batch
org.apache.flink.table.runtime.operators.python.aggregate.arrow.stream
org.apache.flink.table.runtime.operators.python.scalar
org.apache.flink.table.runtime.operators.python.scalar.arrow
org.apache.flink.table.runtime.operators.python.table
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.sort
org.apache.flink.test
org.apache.flink.test.util
org.apache.flink.tests.util.flink
org.apache.flink.util
org.apache.flink.walkthrough.common.sink
org.apache.flink.yarn
org.apache.flink.yarn.cli
org.apache.flink.yarn.configuration
org.apache.flink.yarn.entrypoint
org.apache.flink.yarn.executors

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 and 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 and 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 with parameters of type Configuration

Modifier and Type	Method and Description
void	RichFunction.open(Configuration parameters) Initialization method for the function.
void	AbstractRichFunction.open(Configuration parameters)

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

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

Modifier and Type	Method and Description
static void	FunctionUtils.openFunction(Function function, Configuration parameters)

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 and Description
void	BinaryInputFormat.configure(Configuration parameters)
void	FileOutputFormat.configure(Configuration parameters)
void	FileInputFormat.configure(Configuration parameters) Configures the file input format by reading the file path from the configuration.
void	GenericInputFormat.configure(Configuration parameters)
void	BinaryOutputFormat.configure(Configuration parameters)
void	InputFormat.configure(Configuration parameters) Configures this input format.
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	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 and 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 and Description
protected Configuration	Operator.parameters

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

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

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

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

Modifier and Type	Method and Description
void	BulkIterationBase.TerminationCriterionMapper.open(Configuration parameters)

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 and 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 and Description
Configuration	SourceReaderContext.getConfiguration() Gets the configuration with which Flink was started.

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

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

Modifier and Type	Method and Description
Configuration	ScalaShellStreamEnvironment.getClientConfiguration()
Configuration	ExecutionEnvironment.getConfiguration()

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

Modifier and Type	Method and Description
void	Utils.CountHelper.configure(Configuration parameters)
void	Utils.CollectHelper.configure(Configuration parameters)
void	Utils.ChecksumHashCodeHelper.configure(Configuration parameters)
static LocalEnvironment	ExecutionEnvironment.createLocalEnvironment(Configuration customConfiguration) Creates a LocalEnvironment.
static ExecutionEnvironment	ExecutionEnvironment.createLocalEnvironmentWithWebUI(Configuration conf) Creates a LocalEnvironment for local program execution that also starts the web monitoring UI.
static ExecutionEnvironment	ExecutionEnvironment.createRemoteEnvironment(String host, int port, Configuration clientConfiguration, String... jarFiles) Creates a RemoteEnvironment.
static void	RemoteEnvironmentConfigUtils.setJarURLsToConfig(String[] jars, Configuration configuration)
static void	RemoteEnvironmentConfigUtils.setJobManagerAddressToConfig(String host, int port, Configuration configuration)

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

Constructor and Description
ExecutionEnvironment(Configuration configuration) Creates a new ExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.
ExecutionEnvironment(Configuration configuration, ClassLoader userClassloader) Creates a new ExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.
ExecutionEnvironment(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userClassloader) Creates a new ExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.
LocalEnvironment(Configuration config) Creates a new local environment that configures its local executor with the given configuration.
RemoteEnvironment(String host, int port, Configuration clientConfig, String[] jarFiles) Creates a new RemoteEnvironment that points to the master (JobManager) described by the given host name and port.
RemoteEnvironment(String host, int port, Configuration clientConfig, String[] jarFiles, URL[] globalClasspaths) Creates a new RemoteEnvironment that points to the master (JobManager) described by the given host name and port.
ScalaShellEnvironment(Configuration configuration, org.apache.flink.api.scala.FlinkILoop flinkILoop, String... jarFiles)
ScalaShellStreamEnvironment(Configuration configuration, org.apache.flink.api.scala.FlinkILoop flinkILoop, String... jarFiles)

Uses of Configuration in org.apache.flink.api.java.hadoop.mapred

Methods in org.apache.flink.api.java.hadoop.mapred with parameters of type Configuration

Modifier and Type	Method and Description
void	HadoopInputFormatBase.configure(Configuration parameters)
void	HadoopOutputFormatBase.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.api.java.hadoop.mapred.utils

Methods in org.apache.flink.api.java.hadoop.mapred.utils with parameters of type Configuration

Modifier and Type	Method and Description
static Configuration	HadoopUtils.getHadoopConfiguration(Configuration flinkConfiguration) Returns a new Hadoop Configuration object using the path to the hadoop conf configured in the main configuration (flink-conf.yaml).
static String[]	HadoopUtils.possibleHadoopConfPaths(Configuration flinkConfiguration) Get possible Hadoop conf dir paths, based on environment variables and flink configuration.

Uses of Configuration in org.apache.flink.api.java.hadoop.mapreduce

Methods in org.apache.flink.api.java.hadoop.mapreduce with parameters of type Configuration

Modifier and Type	Method and Description
void	HadoopInputFormatBase.configure(Configuration parameters)
void	HadoopOutputFormatBase.configure(Configuration parameters)

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

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

Modifier and Type	Method and Description
void	TextInputFormat.configure(Configuration parameters)
void	BlockingShuffleOutputFormat.configure(Configuration parameters)
void	LocalCollectionOutputFormat.configure(Configuration parameters)
void	PrintingOutputFormat.configure(Configuration parameters)
void	TextValueInputFormat.configure(Configuration parameters)
void	DiscardingOutputFormat.configure(Configuration parameters)

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

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

Modifier and Type	Method and Description
Configuration	UdfOperator.getParameters() Gets the configuration parameters that will be passed to the UDF's open method AbstractRichFunction.open(Configuration).
Configuration	SingleInputUdfOperator.getParameters()
Configuration	DataSource.getParameters()
Configuration	TwoInputUdfOperator.getParameters()
Configuration	DataSink.getParameters()

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

Modifier and Type	Method and Description
O	UdfOperator.withParameters(Configuration parameters) Sets the configuration parameters for the UDF.
O	SingleInputUdfOperator.withParameters(Configuration parameters)
DataSource<OUT>	DataSource.withParameters(Configuration parameters) Pass a configuration to the InputFormat.
O	TwoInputUdfOperator.withParameters(Configuration parameters)
DataSink<T>	DataSink.withParameters(Configuration parameters) Pass a configuration to the OutputFormat.

Uses of Configuration in org.apache.flink.api.java.operators.translation

Methods in org.apache.flink.api.java.operators.translation with parameters of type Configuration

Modifier and Type	Method and Description
void	RichCombineToGroupCombineWrapper.open(Configuration config)
void	WrappingFunction.open(Configuration parameters)

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 and Description
void	RuntimeSerializerFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	RuntimeComparatorFactory.readParametersFromConfig(Configuration config, ClassLoader cl)
void	RuntimeSerializerFactory.writeParametersToConfig(Configuration config)
void	RuntimeComparatorFactory.writeParametersToConfig(Configuration config)

Uses of Configuration in org.apache.flink.api.java.utils

Methods in org.apache.flink.api.java.utils that return Configuration

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

Uses of Configuration in org.apache.flink.batch.connectors.cassandra

Methods in org.apache.flink.batch.connectors.cassandra with parameters of type Configuration

Modifier and Type	Method and Description
void	CassandraInputFormatBase.configure(Configuration parameters)
void	CassandraOutputFormatBase.configure(Configuration parameters)
void	CassandraPojoOutputFormat.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.batch.tests

Methods in org.apache.flink.batch.tests with parameters of type Configuration

Modifier and Type	Method and Description
void	Generator.configure(Configuration parameters)
void	BlockingIncrementingMapFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.cep.functions.adaptors

Methods in org.apache.flink.cep.functions.adaptors with parameters of type Configuration

Modifier and Type	Method and Description
void	PatternSelectAdapter.open(Configuration parameters)
void	PatternTimeoutFlatSelectAdapter.open(Configuration parameters)
void	PatternFlatSelectAdapter.open(Configuration parameters)
void	PatternTimeoutSelectAdapter.open(Configuration parameters)

Uses of Configuration in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa with parameters of type Configuration

Modifier and Type	Method and Description
void	NFA.open(RuntimeContext cepRuntimeContext, Configuration conf) Initialization method for the NFA.

Uses of Configuration in org.apache.flink.cep.pattern.conditions

Methods in org.apache.flink.cep.pattern.conditions with parameters of type Configuration

Modifier and Type	Method and Description
void	RichCompositeIterativeCondition.open(Configuration parameters)
void	RichIterativeCondition.open(Configuration parameters)

Uses of Configuration in org.apache.flink.client

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

Modifier and Type	Method and Description
static URLClassLoader	ClientUtils.buildUserCodeClassLoader(List<URL> jars, List<URL> classpaths, ClassLoader parent, Configuration configuration)
static void	ClientUtils.executeProgram(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, PackagedProgram program, boolean enforceSingleJobExecution, boolean suppressSysout)
static JobGraph	FlinkPipelineTranslationUtil.getJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) Transmogrifies the given Pipeline to a JobGraph.
static JobGraph	FlinkPipelineTranslationUtil.getJobGraphUnderUserClassLoader(ClassLoader userClassloader, Pipeline pipeline, Configuration configuration, int defaultParallelism) Transmogrifies the given Pipeline under the userClassloader to a JobGraph.
JobGraph	FlinkPipelineTranslator.translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph.
JobGraph	PlanTranslator.translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
JobGraph	StreamGraphTranslator.translateToJobGraph(Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)

Uses of Configuration in org.apache.flink.client.cli

Methods in org.apache.flink.client.cli that return Configuration

Modifier and Type	Method and Description
Configuration	ExecutionConfigAccessor.applyToConfiguration(Configuration baseConfiguration)
Configuration	CliFrontend.getConfiguration() Getter which returns a copy of the associated configuration.
Configuration	CustomCommandLine.toConfiguration(org.apache.commons.cli.CommandLine commandLine) Materializes the command line arguments in the given CommandLine to a Configuration and returns it.
Configuration	AbstractCustomCommandLine.toConfiguration(org.apache.commons.cli.CommandLine commandLine)
Configuration	DefaultCLI.toConfiguration(org.apache.commons.cli.CommandLine commandLine)
Configuration	GenericCLI.toConfiguration(org.apache.commons.cli.CommandLine commandLine)

Methods in org.apache.flink.client.cli with parameters of type Configuration

Modifier and Type	Method and Description
void	PythonProgramOptions.applyToConfiguration(Configuration configuration)
Configuration	ExecutionConfigAccessor.applyToConfiguration(Configuration baseConfiguration)
void	ProgramOptions.applyToConfiguration(Configuration configuration)
static void	ProgramOptionsUtils.configurePythonExecution(Configuration configuration, PackagedProgram packagedProgram)
protected void	CliFrontend.executeProgram(Configuration configuration, PackagedProgram program)
static ExecutionConfigAccessor	ExecutionConfigAccessor.fromConfiguration(Configuration configuration) Creates an ExecutionConfigAccessor based on the provided Configuration.
static List<CustomCommandLine>	CliFrontend.loadCustomCommandLines(Configuration configuration, String configurationDirectory)
<ClusterID> void	ApplicationDeployer.run(Configuration configuration, ApplicationConfiguration applicationConfiguration) Submits a user program for execution and runs the main user method on the cluster.

Constructors in org.apache.flink.client.cli with parameters of type Configuration

Constructor and Description
CliFrontend(Configuration configuration, ClusterClientServiceLoader clusterClientServiceLoader, List<CustomCommandLine> customCommandLines)
CliFrontend(Configuration configuration, List<CustomCommandLine> customCommandLines)
GenericCLI(Configuration configuration, String configDir)

Uses of Configuration in org.apache.flink.client.deployment

Methods in org.apache.flink.client.deployment with parameters of type Configuration

Modifier and Type	Method and Description
ClusterDescriptor<ClusterID>	ClusterClientFactory.createClusterDescriptor(Configuration configuration) Create a ClusterDescriptor from the given configuration.
StandaloneClusterDescriptor	StandaloneClientFactory.createClusterDescriptor(Configuration configuration)
<ClusterID> ClusterClientFactory<ClusterID>	ClusterClientServiceLoader.getClusterClientFactory(Configuration configuration) Discovers the appropriate ClusterClientFactory based on the provided configuration.
<ClusterID> ClusterClientFactory<ClusterID>	DefaultClusterClientServiceLoader.getClusterClientFactory(Configuration configuration)
ClusterID	ClusterClientFactory.getClusterId(Configuration configuration) Returns the cluster id if a cluster id is specified in the provided configuration, otherwise it returns null.
StandaloneClusterId	StandaloneClientFactory.getClusterId(Configuration configuration)
ClusterSpecification	ClusterClientFactory.getClusterSpecification(Configuration configuration) Returns the ClusterSpecification specified by the configuration and the command line options.
ClusterSpecification	StandaloneClientFactory.getClusterSpecification(Configuration configuration)
ClusterSpecification	AbstractContainerizedClusterClientFactory.getClusterSpecification(Configuration configuration)
boolean	ClusterClientFactory.isCompatibleWith(Configuration configuration) Returns true if the current ClusterClientFactory is compatible with the provided configuration, false otherwise.
boolean	StandaloneClientFactory.isCompatibleWith(Configuration configuration)

Constructors in org.apache.flink.client.deployment with parameters of type Configuration

Constructor and Description
StandaloneClusterDescriptor(Configuration config)

Uses of Configuration in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type Configuration

Modifier and Type	Method and Description
void	ApplicationConfiguration.applyToConfiguration(Configuration configuration)
protected static void	ApplicationClusterEntryPoint.configureExecution(Configuration configuration, PackagedProgram program)
static ApplicationDispatcherLeaderProcessFactoryFactory	ApplicationDispatcherLeaderProcessFactoryFactory.create(Configuration configuration, DispatcherFactory dispatcherFactory, PackagedProgram program)
protected DispatcherResourceManagerComponentFactory	ApplicationClusterEntryPoint.createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected ExecutionGraphInfoStore	ApplicationClusterEntryPoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
static ApplicationConfiguration	ApplicationConfiguration.fromConfiguration(Configuration configuration)
static ClassPathPackagedProgramRetriever.Builder	ClassPathPackagedProgramRetriever.newBuilder(String[] programArguments, Configuration configuration)
List<JobID>	DetachedApplicationRunner.run(DispatcherGateway dispatcherGateway, PackagedProgram program, Configuration configuration)
List<JobID>	ApplicationRunner.run(DispatcherGateway dispatcherGateway, PackagedProgram program, Configuration configuration) Runs the application using the provided dispatcherGateway.

Constructors in org.apache.flink.client.deployment.application with parameters of type Configuration

Constructor and Description
ApplicationClusterEntryPoint(Configuration configuration, PackagedProgram program, ResourceManagerFactory<?> resourceManagerFactory)
ApplicationDispatcherBootstrap(PackagedProgram application, Collection<JobID> recoveredJobIds, Configuration configuration, DispatcherGateway dispatcherGateway, ScheduledExecutor scheduledExecutor, FatalErrorHandler errorHandler)
ApplicationDispatcherGatewayServiceFactory(Configuration configuration, DispatcherFactory dispatcherFactory, PackagedProgram application, RpcService rpcService, PartialDispatcherServices partialDispatcherServices)

Uses of Configuration in org.apache.flink.client.deployment.application.cli

Methods in org.apache.flink.client.deployment.application.cli with parameters of type Configuration

Modifier and Type	Method and Description
<ClusterID> void	ApplicationClusterDeployer.run(Configuration configuration, ApplicationConfiguration applicationConfiguration)

Uses of Configuration in org.apache.flink.client.deployment.application.executors

Methods in org.apache.flink.client.deployment.application.executors with parameters of type Configuration

Modifier and Type	Method and Description
CompletableFuture<JobClient>	EmbeddedExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
PipelineExecutor	WebSubmissionExecutorFactory.getExecutor(Configuration configuration)
PipelineExecutor	EmbeddedExecutorFactory.getExecutor(Configuration configuration)
PipelineExecutorFactory	WebSubmissionExecutorServiceLoader.getExecutorFactory(Configuration configuration)
PipelineExecutorFactory	EmbeddedExecutorServiceLoader.getExecutorFactory(Configuration configuration)
boolean	WebSubmissionExecutorFactory.isCompatibleWith(Configuration configuration)
boolean	EmbeddedExecutorFactory.isCompatibleWith(Configuration configuration)

Uses of Configuration in org.apache.flink.client.deployment.executors

Methods in org.apache.flink.client.deployment.executors with parameters of type Configuration

Modifier and Type	Method and Description
static LocalExecutor	LocalExecutor.create(Configuration configuration)
static LocalExecutor	LocalExecutor.createWithFactory(Configuration configuration, java.util.function.Function<MiniClusterConfiguration,MiniCluster> miniClusterFactory)
CompletableFuture<JobClient>	AbstractSessionClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
CompletableFuture<JobClient>	LocalExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
CompletableFuture<JobClient>	AbstractJobClusterExecutor.execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
PipelineExecutor	LocalExecutorFactory.getExecutor(Configuration configuration)
PipelineExecutor	RemoteExecutorFactory.getExecutor(Configuration configuration)
static JobGraph	PipelineExecutorUtils.getJobGraph(Pipeline pipeline, Configuration configuration) Creates the JobGraph corresponding to the provided Pipeline.
boolean	LocalExecutorFactory.isCompatibleWith(Configuration configuration)
boolean	RemoteExecutorFactory.isCompatibleWith(Configuration configuration)

Uses of Configuration in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return Configuration

Modifier and Type	Method and Description
Configuration	MiniClusterClient.getFlinkConfiguration()
Configuration	ClusterClient.getFlinkConfiguration() Return the Flink configuration object.

Methods in org.apache.flink.client.program with parameters of type Configuration

Modifier and Type	Method and Description
static JobGraph	PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism, boolean suppressOutput) Creates a JobGraph with a random JobID from the given PackagedProgram.
static JobGraph	PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism, JobID jobID, boolean suppressOutput) Creates a JobGraph with a specified JobID from the given PackagedProgram.
static PerJobMiniClusterFactory	PerJobMiniClusterFactory.createWithFactory(Configuration configuration, java.util.function.Function<? super MiniClusterConfiguration,? extends MiniCluster> miniClusterFactory)
static Pipeline	PackagedProgramUtils.getPipelineFromProgram(PackagedProgram program, Configuration configuration, int parallelism, boolean suppressOutput)
static void	ContextEnvironment.setAsContext(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)
static void	StreamContextEnvironment.setAsContext(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)
PackagedProgram.Builder	PackagedProgram.Builder.setConfiguration(Configuration configuration)

Constructors in org.apache.flink.client.program with parameters of type Configuration

Constructor and Description
ContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)
MiniClusterClient(Configuration configuration, MiniCluster miniCluster)
OptimizerPlanEnvironment(Configuration configuration, ClassLoader userClassloader, int parallelism)
StreamContextEnvironment(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userCodeClassLoader, boolean enforceSingleJobExecution, boolean suppressSysout)
StreamPlanEnvironment(Configuration configuration, ClassLoader userClassLoader, int parallelism)

Uses of Configuration in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest that return Configuration

Modifier and Type	Method and Description
Configuration	RestClusterClient.getFlinkConfiguration()

Methods in org.apache.flink.client.program.rest with parameters of type Configuration

Modifier and Type	Method and Description
static RestClusterClientConfiguration	RestClusterClientConfiguration.fromConfiguration(Configuration config)

Constructors in org.apache.flink.client.program.rest with parameters of type Configuration

Constructor and Description
RestClusterClient(Configuration config, T clusterId)
RestClusterClient(Configuration config, T clusterId, ClientHighAvailabilityServices clientHAServices)

Uses of Configuration in org.apache.flink.configuration

Subclasses of Configuration in org.apache.flink.configuration

Modifier and Type	Class and 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 and Description
Configuration	DelegatingConfiguration.clone()
Configuration	Configuration.clone()
static Configuration	ConfigurationUtils.createConfiguration(Properties properties) Creates a new Configuration from the given Properties.
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(Configuration dynamicProperties) Loads the global configuration and adds the given dynamic properties configuration.
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.
<T> Configuration	DelegatingConfiguration.set(ConfigOption<T> option, T value)
<T> Configuration	Configuration.set(ConfigOption<T> option, T value)

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

Modifier and Type	Method and Description
void	DelegatingConfiguration.addAll(Configuration other)
void	UnmodifiableConfiguration.addAll(Configuration other)
void	Configuration.addAll(Configuration other)
void	DelegatingConfiguration.addAll(Configuration other, String prefix)
void	UnmodifiableConfiguration.addAll(Configuration other, String prefix)
void	Configuration.addAll(Configuration other, String prefix) Adds all entries from the given configuration into this configuration.
static String[]	CoreOptions.getParentFirstLoaderPatterns(Configuration config)
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 JobManagerOptions.SchedulerType	ClusterOptions.getSchedulerType(Configuration configuration)
static Time	ConfigurationUtils.getStandaloneClusterStartupPeriodTime(Configuration configuration)
static Optional<Time>	ConfigurationUtils.getSystemResourceMetricsProbingInterval(Configuration configuration)
static boolean	ClusterOptions.isAdaptiveSchedulerEnabled(Configuration configuration)
static boolean	ClusterOptions.isDeclarativeResourceManagementEnabled(Configuration configuration)
static boolean	ClusterOptions.isFineGrainedResourceManagementEnabled(Configuration configuration)
static Configuration	GlobalConfiguration.loadConfiguration(Configuration dynamicProperties) Loads the global configuration and adds the given dynamic properties configuration.
static Configuration	GlobalConfiguration.loadConfiguration(String configDir, Configuration dynamicProperties) Loads the configuration files from the specified directory.
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 and 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.connector.base.source.reader

Fields in org.apache.flink.connector.base.source.reader declared as Configuration

Modifier and Type	Field and Description
protected Configuration	SourceReaderBase.config The raw configurations that may be used by subclasses.

Constructors in org.apache.flink.connector.base.source.reader with parameters of type Configuration

Constructor and Description
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SingleThreadFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context) This constructor behaves like SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext), but accepts a specific FutureCompletingBlockingQueue and SingleThreadFetcherManager.
SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context) This constructor behaves like SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext), but accepts a specific FutureCompletingBlockingQueue.
SingleThreadMultiplexSourceReaderBase(java.util.function.Supplier<SplitReader<E,SplitT>> splitReaderSupplier, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context) The primary constructor for the source reader.
SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>> elementsQueue, SplitFetcherManager<E,SplitT> splitFetcherManager, RecordEmitter<E,T,SplitStateT> recordEmitter, Configuration config, SourceReaderContext context)
SourceReaderOptions(Configuration config)

Uses of Configuration in org.apache.flink.connector.file.src.impl

Methods in org.apache.flink.connector.file.src.impl with parameters of type Configuration

Modifier and Type	Method and Description
BulkFormat.Reader<T>	StreamFormatAdapter.createReader(Configuration config, FileSourceSplit split)
BulkFormat.Reader<T>	FileRecordFormatAdapter.createReader(Configuration config, FileSourceSplit split)
BulkFormat.Reader<T>	StreamFormatAdapter.restoreReader(Configuration config, FileSourceSplit split)
BulkFormat.Reader<T>	FileRecordFormatAdapter.restoreReader(Configuration config, FileSourceSplit split)

Constructors in org.apache.flink.connector.file.src.impl with parameters of type Configuration

Constructor and Description
FileSourceReader(SourceReaderContext readerContext, BulkFormat<T,SplitT> readerFormat, Configuration config)

Uses of Configuration in org.apache.flink.connector.file.src.reader

Methods in org.apache.flink.connector.file.src.reader with parameters of type Configuration

Modifier and Type	Method and Description
abstract StreamFormat.Reader<T>	SimpleStreamFormat.createReader(Configuration config, FSDataInputStream stream) Creates a new reader.
TextLineFormat.Reader	TextLineFormat.createReader(Configuration config, FSDataInputStream stream)
StreamFormat.Reader<T>	SimpleStreamFormat.createReader(Configuration config, FSDataInputStream stream, long fileLen, long splitEnd)
StreamFormat.Reader<T>	StreamFormat.createReader(Configuration config, FSDataInputStream stream, long fileLen, long splitEnd) Creates a new reader to read in this format.
FileRecordFormat.Reader<T>	FileRecordFormat.createReader(Configuration config, Path filePath, long splitOffset, long splitLength) Creates a new reader to read in this format.
BulkFormat.Reader<T>	BulkFormat.createReader(Configuration config, SplitT split) Creates a new reader that reads from the split's path starting at the FileSourceSplit.offset() split's offset} and reads length bytes after the offset.
StreamFormat.Reader<T>	SimpleStreamFormat.restoreReader(Configuration config, FSDataInputStream stream, long restoredOffset, long fileLen, long splitEnd)
StreamFormat.Reader<T>	StreamFormat.restoreReader(Configuration config, FSDataInputStream stream, long restoredOffset, long fileLen, long splitEnd) Restores a reader from a checkpointed position.
FileRecordFormat.Reader<T>	FileRecordFormat.restoreReader(Configuration config, Path filePath, long restoredOffset, long splitOffset, long splitLength) Restores a reader from a checkpointed position.
BulkFormat.Reader<T>	BulkFormat.restoreReader(Configuration config, SplitT split) Creates a new reader that reads from split.path() starting at offset and reads until length bytes after the offset.

Uses of Configuration in org.apache.flink.connector.hbase.sink

Methods in org.apache.flink.connector.hbase.sink with parameters of type Configuration

Modifier and Type	Method and Description
void	HBaseSinkFunction.open(Configuration parameters)

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

Methods in org.apache.flink.connector.hbase1.source with parameters of type Configuration

Modifier and Type	Method and Description
void	AbstractTableInputFormat.configure(Configuration parameters)

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

Methods in org.apache.flink.connector.hbase2.source with parameters of type Configuration

Modifier and Type	Method and Description
void	AbstractTableInputFormat.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.connector.jdbc

Methods in org.apache.flink.connector.jdbc with parameters of type Configuration

Modifier and Type	Method and Description
void	JdbcInputFormat.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.connector.jdbc.internal

Methods in org.apache.flink.connector.jdbc.internal with parameters of type Configuration

Modifier and Type	Method and Description
void	AbstractJdbcOutputFormat.configure(Configuration parameters)
void	GenericJdbcSinkFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.connector.jdbc.table

Methods in org.apache.flink.connector.jdbc.table with parameters of type Configuration

Modifier and Type	Method and Description
void	JdbcRowDataInputFormat.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.connector.jdbc.xa

Methods in org.apache.flink.connector.jdbc.xa with parameters of type Configuration

Modifier and Type	Method and Description
void	JdbcXaSinkFunction.open(Configuration configuration)

Uses of Configuration in org.apache.flink.connector.kafka.source.reader

Constructors in org.apache.flink.connector.kafka.source.reader with parameters of type Configuration

Constructor and Description
KafkaSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<Tuple3<T,Long,Long>>> elementsQueue, KafkaSourceFetcherManager<T> kafkaSourceFetcherManager, RecordEmitter<Tuple3<T,Long,Long>,T,KafkaPartitionSplitState> recordEmitter, Configuration config, SourceReaderContext context, KafkaSourceReaderMetrics kafkaSourceReaderMetrics)

Uses of Configuration in org.apache.flink.connector.testutils.source.reader

Methods in org.apache.flink.connector.testutils.source.reader that return Configuration

Modifier and Type	Method and Description
Configuration	TestingReaderContext.getConfiguration()

Constructors in org.apache.flink.connector.testutils.source.reader with parameters of type Configuration

Constructor and Description
TestingReaderContext(Configuration config, MetricGroup metricGroup)

Uses of Configuration in org.apache.flink.connectors.hive

Constructors in org.apache.flink.connectors.hive with parameters of type Configuration

Constructor and Description
HiveContinuousPartitionFetcherContext(ObjectPath tablePath, HiveShim hiveShim, JobConfWrapper confWrapper, List<String> partitionKeys, DataType[] fieldTypes, String[] fieldNames, Configuration configuration, String defaultPartitionName)

Uses of Configuration in org.apache.flink.connectors.hive.read

Fields in org.apache.flink.connectors.hive.read declared as Configuration

Modifier and Type	Field and Description
protected Configuration	HivePartitionFetcherContextBase.configuration

Methods in org.apache.flink.connectors.hive.read with parameters of type Configuration

Modifier and Type	Method and Description
void	HiveTableInputFormat.configure(Configuration parameters)
void	HiveTableFileInputFormat.configure(Configuration parameters)
BulkFormat.Reader<RowData>	HiveBulkFormatAdapter.createReader(Configuration config, HiveSourceSplit split)
BulkFormat.Reader<RowData>	HiveBulkFormatAdapter.restoreReader(Configuration config, HiveSourceSplit split)

Constructors in org.apache.flink.connectors.hive.read with parameters of type Configuration

Constructor and Description
HivePartitionFetcherContextBase(ObjectPath tablePath, HiveShim hiveShim, JobConfWrapper confWrapper, List<String> partitionKeys, DataType[] fieldTypes, String[] fieldNames, Configuration configuration, String defaultPartitionName)

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

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

Modifier and Type	Method and Description
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.
PipelineExecutor	PipelineExecutorFactory.getExecutor(Configuration configuration) Instantiates an PipelineExecutor compatible with the provided configuration.
PipelineExecutorFactory	PipelineExecutorServiceLoader.getExecutorFactory(Configuration configuration) Loads the PipelineExecutorFactory which is compatible with the provided configuration.
PipelineExecutorFactory	DefaultExecutorServiceLoader.getExecutorFactory(Configuration configuration)
boolean	PipelineExecutorFactory.isCompatibleWith(Configuration configuration) Returns true if this factory is compatible with the options in the provided configuration, false otherwise.

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 and Description
void	PluginFileSystemFactory.configure(Configuration config)
void	ConnectionLimitingFactory.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 and 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.examples.java.clustering

Methods in org.apache.flink.examples.java.clustering with parameters of type Configuration

Modifier and Type	Method and Description
void	KMeans.SelectNearestCenter.open(Configuration parameters) Reads the centroid values from a broadcast variable into a collection.

Uses of Configuration in org.apache.flink.examples.java.distcp

Methods in org.apache.flink.examples.java.distcp with parameters of type Configuration

Modifier and Type	Method and Description
void	FileCopyTaskInputFormat.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.examples.java.relational

Methods in org.apache.flink.examples.java.relational with parameters of type Configuration

Modifier and Type	Method and Description
void	EmptyFieldsCountAccumulator.EmptyFieldFilter.open(Configuration parameters)

Uses of Configuration in org.apache.flink.externalresource.gpu

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

Modifier and Type	Method and Description
ExternalResourceDriver	GPUDriverFactory.createExternalResourceDriver(Configuration config)

Uses of Configuration in org.apache.flink.formats.parquet

Methods in org.apache.flink.formats.parquet with parameters of type Configuration

Modifier and Type	Method and Description
void	ParquetInputFormat.configure(Configuration parameters)
org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReader	ParquetVectorizedInputFormat.createReader(Configuration config, SplitT split)
protected int	ParquetVectorizedInputFormat.numBatchesToCirculate(Configuration config)
protected int	ParquetColumnarRowInputFormat.numBatchesToCirculate(Configuration config)
org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReader	ParquetVectorizedInputFormat.restoreReader(Configuration config, SplitT split)

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

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

Modifier and Type	Method and Description
void	AbstractAzureFSFactory.configure(Configuration config)

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

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

Modifier and Type	Method and Description
void	OSSFileSystemFactory.configure(Configuration config)

Uses of Configuration in org.apache.flink.fs.s3.common

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

Modifier and Type	Method and Description
void	AbstractS3FileSystemFactory.configure(Configuration config)

Uses of Configuration in org.apache.flink.graph

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

Modifier and Type	Method and Description
void	AnalyticHelper.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.hadoopcompatibility.mapred

Methods in org.apache.flink.hadoopcompatibility.mapred with parameters of type Configuration

Modifier and Type	Method and Description
void	HadoopReduceCombineFunction.open(Configuration parameters)
void	HadoopReduceFunction.open(Configuration parameters)
void	HadoopMapFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.hcatalog

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

Modifier and Type	Method and Description
void	HCatInputFormatBase.configure(Configuration parameters)

Uses of Configuration in org.apache.flink.kubernetes

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

Modifier and Type	Method and Description
KubernetesClusterDescriptor	KubernetesClusterClientFactory.createClusterDescriptor(Configuration configuration)
String	KubernetesClusterClientFactory.getClusterId(Configuration configuration)
boolean	KubernetesClusterClientFactory.isCompatibleWith(Configuration configuration)

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

Constructor and Description
KubernetesClusterDescriptor(Configuration flinkConfig, FlinkKubeClient client)
KubernetesResourceManagerDriver(Configuration flinkConfig, FlinkKubeClient flinkKubeClient, KubernetesResourceManagerDriverConfiguration configuration)

Uses of Configuration in org.apache.flink.kubernetes.cli

Constructors in org.apache.flink.kubernetes.cli with parameters of type Configuration

Constructor and Description
KubernetesSessionCli(Configuration configuration, ClusterClientServiceLoader clusterClientServiceLoader, String configDir)
KubernetesSessionCli(Configuration configuration, String configDir)

Uses of Configuration in org.apache.flink.kubernetes.configuration

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

Modifier and Type	Method and Description
static KubernetesDeploymentTarget	KubernetesDeploymentTarget.fromConfig(Configuration configuration)

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

Constructor and Description
KubernetesLeaderElectionConfiguration(String configMapName, String lockIdentity, Configuration config)

Uses of Configuration in org.apache.flink.kubernetes.entrypoint

Methods in org.apache.flink.kubernetes.entrypoint with parameters of type Configuration

Modifier and Type	Method and Description
WorkerResourceSpec	KubernetesWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)
protected DispatcherResourceManagerComponentFactory	KubernetesSessionClusterEntrypoint.createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected ResourceManagerDriver<KubernetesWorkerNode>	KubernetesResourceManagerFactory.createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress)
protected ResourceManagerRuntimeServicesConfiguration	KubernetesResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration)

Constructors in org.apache.flink.kubernetes.entrypoint with parameters of type Configuration

Constructor and Description
KubernetesSessionClusterEntrypoint(Configuration configuration)

Uses of Configuration in org.apache.flink.kubernetes.executors

Methods in org.apache.flink.kubernetes.executors with parameters of type Configuration

Modifier and Type	Method and Description
PipelineExecutor	KubernetesSessionClusterExecutorFactory.getExecutor(Configuration configuration)
boolean	KubernetesSessionClusterExecutorFactory.isCompatibleWith(Configuration configuration)

Uses of Configuration in org.apache.flink.kubernetes.highavailability

Methods in org.apache.flink.kubernetes.highavailability with parameters of type Configuration

Modifier and Type	Method and Description
HighAvailabilityServices	KubernetesHaServicesFactory.createHAServices(Configuration configuration, Executor executor)

Constructors in org.apache.flink.kubernetes.highavailability with parameters of type Configuration

Constructor and Description
KubernetesCheckpointRecoveryFactory(FlinkKubeClient kubeClient, Configuration configuration, Executor executor, java.util.function.Function<JobID,String> function, String lockIdentity) Create a KubernetesCheckpointRecoveryFactory.

Uses of Configuration in org.apache.flink.kubernetes.kubeclient

Methods in org.apache.flink.kubernetes.kubeclient with parameters of type Configuration

Modifier and Type	Method and Description
FlinkKubeClient	FlinkKubeClientFactory.fromConfiguration(Configuration flinkConfig, String useCase) Create a Flink Kubernetes client with the given configuration.

Constructors in org.apache.flink.kubernetes.kubeclient with parameters of type Configuration

Constructor and Description
Fabric8FlinkKubeClient(Configuration flinkConfig, io.fabric8.kubernetes.client.NamespacedKubernetesClient client, ExecutorService executorService)

Uses of Configuration in org.apache.flink.kubernetes.kubeclient.parameters

Fields in org.apache.flink.kubernetes.kubeclient.parameters declared as Configuration

Modifier and Type	Field and Description
protected Configuration	AbstractKubernetesParameters.flinkConfig

Methods in org.apache.flink.kubernetes.kubeclient.parameters that return Configuration

Modifier and Type	Method and Description
Configuration	AbstractKubernetesParameters.getFlinkConfiguration()

Constructors in org.apache.flink.kubernetes.kubeclient.parameters with parameters of type Configuration

Constructor and Description
AbstractKubernetesParameters(Configuration flinkConfig)
KubernetesJobManagerParameters(Configuration flinkConfig, ClusterSpecification clusterSpecification)
KubernetesTaskManagerParameters(Configuration flinkConfig, String podName, String dynamicProperties, String jvmMemOptsEnv, ContaineredTaskManagerParameters containeredTaskManagerParameters, Map<String,String> taskManagerExternalResourceConfigKeys)

Uses of Configuration in org.apache.flink.kubernetes.utils

Methods in org.apache.flink.kubernetes.utils with parameters of type Configuration

Modifier and Type	Method and Description
static void	KubernetesUtils.checkAndUpdatePortConfigOption(Configuration flinkConfig, ConfigOption<String> port, int fallbackPort) Check whether the port config option is a fixed port.
static List<File>	KubernetesUtils.checkJarFileForApplicationMode(Configuration configuration)
static CompletedCheckpointStore	KubernetesUtils.createCompletedCheckpointStore(Configuration configuration, FlinkKubeClient kubeClient, Executor executor, String configMapName, String lockIdentity, int maxNumberOfCheckpointsToRetain) Create a DefaultCompletedCheckpointStore with KubernetesStateHandleStore.
static KubernetesStateHandleStore<JobGraph>	KubernetesUtils.createJobGraphStateHandleStore(Configuration configuration, FlinkKubeClient flinkKubeClient, String configMapName, String lockIdentity) Create a KubernetesStateHandleStore which storing JobGraph.
static JobGraphStore	KubernetesUtils.createJobGraphStore(Configuration configuration, FlinkKubeClient flinkKubeClient, String configMapName, String lockIdentity) Create a DefaultJobGraphStore with NoOpJobGraphStoreWatcher.
static Integer	KubernetesUtils.parsePort(Configuration flinkConfig, ConfigOption<String> port) Parse a valid port for the config option.
static <T> String	KubernetesUtils.resolveUserDefinedValue(Configuration flinkConfig, ConfigOption<T> configOption, String valueOfConfigOptionOrDefault, String valueOfPodTemplate, String fieldDescription) Resolve the user defined value with the precedence.

Uses of Configuration in org.apache.flink.mesos.entrypoint

Methods in org.apache.flink.mesos.entrypoint with parameters of type Configuration

Modifier and Type	Method and Description
protected DefaultDispatcherResourceManagerComponentFactory	MesosSessionClusterEntrypoint.createDispatcherResourceManagerComponentFactory(Configuration configuration) Deprecated.
protected DefaultDispatcherResourceManagerComponentFactory	MesosJobClusterEntrypoint.createDispatcherResourceManagerComponentFactory(Configuration configuration) Deprecated.
protected void	MesosSessionClusterEntrypoint.initializeServices(Configuration config, PluginManager pluginManager) Deprecated.
protected void	MesosJobClusterEntrypoint.initializeServices(Configuration config, PluginManager pluginManager) Deprecated.

Constructors in org.apache.flink.mesos.entrypoint with parameters of type Configuration

Constructor and Description
MesosJobClusterEntrypoint(Configuration config) Deprecated.
MesosSessionClusterEntrypoint(Configuration config) Deprecated.

Uses of Configuration in org.apache.flink.mesos.runtime.clusterframework

Methods in org.apache.flink.mesos.runtime.clusterframework with parameters of type Configuration

Modifier and Type	Method and Description
static MesosTaskManagerParameters	MesosTaskManagerParameters.create(Configuration flinkConfig) Deprecated. Create the Mesos TaskManager parameters.
akka.actor.ActorRef	MesosResourceManagerActorFactoryImpl.createConnectionMonitor(Configuration flinkConfig) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactory.createConnectionMonitor(Configuration flinkConfig) Deprecated. Create actor for the connection monitor.
WorkerResourceSpec	MesosWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactoryImpl.createLaunchCoordinator(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizer) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactory.createLaunchCoordinator(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver, TaskSchedulerBuilder optimizer) Deprecated. Create actor for the launch coordinator.
akka.actor.ActorRef	MesosResourceManagerActorFactoryImpl.createReconciliationCoordinator(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactory.createReconciliationCoordinator(Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver) Deprecated. Create actor for the reconciliation coordinator.
protected ResourceManagerDriver<RegisteredMesosWorkerNode>	MesosResourceManagerFactory.createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress) Deprecated.
protected ResourceManagerRuntimeServicesConfiguration	MesosResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactoryImpl.createTaskMonitor(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver) Deprecated.
akka.actor.ActorRef	MesosResourceManagerActorFactory.createTaskMonitor(Configuration flinkConfig, akka.actor.ActorRef resourceManagerActor, org.apache.mesos.SchedulerDriver schedulerDriver) Deprecated. Create actor for the task monitor.

Constructors in org.apache.flink.mesos.runtime.clusterframework with parameters of type Configuration

Constructor and Description
MesosResourceManagerDriver(Configuration flinkConfig, MesosServices mesosServices, MesosConfiguration mesosConfig, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec, String webUiUrl) Deprecated.

Uses of Configuration in org.apache.flink.mesos.runtime.clusterframework.services

Methods in org.apache.flink.mesos.runtime.clusterframework.services with parameters of type Configuration

Modifier and Type	Method and Description
static MesosServices	MesosServicesUtils.createMesosServices(Configuration configuration, String hostname) Deprecated. Creates a MesosServices instance depending on the high availability settings.
MesosWorkerStore	MesosServices.createMesosWorkerStore(Configuration configuration) Deprecated. Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.
MesosWorkerStore	StandaloneMesosServices.createMesosWorkerStore(Configuration configuration) Deprecated.
MesosWorkerStore	ZooKeeperMesosServices.createMesosWorkerStore(Configuration configuration) Deprecated.

Uses of Configuration in org.apache.flink.mesos.util

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

Modifier and Type	Method and Description
static Configuration	MesosUtils.loadConfiguration(Configuration dynamicProperties, org.slf4j.Logger log) Deprecated. Loads the global configuration, adds the given dynamic properties configuration, and sets the temp directory paths.

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

Modifier and Type	Method and Description
static void	MesosUtils.applyOverlays(Configuration configuration, ContainerSpecification containerSpec) Deprecated. Generate a container specification as a TaskManager template.
static ContainerSpecification	MesosUtils.createContainerSpec(Configuration flinkConfiguration) Deprecated.
static MesosConfiguration	MesosUtils.createMesosSchedulerConfiguration(Configuration flinkConfig, String hostname) Deprecated. Loads and validates the Mesos scheduler configuration.
static MesosTaskManagerParameters	MesosUtils.createTmParameters(Configuration configuration, org.slf4j.Logger log) Deprecated.
static Configuration	MesosUtils.loadConfiguration(Configuration dynamicProperties, org.slf4j.Logger log) Deprecated. Loads the global configuration, adds the given dynamic properties configuration, and sets the temp directory paths.

Constructors in org.apache.flink.mesos.util with parameters of type Configuration

Constructor and Description
MesosArtifactServerImpl(String prefix, String serverHostname, int configuredPort, Configuration config) Deprecated.

Uses of Configuration in org.apache.flink.optimizer

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

Constructor and Description
Optimizer(Configuration config) Creates a new optimizer instance.
Optimizer(CostEstimator estimator, Configuration config) Creates a new optimizer instance.
Optimizer(DataStatistics stats, Configuration config) Creates a new optimizer instance that uses the statistics object to determine properties about the input.
Optimizer(DataStatistics stats, CostEstimator estimator, Configuration config) Creates a new optimizer instance that uses the statistics object to determine properties about the input.

Uses of Configuration in org.apache.flink.optimizer.plantranslate

Constructors in org.apache.flink.optimizer.plantranslate with parameters of type Configuration

Constructor and Description
JobGraphGenerator(Configuration config)

Uses of Configuration in org.apache.flink.orc

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

Modifier and Type	Method and Description
AbstractOrcFileInputFormat.OrcVectorizedReader<T,BatchT>	AbstractOrcFileInputFormat.createReader(Configuration config, SplitT split)
AbstractOrcFileInputFormat.OrcVectorizedReader<T,BatchT>	AbstractOrcFileInputFormat.restoreReader(Configuration config, SplitT split)

Uses of Configuration in org.apache.flink.python

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

Modifier and Type	Method and Description
Configuration	PythonConfig.getConfig()

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

Constructor and Description
PythonConfig(Configuration config)

Uses of Configuration in org.apache.flink.python.util

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

Modifier and Type	Method and Description
static Configuration	PythonDependencyUtils.configurePythonDependencies(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cachedFiles, Configuration config) Adds python dependencies to registered cache file list according to given configuration and returns a new configuration which contains the metadata of the registered python dependencies.
static Configuration	PythonConfigUtil.getEnvConfigWithDependencies(StreamExecutionEnvironment env) A static method to get the StreamExecutionEnvironment configuration merged with python dependency management configurations.
static Configuration	PythonConfigUtil.getEnvironmentConfig(StreamExecutionEnvironment env) Get the private method StreamExecutionEnvironment.getConfiguration() by reflection recursively.
static Configuration	PythonConfigUtil.getMergedConfig(ExecutionEnvironment env, TableConfig tableConfig)
static Configuration	PythonConfigUtil.getMergedConfig(StreamExecutionEnvironment env, TableConfig tableConfig)
static Configuration	PythonDependencyUtils.parsePythonDependencyConfiguration(org.apache.commons.cli.CommandLine commandLine)

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

Modifier and Type	Method and Description
static Configuration	PythonDependencyUtils.configurePythonDependencies(List<Tuple2<String,DistributedCache.DistributedCacheEntry>> cachedFiles, Configuration config) Adds python dependencies to registered cache file list according to given configuration and returns a new configuration which contains the metadata of the registered python dependencies.
static void	PythonDependencyUtils.merge(Configuration config, Configuration pythonConfiguration)

Uses of Configuration in org.apache.flink.runtime.blob

Fields in org.apache.flink.runtime.blob declared as Configuration

Modifier and Type	Field and Description
protected Configuration	AbstractBlobCache.blobClientConfig Configuration for the blob client like ssl parameters required to connect to the blob server.

Methods in org.apache.flink.runtime.blob with parameters of type Configuration

Modifier and Type	Method and Description
static BlobStoreService	BlobUtils.createBlobStoreFromConfig(Configuration config) Creates a BlobStore based on the parameters set in the configuration.
static List<PermanentBlobKey>	BlobClient.uploadFiles(InetSocketAddress serverAddress, Configuration clientConfig, JobID jobId, List<Path> files) Uploads the JAR files to the PermanentBlobService of the BlobServer at the given address with HA as configured.

Constructors in org.apache.flink.runtime.blob with parameters of type Configuration

Constructor and Description
AbstractBlobCache(Configuration blobClientConfig, BlobView blobView, org.slf4j.Logger logger, InetSocketAddress serverAddress)
BlobCacheService(Configuration blobClientConfig, BlobView blobView, InetSocketAddress serverAddress) Instantiates a new BLOB cache.
BlobClient(InetSocketAddress serverAddress, Configuration clientConfig) Instantiates a new BLOB client.
BlobServer(Configuration config, BlobStore blobStore) Instantiates a new BLOB server and binds it to a free network port.
PermanentBlobCache(Configuration blobClientConfig, BlobView blobView, InetSocketAddress serverAddress) Instantiates a new cache for permanent BLOBs which are also available in an HA store.
TransientBlobCache(Configuration blobClientConfig, InetSocketAddress serverAddress) Instantiates a new BLOB cache.

Uses of Configuration in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint with parameters of type Configuration

Modifier and Type	Method and Description
static void	Checkpoints.disposeSavepoint(String pointer, Configuration configuration, ClassLoader classLoader, org.slf4j.Logger logger)
static CheckpointStorage	Checkpoints.loadCheckpointStorage(Configuration configuration, ClassLoader classLoader, org.slf4j.Logger logger)
static StateBackend	Checkpoints.loadStateBackend(Configuration configuration, ClassLoader classLoader, org.slf4j.Logger logger)

Constructors in org.apache.flink.runtime.checkpoint with parameters of type Configuration

Constructor and Description
ZooKeeperCheckpointRecoveryFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration config, Executor executor)

Uses of Configuration in org.apache.flink.runtime.clusterframework

Methods in org.apache.flink.runtime.clusterframework that return Configuration

Modifier and Type	Method and Description
static Configuration	BootstrapTools.cloneConfiguration(Configuration configuration) Clones the given configuration and resets instance specific config options.
static Configuration	TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration, ConfigOption<MemorySize> configOption)
Configuration	ContainerSpecification.getFlinkConfiguration() Get the dynamic configuration.
Configuration	ContainerSpecification.getSystemProperties() Get the system properties.
static Configuration	BootstrapTools.parseDynamicProperties(org.apache.commons.cli.CommandLine cmd) Parse the dynamic properties (passed on the command line).

Methods in org.apache.flink.runtime.clusterframework with parameters of type Configuration

Modifier and Type	Method and Description
static Configuration	BootstrapTools.cloneConfiguration(Configuration configuration) Clones the given configuration and resets instance specific config options.
static ContaineredTaskManagerParameters	ContaineredTaskManagerParameters.create(Configuration config, TaskExecutorProcessSpec taskExecutorProcessSpec) Computes the parameters to be used to start a TaskManager Java process.
static String	ContainerSpecification.formatSystemProperties(Configuration jvmArgs) Format the system properties as a shell-compatible command-line argument.
static ContainerSpecification	ContainerSpecification.from(Configuration flinkConfiguration)
static BootstrapTools.ForkJoinExecutorConfiguration	BootstrapTools.ForkJoinExecutorConfiguration.fromConfiguration(Configuration configuration)
static Configuration	TaskExecutorProcessUtils.getConfigurationMapLegacyTaskManagerHeapSizeToConfigOption(Configuration configuration, ConfigOption<MemorySize> configOption)
static CPUResource	TaskExecutorProcessUtils.getCpuCoresWithFallback(Configuration config, double fallback)
static double	TaskExecutorProcessUtils.getCpuCoresWithFallbackConfigOption(Configuration config, ConfigOption<Double> fallbackOption)
static String	BootstrapTools.getDynamicPropertiesAsString(Configuration baseConfig, Configuration targetConfig) Get dynamic properties based on two Flink configurations.
static String	BootstrapTools.getTaskManagerShellCommand(Configuration flinkConfig, ContaineredTaskManagerParameters tmParams, String configDirectory, String logDirectory, boolean hasLogback, boolean hasLog4j, boolean hasKrb5, Class<?> mainClass, String mainArgs) Generates the shell command to start a task manager.
static TaskExecutorProcessSpecBuilder	TaskExecutorProcessUtils.newProcessSpecBuilder(Configuration config)
static TaskExecutorProcessSpec	TaskExecutorProcessUtils.processSpecFromConfig(Configuration config)
static TaskExecutorProcessSpec	TaskExecutorProcessUtils.processSpecFromWorkerResourceSpec(Configuration config, WorkerResourceSpec workerResourceSpec)
static akka.actor.ActorSystem	BootstrapTools.startLocalActorSystem(Configuration configuration, String actorSystemName, org.slf4j.Logger logger, BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration, com.typesafe.config.Config customConfig) Starts a local Actor System.
static akka.actor.ActorSystem	BootstrapTools.startRemoteActorSystem(Configuration configuration, String externalAddress, String externalPortRange, org.slf4j.Logger logger) Starts a remote ActorSystem at given address and specific port range.
static akka.actor.ActorSystem	BootstrapTools.startRemoteActorSystem(Configuration configuration, String actorSystemName, String externalAddress, String externalPortRange, String bindAddress, Optional<Integer> bindPort, org.slf4j.Logger logger, BootstrapTools.ActorSystemExecutorConfiguration actorSystemExecutorConfiguration, com.typesafe.config.Config customConfig) Starts a remote ActorSystem at given address and specific port range.
static void	BootstrapTools.substituteDeprecatedConfigKey(Configuration config, String deprecated, String designated) Sets the value of a new config key to the value of a deprecated config key.
static void	BootstrapTools.substituteDeprecatedConfigPrefix(Configuration config, String deprecatedPrefix, String designatedPrefix) Sets the value of a new config key to the value of a deprecated config key.
static void	BootstrapTools.updateTmpDirectoriesInConfiguration(Configuration configuration, String defaultDirs) Set temporary configuration directories if necessary.
static void	BootstrapTools.writeConfiguration(Configuration cfg, File file) Writes a Flink YAML config file from a Flink Configuration object.

Uses of Configuration in org.apache.flink.runtime.clusterframework.overlays

Methods in org.apache.flink.runtime.clusterframework.overlays with parameters of type Configuration

Modifier and Type	Method and Description
FlinkDistributionOverlay.Builder	FlinkDistributionOverlay.Builder.fromEnvironment(Configuration globalConfiguration) Configures the overlay using the current environment.
KeytabOverlay.Builder	KeytabOverlay.Builder.fromEnvironment(Configuration globalConfiguration) Configures the overlay using the current environment (and global configuration).
HadoopConfOverlay.Builder	HadoopConfOverlay.Builder.fromEnvironment(Configuration globalConfiguration) Configures the overlay using the current environment's Hadoop configuration.
HadoopUserOverlay.Builder	HadoopUserOverlay.Builder.fromEnvironment(Configuration globalConfiguration) Configures the overlay using the current Hadoop user information (from UserGroupInformation).
SSLStoreOverlay.Builder	SSLStoreOverlay.Builder.fromEnvironment(Configuration globalConfiguration) Configures the overlay using the current environment (and global configuration).
Krb5ConfOverlay.Builder	Krb5ConfOverlay.Builder.fromEnvironmentOrConfiguration(Configuration globalConfiguration) Configures the overlay using the current environment.

Uses of Configuration in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return Configuration

Modifier and Type	Method and Description
Configuration	PartialDispatcherServices.getConfiguration()
Configuration	DispatcherServices.getConfiguration()

Methods in org.apache.flink.runtime.dispatcher with parameters of type Configuration

Modifier and Type	Method and Description
static HistoryServerArchivist	HistoryServerArchivist.createHistoryServerArchivist(Configuration configuration, JsonArchivist jsonArchivist, Executor ioExecutor)
JobManagerRunner	JobManagerRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)
JobManagerRunner	JobMasterServiceLeadershipRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, long initializationTimestamp)

Constructors in org.apache.flink.runtime.dispatcher with parameters of type Configuration

Constructor and Description
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration, GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)
DispatcherServices(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, JobManagerMetricGroup jobManagerMetricGroup, JobGraphWriter jobGraphWriter, JobManagerRunnerFactory jobManagerRunnerFactory, Executor ioExecutor)
PartialDispatcherServices(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroupFactory jobManagerMetricGroupFactory, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, Executor ioExecutor)
PartialDispatcherServicesWithJobGraphStore(Configuration configuration, HighAvailabilityServices highAvailabilityServices, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, BlobServer blobServer, HeartbeatServices heartbeatServices, JobManagerMetricGroupFactory jobManagerMetricGroupFactory, ExecutionGraphInfoStore executionGraphInfoStore, FatalErrorHandler fatalErrorHandler, HistoryServerArchivist historyServerArchivist, String metricQueryServiceAddress, Executor ioExecutor, JobGraphWriter jobGraphWriter)

Uses of Configuration in org.apache.flink.runtime.entrypoint

Methods in org.apache.flink.runtime.entrypoint that return Configuration

Modifier and Type	Method and Description
Configuration	DynamicParametersConfigurationParserFactory.createResult(org.apache.commons.cli.CommandLine commandLine)
protected static Configuration	ClusterEntrypoint.loadConfiguration(EntrypointClusterConfiguration entrypointClusterConfiguration)

Methods in org.apache.flink.runtime.entrypoint with parameters of type Configuration

Modifier and Type	Method and Description
protected abstract DispatcherResourceManagerComponentFactory	ClusterEntrypoint.createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected DefaultDispatcherResourceManagerComponentFactory	StandaloneSessionClusterEntrypoint.createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected HighAvailabilityServices	ClusterEntrypoint.createHaServices(Configuration configuration, Executor executor)
protected HeartbeatServices	ClusterEntrypoint.createHeartbeatServices(Configuration configuration)
protected MetricRegistryImpl	ClusterEntrypoint.createMetricRegistry(Configuration configuration, PluginManager pluginManager)
protected ExecutionGraphInfoStore	JobClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
protected abstract ExecutionGraphInfoStore	ClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
protected ExecutionGraphInfoStore	SessionClusterEntrypoint.createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
static int	ClusterEntrypointUtils.getPoolSize(Configuration config) Gets and verify the io-executor pool size based on configuration.
protected String	ClusterEntrypoint.getRPCPortRange(Configuration configuration) Returns the port range for the common RpcService.
protected void	ClusterEntrypoint.initializeServices(Configuration configuration, PluginManager pluginManager)

Constructors in org.apache.flink.runtime.entrypoint with parameters of type Configuration

Constructor and Description
ClusterEntrypoint(Configuration configuration)
JobClusterEntrypoint(Configuration configuration)
SessionClusterEntrypoint(Configuration configuration)
StandaloneSessionClusterEntrypoint(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.entrypoint.component

Methods in org.apache.flink.runtime.entrypoint.component with parameters of type Configuration

Modifier and Type	Method and Description
DispatcherResourceManagerComponent	DefaultDispatcherResourceManagerComponentFactory.create(Configuration configuration, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
DispatcherResourceManagerComponent	DispatcherResourceManagerComponentFactory.create(Configuration configuration, Executor ioExecutor, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ExecutionGraphInfoStore executionGraphInfoStore, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
static FileJobGraphRetriever	FileJobGraphRetriever.createFrom(Configuration configuration, File usrLibDir)
JobGraph	FileJobGraphRetriever.retrieveJobGraph(Configuration configuration)
JobGraph	JobGraphRetriever.retrieveJobGraph(Configuration configuration) Retrieve the JobGraph.

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

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

Modifier and Type	Method and Description
Configuration	Environment.getJobConfiguration() Returns the job-wide configuration object that was attached to the JobGraph.
Configuration	Environment.getTaskConfiguration() Returns the task-wide configuration object, originally attached to the job vertex.

Uses of Configuration in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return Configuration

Modifier and Type	Method and Description
Configuration	DefaultExecutionGraph.getJobConfiguration()
Configuration	ExecutionGraph.getJobConfiguration()
Configuration	JobInformation.getJobConfiguration()
Configuration	TaskInformation.getTaskConfiguration()

Methods in org.apache.flink.runtime.executiongraph with parameters of type Configuration

Modifier and Type

Method and Description

static DefaultExecutionGraph

DefaultExecutionGraphBuilder.buildGraph(JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, ClassLoader classLoader, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, Time rpcTimeout, MetricGroup metrics, BlobWriter blobWriter, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, ExecutionDeploymentListener executionDeploymentListener, ExecutionStateUpdateListener executionStateUpdateListener, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore)

Constructors in org.apache.flink.runtime.executiongraph with parameters of type Configuration

Constructor and Description
JobInformation(JobID jobId, String jobName, SerializedValue<ExecutionConfig> serializedExecutionConfig, Configuration jobConfiguration, Collection<PermanentBlobKey> requiredJarFileBlobKeys, Collection<URL> requiredClasspathURLs)
TaskInformation(JobVertexID jobVertexId, String taskName, int numberOfSubtasks, int maxNumberOfSubtasks, String invokableClassName, Configuration taskConfiguration)

Uses of Configuration in org.apache.flink.runtime.executiongraph.failover.flip1

Methods in org.apache.flink.runtime.executiongraph.failover.flip1 with parameters of type Configuration

Modifier and Type	Method and Description
static FixedDelayRestartBackoffTimeStrategy.FixedDelayRestartBackoffTimeStrategyFactory	FixedDelayRestartBackoffTimeStrategy.createFactory(Configuration configuration)
static FailureRateRestartBackoffTimeStrategy.FailureRateRestartBackoffTimeStrategyFactory	FailureRateRestartBackoffTimeStrategy.createFactory(Configuration configuration)
static ExponentialDelayRestartBackoffTimeStrategy.ExponentialDelayRestartBackoffTimeStrategyFactory	ExponentialDelayRestartBackoffTimeStrategy.createFactory(Configuration configuration)
static RestartBackoffTimeStrategy.Factory	RestartBackoffTimeStrategyFactoryLoader.createRestartBackoffTimeStrategyFactory(RestartStrategies.RestartStrategyConfiguration jobRestartStrategyConfiguration, Configuration clusterConfiguration, boolean isCheckpointingEnabled) Creates RestartBackoffTimeStrategy.Factory from the given configuration.
static FailoverStrategy.Factory	FailoverStrategyFactoryLoader.loadFailoverStrategyFactory(Configuration config) Loads a FailoverStrategy.Factory from the given configuration.

Uses of Configuration in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease

Methods in org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease with parameters of type Configuration

Modifier and Type	Method and Description
static PartitionReleaseStrategy.Factory	PartitionReleaseStrategyFactoryLoader.loadPartitionReleaseStrategyFactory(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.externalresource

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

Modifier and Type	Method and Description
static ExternalResourceInfoProvider	ExternalResourceUtils.createStaticExternalResourceInfoProviderFromConfig(Configuration configuration, PluginManager pluginManager) Instantiate StaticExternalResourceInfoProvider for all of enabled external resources.
static Map<String,String>	ExternalResourceUtils.getExternalResourceConfigurationKeys(Configuration config, String suffix) Get the external resource configuration keys map, indexed by the resource name.
static Collection<ExternalResource>	ExternalResourceUtils.getExternalResourcesCollection(Configuration config) Get the collection of all enabled external resources.

Uses of Configuration in org.apache.flink.runtime.fs.hdfs

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

Modifier and Type	Method and Description
void	HadoopFsFactory.configure(Configuration config)

Uses of Configuration in org.apache.flink.runtime.heartbeat

Methods in org.apache.flink.runtime.heartbeat with parameters of type Configuration

Modifier and Type	Method and Description
static HeartbeatServices	HeartbeatServices.fromConfiguration(Configuration configuration) Creates an HeartbeatServices instance from a Configuration.

Uses of Configuration in org.apache.flink.runtime.highavailability

Fields in org.apache.flink.runtime.highavailability declared as Configuration

Modifier and Type	Field and Description
protected Configuration	AbstractHaServices.configuration The runtime configuration.

Methods in org.apache.flink.runtime.highavailability with parameters of type Configuration

Modifier and Type	Method and Description
static HighAvailabilityServices	HighAvailabilityServicesUtils.createAvailableOrEmbeddedServices(Configuration config, Executor executor)
static ClientHighAvailabilityServices	HighAvailabilityServicesUtils.createClientHAService(Configuration configuration)
default ClientHighAvailabilityServices	HighAvailabilityServicesFactory.createClientHAServices(Configuration configuration) Create a ClientHighAvailabilityServices instance.
HighAvailabilityServices	HighAvailabilityServicesFactory.createHAServices(Configuration configuration, Executor executor) Creates a HighAvailabilityServices instance.
static HighAvailabilityServices	HighAvailabilityServicesUtils.createHighAvailabilityServices(Configuration configuration, Executor executor, HighAvailabilityServicesUtils.AddressResolution addressResolution)
static Path	HighAvailabilityServicesUtils.getClusterHighAvailableStoragePath(Configuration configuration) Gets the cluster high available storage path from the provided configuration.
static Tuple2<String,Integer>	HighAvailabilityServicesUtils.getJobManagerAddress(Configuration configuration) Returns the JobManager's hostname and port extracted from the given Configuration.
static String	HighAvailabilityServicesUtils.getWebMonitorAddress(Configuration configuration, HighAvailabilityServicesUtils.AddressResolution resolution) Get address of web monitor from configuration.

Constructors in org.apache.flink.runtime.highavailability with parameters of type Configuration

Constructor and Description
AbstractHaServices(Configuration config, Executor ioExecutor, BlobStoreService blobStoreService)

Uses of Configuration in org.apache.flink.runtime.highavailability.zookeeper

Constructors in org.apache.flink.runtime.highavailability.zookeeper with parameters of type Configuration

Constructor and Description
ZooKeeperClientHAServices(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration)
ZooKeeperHaServices(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Executor executor, Configuration configuration, BlobStoreService blobStoreService)
ZooKeeperRunningJobsRegistry(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with parameters of type Configuration

Modifier and Type	Method and Description
NettyShuffleMaster	NettyShuffleServiceFactory.createShuffleMaster(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.io.network.netty

Methods in org.apache.flink.runtime.io.network.netty that return Configuration

Modifier and Type	Method and Description
Configuration	NettyConfig.getConfig()

Constructors in org.apache.flink.runtime.io.network.netty with parameters of type Configuration

Constructor and Description
NettyConfig(InetAddress serverAddress, int serverPort, int memorySegmentSize, int numberOfSlots, Configuration config)

Uses of Configuration in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return Configuration

Modifier and Type	Method and Description
Configuration	JobVertex.getConfiguration() Returns the vertex's configuration object which can be used to pass custom settings to the task at runtime.
Configuration	JobGraph.getJobConfiguration() Returns the configuration object for this job.
Configuration	InputOutputFormatContainer.getParameters(OperatorID operatorId)

Methods in org.apache.flink.runtime.jobgraph with parameters of type Configuration

Modifier and Type	Method and Description
InputOutputFormatContainer	InputOutputFormatContainer.addParameters(OperatorID operatorId, Configuration parameters)
static void	SavepointRestoreSettings.toConfiguration(SavepointRestoreSettings savepointRestoreSettings, Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks that return Configuration

Modifier and Type	Method and Description
Configuration	AbstractInvokable.getJobConfiguration() Returns the job configuration object which was attached to the original JobGraph.
Configuration	AbstractInvokable.getTaskConfiguration() Returns the task configuration object which was attached to the original JobVertex.

Uses of Configuration in org.apache.flink.runtime.jobmanager

Methods in org.apache.flink.runtime.jobmanager with parameters of type Configuration

Modifier and Type	Method and Description
static HighAvailabilityMode	HighAvailabilityMode.fromConfig(Configuration config) Return the configured HighAvailabilityMode.
static String	JobManagerProcessUtils.generateJvmParametersStr(JobManagerProcessSpec processSpec, Configuration configuration)
static boolean	HighAvailabilityMode.isHighAvailabilityModeActivated(Configuration configuration) Returns true if the defined recovery mode supports high availability.
static JobManagerProcessSpec	JobManagerProcessUtils.processSpecFromConfigWithNewOptionToInterpretLegacyHeap(Configuration config, ConfigOption<MemorySize> newOptionToInterpretLegacyHeap)

Uses of Configuration in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return Configuration

Modifier and Type	Method and Description
Configuration	JobMasterConfiguration.getConfiguration()

Methods in org.apache.flink.runtime.jobmaster with parameters of type Configuration

Modifier and Type	Method and Description
SchedulerNG	DefaultSlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, ScheduledExecutorService scheduledExecutorService, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService executorService, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener)
SchedulerNG	SlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, ScheduledExecutorService scheduledExecutorService, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService executorService, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener) Creates a SchedulerNG.
static JobMasterConfiguration	JobMasterConfiguration.fromConfiguration(Configuration configuration)
static JobManagerSharedServices	JobManagerSharedServices.fromConfiguration(Configuration config, BlobServer blobServer, FatalErrorHandler fatalErrorHandler)
static DefaultSlotPoolServiceSchedulerFactory	DefaultSlotPoolServiceSchedulerFactory.fromConfiguration(Configuration configuration, JobType jobType)

Constructors in org.apache.flink.runtime.jobmaster with parameters of type Configuration

Constructor and Description
JobMasterConfiguration(Time rpcTimeout, Time slotRequestTimeout, String tmpDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration, Configuration configuration)
MiniDispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)

Uses of Configuration in org.apache.flink.runtime.metrics

Methods in org.apache.flink.runtime.metrics with parameters of type Configuration

Modifier and Type	Method and Description
static MetricRegistryConfiguration	MetricRegistryConfiguration.fromConfiguration(Configuration configuration) Create a metric registry configuration object from the given Configuration.
static List<ReporterSetup>	ReporterSetup.fromConfiguration(Configuration configuration, PluginManager pluginManager)

Uses of Configuration in org.apache.flink.runtime.metrics.scope

Methods in org.apache.flink.runtime.metrics.scope with parameters of type Configuration

Modifier and Type	Method and Description
static ScopeFormats	ScopeFormats.fromConfig(Configuration config) Creates the scope formats as defined in the given configuration.

Uses of Configuration in org.apache.flink.runtime.metrics.util

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

Modifier and Type	Method and Description
static RpcService	MetricUtils.startLocalMetricsRpcService(Configuration configuration)
static RpcService	MetricUtils.startRemoteMetricsRpcService(Configuration configuration, String hostname)

Uses of Configuration in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster with parameters of type Configuration

Modifier and Type	Method and Description
protected Collection<? extends DispatcherResourceManagerComponent>	MiniCluster.createDispatcherResourceManagerComponents(Configuration configuration, MiniCluster.RpcServiceFactory rpcServiceFactory, HighAvailabilityServices haServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, MetricQueryServiceRetriever metricQueryServiceRetriever, FatalErrorHandler fatalErrorHandler)
protected HighAvailabilityServices	MiniCluster.createHighAvailabilityServices(Configuration configuration, Executor executor)
protected RpcService	MiniCluster.createLocalRpcService(Configuration configuration) Factory method to instantiate the local RPC service.
protected MetricRegistryImpl	MiniCluster.createMetricRegistry(Configuration config) Factory method to create the metric registry for the mini cluster.
protected RpcService	MiniCluster.createRemoteRpcService(Configuration configuration, String bindAddress, int bindPort) Factory method to instantiate the remote RPC service.
protected RpcService	MiniCluster.createRemoteRpcService(Configuration configuration, String externalAddress, String externalPortRange, String bindAddress) Factory method to instantiate the remote RPC service.
MiniClusterConfiguration.Builder	MiniClusterConfiguration.Builder.setConfiguration(Configuration configuration1)

Constructors in org.apache.flink.runtime.minicluster with parameters of type Configuration

Constructor and Description
MiniClusterConfiguration(Configuration configuration, int numTaskManagers, RpcServiceSharing rpcServiceSharing, String commonBindAddress, MiniCluster.HaServices haServices)

Uses of Configuration in org.apache.flink.runtime.net

Methods in org.apache.flink.runtime.net with parameters of type Configuration

Modifier and Type	Method and Description
static SSLHandlerFactory	SSLUtils.createInternalClientSSLEngineFactory(Configuration config) Creates a SSLEngineFactory to be used by internal communication client endpoints.
static SSLHandlerFactory	SSLUtils.createInternalServerSSLEngineFactory(Configuration config) Creates a SSLEngineFactory to be used by internal communication server endpoints.
static SSLHandlerFactory	SSLUtils.createRestClientSSLEngineFactory(Configuration config) Creates a SSLHandlerFactory to be used by the REST Clients.
static org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslContext	SSLUtils.createRestNettySSLContext(Configuration config, boolean clientMode, org.apache.flink.shaded.netty4.io.netty.handler.ssl.ClientAuth clientAuth, org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslProvider provider) Creates an SSL context for the external REST SSL.
static SSLHandlerFactory	SSLUtils.createRestServerSSLEngineFactory(Configuration config) Creates a SSLHandlerFactory to be used by the REST Servers.
static SSLContext	SSLUtils.createRestSSLContext(Configuration config, boolean clientMode) Creates an SSL context for clients against the external REST endpoint.
static SocketFactory	SSLUtils.createSSLClientSocketFactory(Configuration config) Creates a factory for SSL Client Sockets from the given configuration.
static ServerSocketFactory	SSLUtils.createSSLServerSocketFactory(Configuration config) Creates a factory for SSL Server Sockets from the given configuration.
static boolean	SSLUtils.isInternalSSLEnabled(Configuration sslConfig) Checks whether SSL for internal communication (rpc, data transport, blob server) is enabled.
static boolean	SSLUtils.isRestSSLAuthenticationEnabled(Configuration sslConfig) Checks whether mutual SSL authentication for the external REST endpoint is enabled.
static boolean	SSLUtils.isRestSSLEnabled(Configuration sslConfig) Checks whether SSL for the external REST endpoint is enabled.

Uses of Configuration in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators with parameters of type Configuration

Modifier and Type	Method and Description
static void	BatchTask.openUserCode(Function stub, Configuration parameters) Opens the given stub using its RichFunction.open(Configuration) method.

Uses of Configuration in org.apache.flink.runtime.operators.sort

Methods in org.apache.flink.runtime.operators.sort with parameters of type Configuration

Modifier and Type	Method and Description
ExternalSorterBuilder<T>	ExternalSorterBuilder.withCombiner(GroupCombineFunction<T,T> combineFunction, Configuration udfConfig)

Uses of Configuration in org.apache.flink.runtime.operators.util

Fields in org.apache.flink.runtime.operators.util declared as Configuration

Modifier and Type	Field and Description
protected Configuration	TaskConfig.config

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

Modifier and Type	Method and Description
Configuration	TaskConfig.getConfiguration() Gets the configuration that holds the actual values encoded.
Configuration	TaskConfig.getStubParameters()

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

Modifier and Type	Method and Description
void	TaskConfig.setStubParameters(Configuration parameters)

Constructors in org.apache.flink.runtime.operators.util with parameters of type Configuration

Constructor and Description
TaskConfig(Configuration config) Creates a new Task Config that wraps the given configuration.

Uses of Configuration in org.apache.flink.runtime.registration

Methods in org.apache.flink.runtime.registration with parameters of type Configuration

Modifier and Type	Method and Description
static RetryingRegistrationConfiguration	RetryingRegistrationConfiguration.fromConfiguration(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager that return Configuration

Modifier and Type	Method and Description
protected Configuration	ResourceManagerFactory.getEffectiveConfigurationForResourceManager(Configuration configuration) Configuration changes in this method will be visible to only ResourceManager.
protected Configuration	ResourceManagerFactory.getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration) Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices.

Methods in org.apache.flink.runtime.resourcemanager with parameters of type Configuration

Modifier and Type	Method and Description
WorkerResourceSpec	ArbitraryWorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)
abstract WorkerResourceSpec	WorkerResourceSpecFactory.createDefaultWorkerResourceSpec(Configuration configuration)
ResourceManager<T>	ResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
protected ResourceManager<ResourceID>	StandaloneResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected abstract ResourceManager<T>	ResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected ResourceManagerRuntimeServicesConfiguration	StandaloneResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
protected abstract ResourceManagerRuntimeServicesConfiguration	ResourceManagerFactory.createResourceManagerRuntimeServicesConfiguration(Configuration configuration)
static ResourceManagerRuntimeServicesConfiguration	ResourceManagerRuntimeServicesConfiguration.fromConfiguration(Configuration configuration, WorkerResourceSpecFactory defaultWorkerResourceSpecFactory)
protected Configuration	ResourceManagerFactory.getEffectiveConfigurationForResourceManager(Configuration configuration) Configuration changes in this method will be visible to only ResourceManager.
protected Configuration	ResourceManagerFactory.getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration) Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices.
protected WorkerResourceSpec	WorkerResourceSpecFactory.workerResourceSpecFromConfigAndCpu(Configuration configuration, CPUResource cpuResource)

Uses of Configuration in org.apache.flink.runtime.resourcemanager.active

Fields in org.apache.flink.runtime.resourcemanager.active declared as Configuration

Modifier and Type	Field and Description
protected Configuration	AbstractResourceManagerDriver.flinkClientConfig
protected Configuration	AbstractResourceManagerDriver.flinkConfig
protected Configuration	ActiveResourceManager.flinkConfig

Methods in org.apache.flink.runtime.resourcemanager.active that return Configuration

Modifier and Type	Method and Description
protected Configuration	ActiveResourceManagerFactory.getEffectiveConfigurationForResourceManager(Configuration configuration)
protected Configuration	ActiveResourceManagerFactory.getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration)

Methods in org.apache.flink.runtime.resourcemanager.active with parameters of type Configuration

Modifier and Type	Method and Description
ResourceManager<WorkerType>	ActiveResourceManagerFactory.createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
protected abstract ResourceManagerDriver<WorkerType>	ActiveResourceManagerFactory.createResourceManagerDriver(Configuration configuration, String webInterfaceUrl, String rpcAddress)
static ThresholdMeter	ActiveResourceManagerFactory.createStartWorkerFailureRater(Configuration configuration)
protected Configuration	ActiveResourceManagerFactory.getEffectiveConfigurationForResourceManager(Configuration configuration)
protected Configuration	ActiveResourceManagerFactory.getEffectiveConfigurationForResourceManagerAndRuntimeServices(Configuration configuration)

Constructors in org.apache.flink.runtime.resourcemanager.active with parameters of type Configuration

Constructor and Description
AbstractResourceManagerDriver(Configuration flinkConfig, Configuration flinkClientConfig)
ActiveResourceManager(ResourceManagerDriver<WorkerType> resourceManagerDriver, Configuration flinkConfig, RpcService rpcService, ResourceID resourceId, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, ResourceManagerMetricGroup resourceManagerMetricGroup, ThresholdMeter startWorkerFailureRater, java.time.Duration retryInterval, java.time.Duration workerRegistrationTimeout, Executor ioExecutor)

Uses of Configuration in org.apache.flink.runtime.resourcemanager.slotmanager

Methods in org.apache.flink.runtime.resourcemanager.slotmanager with parameters of type Configuration

Modifier and Type	Method and Description
static SlotManagerConfiguration	SlotManagerConfiguration.fromConfiguration(Configuration configuration, WorkerResourceSpec defaultWorkerResourceSpec)

Uses of Configuration in org.apache.flink.runtime.rest

Methods in org.apache.flink.runtime.rest with parameters of type Configuration

Modifier and Type	Method and Description
WebMonitorEndpoint<T>	RestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<DispatcherGateway>	SessionRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
WebMonitorEndpoint<RestfulGateway>	JobRestEndpointFactory.createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)
static RestServerEndpointConfiguration	RestServerEndpointConfiguration.fromConfiguration(Configuration config) Creates and returns a new RestServerEndpointConfiguration from the given Configuration.
static RestClientConfiguration	RestClientConfiguration.fromConfiguration(Configuration config) Creates and returns a new RestClientConfiguration from the given Configuration.

Uses of Configuration in org.apache.flink.runtime.rest.handler

Methods in org.apache.flink.runtime.rest.handler with parameters of type Configuration

Modifier and Type	Method and Description
static RestHandlerConfiguration	RestHandlerConfiguration.fromConfiguration(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.rest.handler.cluster

Constructors in org.apache.flink.runtime.rest.handler.cluster with parameters of type Configuration

Constructor and Description
ClusterConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ClusterConfigurationInfo,EmptyMessageParameters> messageHeaders, Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.rest.handler.job

Constructors in org.apache.flink.runtime.rest.handler.job with parameters of type Configuration

Constructor and Description
JobSubmitHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> headers, Executor executor, Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.rest.handler.legacy.metrics

Methods in org.apache.flink.runtime.rest.handler.legacy.metrics with parameters of type Configuration

Modifier and Type	Method and Description
static <T extends RestfulGateway> MetricFetcherImpl<T>	MetricFetcherImpl.fromConfiguration(Configuration configuration, MetricQueryServiceRetriever metricQueryServiceGatewayRetriever, GatewayRetriever<T> dispatcherGatewayRetriever, ExecutorService executor)

Uses of Configuration in org.apache.flink.runtime.rest.messages

Methods in org.apache.flink.runtime.rest.messages with parameters of type Configuration

Modifier and Type	Method and Description
static ClusterConfigurationInfo	ClusterConfigurationInfo.from(Configuration config)

Uses of Configuration in org.apache.flink.runtime.rpc.akka

Methods in org.apache.flink.runtime.rpc.akka that return Configuration

Modifier and Type	Method and Description
Configuration	AkkaRpcServiceConfiguration.getConfiguration()

Methods in org.apache.flink.runtime.rpc.akka with parameters of type Configuration

Modifier and Type	Method and Description
static AkkaRpcService	AkkaRpcServiceUtils.createRemoteRpcService(Configuration configuration, String externalAddress, String externalPortRange, String bindAddress, Optional<Integer> bindPort)
static long	AkkaRpcServiceUtils.extractMaximumFramesize(Configuration configuration)
static AkkaRpcServiceConfiguration	AkkaRpcServiceConfiguration.fromConfiguration(Configuration configuration)
static String	AkkaRpcServiceUtils.getRpcUrl(String hostname, int port, String endpointName, HighAvailabilityServicesUtils.AddressResolution addressResolution, Configuration config)
static AkkaRpcServiceUtils.AkkaRpcServiceBuilder	AkkaRpcServiceUtils.localServiceBuilder(Configuration configuration)
static AkkaRpcServiceUtils.AkkaRpcServiceBuilder	AkkaRpcServiceUtils.remoteServiceBuilder(Configuration configuration, String externalAddress, int externalPort)
static AkkaRpcServiceUtils.AkkaRpcServiceBuilder	AkkaRpcServiceUtils.remoteServiceBuilder(Configuration configuration, String externalAddress, String externalPortRange)

Constructors in org.apache.flink.runtime.rpc.akka with parameters of type Configuration

Constructor and Description
AkkaRpcServiceConfiguration(Configuration configuration, Time timeout, long maximumFramesize, boolean captureAskCallStack)

Uses of Configuration in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type Configuration

Modifier and Type	Method and Description
static CompletedCheckpointStore	SchedulerUtils.createCompletedCheckpointStoreIfCheckpointingIsEnabled(JobGraph jobGraph, Configuration configuration, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, org.slf4j.Logger log)
SchedulerNG	SchedulerNGFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener)
SchedulerNG	DefaultSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener)

Constructors in org.apache.flink.runtime.scheduler with parameters of type Configuration

Constructor and Description
DefaultExecutionGraphFactory(Configuration configuration, ClassLoader userCodeClassLoader, ExecutionDeploymentTracker executionDeploymentTracker, ScheduledExecutorService futureExecutor, Executor ioExecutor, Time rpcTimeout, JobManagerJobMetricGroup jobManagerJobMetricGroup, BlobWriter blobWriter, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker jobMasterPartitionTracker)
SchedulerBase(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, ExecutionVertexVersioner executionVertexVersioner, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, ExecutionGraphFactory executionGraphFactory)

Uses of Configuration in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type Configuration

Modifier and Type

Method and Description

SchedulerNG

AdaptiveSchedulerFactory.createInstance(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Time rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Time slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener)

Constructors in org.apache.flink.runtime.scheduler.adaptive with parameters of type Configuration

Constructor and Description

AdaptiveScheduler(JobGraph jobGraph, Configuration configuration, DeclarativeSlotPool declarativeSlotPool, SlotAllocator slotAllocator, Executor ioExecutor, ClassLoader userCodeClassLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, java.time.Duration initialResourceAllocationTimeout, java.time.Duration resourceStabilizationTimeout, JobManagerJobMetricGroup jobManagerJobMetricGroup, RestartBackoffTimeStrategy restartBackoffTimeStrategy, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, ExecutionGraphFactory executionGraphFactory)

Uses of Configuration in org.apache.flink.runtime.scheduler.adaptive.scalingpolicy

Constructors in org.apache.flink.runtime.scheduler.adaptive.scalingpolicy with parameters of type Configuration

Constructor and Description
ReactiveScaleUpController(Configuration configuration)

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

Methods in org.apache.flink.runtime.security that return Configuration

Modifier and Type	Method and Description
Configuration	SecurityConfiguration.getFlinkConfig()

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

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

Constructors in org.apache.flink.runtime.security with parameters of type Configuration

Constructor and Description
SecurityConfiguration(Configuration flinkConf) Create a security configuration from the global configuration.
SecurityConfiguration(Configuration flinkConf, List<String> securityContextFactory, List<String> securityModuleFactories) Create a security configuration from the global configuration.

Uses of Configuration in org.apache.flink.runtime.shuffle

Methods in org.apache.flink.runtime.shuffle that return Configuration

Modifier and Type	Method and Description
Configuration	ShuffleEnvironmentContext.getConfiguration()

Methods in org.apache.flink.runtime.shuffle with parameters of type Configuration

Modifier and Type	Method and Description
ShuffleMaster<SD>	ShuffleServiceFactory.createShuffleMaster(Configuration configuration) Factory method to create a specific ShuffleMaster implementation.
static ShuffleServiceFactory<?,?,?>	ShuffleServiceLoader.loadShuffleServiceFactory(Configuration configuration)

Constructors in org.apache.flink.runtime.shuffle with parameters of type Configuration

Constructor and Description
ShuffleEnvironmentContext(Configuration configuration, ResourceID taskExecutorResourceId, MemorySize networkMemorySize, boolean localCommunicationOnly, InetAddress hostAddress, TaskEventPublisher eventPublisher, MetricGroup parentMetricGroup, Executor ioExecutor)

Uses of Configuration in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state with parameters of type Configuration

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 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 boolean	StateBackendLoader.stateBackendFromApplicationOrConfigOrDefaultUseManagedMemory(Configuration config, Optional<Boolean> stateBackendFromApplicationUsesManagedMemory, ClassLoader classLoader) Checks whether state backend uses managed memory, without having to deserialize or load the state backend.

Uses of Configuration in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor that return Configuration

Modifier and Type	Method and Description
static Configuration	TaskExecutorResourceUtils.adjustForLocalExecution(Configuration config)
Configuration	TaskManagerConfiguration.getConfiguration()
Configuration	TaskManagerServicesConfiguration.getConfiguration()
static Configuration	TaskManagerRunner.loadConfiguration(String[] args)

Methods in org.apache.flink.runtime.taskexecutor with parameters of type Configuration

Modifier and Type	Method and Description
static Configuration	TaskExecutorResourceUtils.adjustForLocalExecution(Configuration config)
static long	TaskExecutorResourceUtils.calculateTotalFlinkMemoryFromComponents(Configuration config)
static long	TaskExecutorResourceUtils.calculateTotalProcessMemoryFromComponents(Configuration config)
static TaskExecutorMemoryConfiguration	TaskExecutorMemoryConfiguration.create(Configuration config) Factory method for initializing a TaskExecutorMemoryConfiguration based on the passed Configuration.
TaskManagerRunner.TaskExecutorService	TaskManagerRunner.TaskExecutorServiceFactory.createTaskExecutor(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)
static TaskManagerRunner.TaskExecutorService	TaskManagerRunner.createTaskExecutorService(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)
static QueryableStateConfiguration	QueryableStateConfiguration.fromConfiguration(Configuration config) Creates the QueryableStateConfiguration from the given Configuration.
static TaskManagerServicesConfiguration	TaskManagerServicesConfiguration.fromConfiguration(Configuration configuration, ResourceID resourceID, String externalAddress, boolean localCommunicationOnly, TaskExecutorResourceSpec taskExecutorResourceSpec) Utility method to extract TaskManager config parameters from the configuration and to sanity check them.
static TaskManagerConfiguration	TaskManagerConfiguration.fromConfiguration(Configuration configuration, TaskExecutorResourceSpec taskExecutorResourceSpec, String externalAddress)
static TaskExecutorResourceSpec	TaskExecutorResourceUtils.resourceSpecFromConfigForLocalExecution(Configuration config)
static int	TaskManagerRunner.runTaskManager(Configuration configuration, PluginManager pluginManager)
static void	TaskManagerRunner.runTaskManagerProcessSecurely(Configuration configuration)
static TaskExecutor	TaskManagerRunner.startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, ExternalResourceInfoProvider externalResourceInfoProvider, FatalErrorHandler fatalErrorHandler)

Constructors in org.apache.flink.runtime.taskexecutor with parameters of type Configuration

Constructor and Description
TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, Time rpcTimeout, Time slotTimeout, Time maxRegistrationDuration, Configuration configuration, boolean exitJvmOnOutOfMemory, String taskManagerLogPath, String taskManagerStdoutPath, String taskManagerLogDir, String taskManagerExternalAddress, RetryingRegistrationConfiguration retryingRegistrationConfiguration)
TaskManagerRunner(Configuration configuration, PluginManager pluginManager, TaskManagerRunner.TaskExecutorServiceFactory taskExecutorServiceFactory)

Uses of Configuration in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return Configuration

Modifier and Type	Method and Description
Configuration	TaskManagerRuntimeInfo.getConfiguration() Gets the configuration that the TaskManager was started with.
Configuration	RuntimeEnvironment.getJobConfiguration()
Configuration	Task.getJobConfiguration()
Configuration	RuntimeEnvironment.getTaskConfiguration()
Configuration	Task.getTaskConfiguration()

Methods in org.apache.flink.runtime.taskmanager with parameters of type Configuration

Modifier and Type	Method and Description
static NettyShuffleEnvironmentConfiguration	NettyShuffleEnvironmentConfiguration.fromConfiguration(Configuration configuration, MemorySize networkMemorySize, boolean localTaskManagerCommunication, InetAddress taskManagerAddress) Utility method to extract network related parameters from the configuration and to sanity check them.
static void	MemoryLogger.startIfConfigured(org.slf4j.Logger logger, Configuration configuration, CompletableFuture<Void> taskManagerTerminationFuture)

Constructors in org.apache.flink.runtime.taskmanager with parameters of type Configuration

Constructor and Description

RuntimeEnvironment(JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, ExecutionConfig executionConfig, TaskInfo taskInfo, Configuration jobConfiguration, Configuration taskConfiguration, UserCodeClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, TaskStateManager taskStateManager, GlobalAggregateManager aggregateManager, AccumulatorRegistry accumulatorRegistry, TaskKvStateRegistry kvStateRegistry, InputSplitProvider splitProvider, Map<String,Future<Path>> distCacheEntries, ResultPartitionWriter[] writers, IndexedInputGate[] inputGates, TaskEventDispatcher taskEventDispatcher, CheckpointResponder checkpointResponder, TaskOperatorEventGateway operatorEventGateway, TaskManagerRuntimeInfo taskManagerInfo, TaskMetricGroup metrics, Task containingTask, ExternalResourceInfoProvider externalResourceInfoProvider)

Uses of Configuration in org.apache.flink.runtime.util

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

Modifier and Type	Method and Description
static Configuration	ConfigurationParserUtils.loadCommonConfiguration(String[] args, String cmdLineSyntax) Generate configuration from only the config file and dynamic properties.

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

Modifier and Type	Method and Description
static ZooKeeperCheckpointIDCounter	ZooKeeperUtils.createCheckpointIDCounter(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, JobID jobId) Creates a ZooKeeperCheckpointIDCounter instance.
static CompletedCheckpointStore	ZooKeeperUtils.createCompletedCheckpoints(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, JobID jobId, int maxNumberOfCheckpointsToRetain, Executor executor) Creates a DefaultCompletedCheckpointStore instance with ZooKeeperStateHandleStore.
static <T extends Serializable> FileSystemStateStorageHelper<T>	ZooKeeperUtils.createFileSystemStateStorage(Configuration configuration, String prefix) Creates a FileSystemStateStorageHelper instance.
static JobGraphStore	ZooKeeperUtils.createJobGraphs(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration) Creates a DefaultJobGraphStore instance with ZooKeeperStateHandleStore, ZooKeeperJobGraphStoreWatcher and ZooKeeperJobGraphStoreUtil.
static ZooKeeperLeaderElectionDriverFactory	ZooKeeperUtils.createLeaderElectionDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration) Creates a LeaderElectionDriverFactory implemented by ZooKeeper.
static ZooKeeperLeaderElectionDriverFactory	ZooKeeperUtils.createLeaderElectionDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, String pathSuffix) Creates a LeaderElectionDriverFactory implemented by ZooKeeper.
static DefaultLeaderElectionService	ZooKeeperUtils.createLeaderElectionService(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration) Creates a DefaultLeaderElectionService instance with ZooKeeperLeaderElectionDriver.
static DefaultLeaderElectionService	ZooKeeperUtils.createLeaderElectionService(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, String pathSuffix) Creates a DefaultLeaderElectionService instance with ZooKeeperLeaderElectionDriver.
static ZooKeeperLeaderRetrievalDriverFactory	ZooKeeperUtils.createLeaderRetrievalDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration) Creates a LeaderRetrievalDriverFactory implemented by ZooKeeper.
static ZooKeeperLeaderRetrievalDriverFactory	ZooKeeperUtils.createLeaderRetrievalDriverFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, String pathSuffix) Creates a LeaderRetrievalDriverFactory implemented by ZooKeeper.
static DefaultLeaderRetrievalService	ZooKeeperUtils.createLeaderRetrievalService(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration) Creates a DefaultLeaderRetrievalService instance with ZooKeeperLeaderRetrievalDriver.
static DefaultLeaderRetrievalService	ZooKeeperUtils.createLeaderRetrievalService(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, String pathSuffix) Creates a DefaultLeaderRetrievalService instance with ZooKeeperLeaderRetrievalDriver.
static ZooKeeperUtils.ZkClientACLMode	ZooKeeperUtils.ZkClientACLMode.fromConfig(Configuration config) Return the configured ZooKeeperUtils.ZkClientACLMode.
static Configuration	HadoopUtils.getHadoopConfiguration(Configuration flinkConfiguration)
static int	ConfigurationParserUtils.getPageSize(Configuration configuration) Parses the configuration to get the page size and validates the value.
static int	ConfigurationParserUtils.getSlot(Configuration configuration) Parses the configuration to get the number of slots and validates the value.
static String	ZooKeeperUtils.getZooKeeperEnsemble(Configuration flinkConf) Returns the configured ZooKeeper quorum (and removes whitespace, because ZooKeeper does not tolerate it).
static boolean	ZooKeeperUtils.isZooKeeperRecoveryMode(Configuration flinkConf) Returns whether HighAvailabilityMode.ZOOKEEPER is configured.
void	HadoopConfigLoader.setFlinkConfig(Configuration config)
static org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework	ZooKeeperUtils.startCuratorFramework(Configuration configuration) Starts a CuratorFramework instance and connects it to the given ZooKeeper quorum.

Uses of Configuration in org.apache.flink.runtime.util.bash

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

Modifier and Type	Method and Description
static Configuration	FlinkConfigLoader.loadConfiguration(String[] args)

Uses of Configuration in org.apache.flink.runtime.util.config.memory

Methods in org.apache.flink.runtime.util.config.memory that return Configuration

Modifier and Type	Method and Description
Configuration	MemoryBackwardsCompatibilityUtils.getConfWithLegacyHeapSizeMappedToNewConfigOption(Configuration configuration, ConfigOption<MemorySize> configOption)

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

Modifier and Type	Method and Description
static double	ManagedMemoryUtils.convertToFractionOfSlot(ManagedMemoryUseCase useCase, double fractionOfUseCase, Set<ManagedMemoryUseCase> allUseCases, Configuration config, Optional<Boolean> stateBackendFromApplicationUsesManagedMemory, ClassLoader classLoader)
FM	FlinkMemoryUtils.deriveFromRequiredFineGrainedOptions(Configuration config)
FM	FlinkMemoryUtils.deriveFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)
JvmMetaspaceAndOverhead	ProcessMemoryUtils.deriveJvmMetaspaceAndOverheadFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)
Configuration	MemoryBackwardsCompatibilityUtils.getConfWithLegacyHeapSizeMappedToNewConfigOption(Configuration configuration, ConfigOption<MemorySize> configOption)
static MemorySize	ProcessMemoryUtils.getMemorySizeFromConfig(Configuration config, ConfigOption<MemorySize> option)
static RangeFraction	ProcessMemoryUtils.getRangeFraction(MemorySize minSize, MemorySize maxSize, ConfigOption<Float> fractionOption, Configuration config)
CommonProcessMemorySpec<FM>	ProcessMemoryUtils.memoryProcessSpecFromConfig(Configuration config)

Uses of Configuration in org.apache.flink.runtime.util.config.memory.jobmanager

Methods in org.apache.flink.runtime.util.config.memory.jobmanager with parameters of type Configuration

Modifier and Type	Method and Description
JobManagerFlinkMemory	JobManagerFlinkMemoryUtils.deriveFromRequiredFineGrainedOptions(Configuration config)
JobManagerFlinkMemory	JobManagerFlinkMemoryUtils.deriveFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)

Uses of Configuration in org.apache.flink.runtime.util.config.memory.taskmanager

Methods in org.apache.flink.runtime.util.config.memory.taskmanager with parameters of type Configuration

Modifier and Type	Method and Description
TaskExecutorFlinkMemory	TaskExecutorFlinkMemoryUtils.deriveFromRequiredFineGrainedOptions(Configuration config)
TaskExecutorFlinkMemory	TaskExecutorFlinkMemoryUtils.deriveFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)
static MemorySize	TaskExecutorFlinkMemoryUtils.getFrameworkHeapMemorySize(Configuration config)
static MemorySize	TaskExecutorFlinkMemoryUtils.getFrameworkOffHeapMemorySize(Configuration config)

Uses of Configuration in org.apache.flink.runtime.webmonitor

Fields in org.apache.flink.runtime.webmonitor declared as Configuration

Modifier and Type	Field and Description
protected Configuration	WebMonitorEndpoint.clusterConfiguration

Methods in org.apache.flink.runtime.webmonitor with parameters of type Configuration

Modifier and Type	Method and Description
static WebMonitorUtils.LogFileLocation	WebMonitorUtils.LogFileLocation.find(Configuration config) Finds the Flink log directory using log.file Java property that is set during startup.
static WebMonitorExtension	WebMonitorUtils.loadWebSubmissionExtension(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path uploadDir, Executor executor, Configuration configuration) Loads the WebMonitorExtension which enables web submission.

Constructors in org.apache.flink.runtime.webmonitor with parameters of type Configuration

Constructor and Description
WebMonitorEndpoint(RestServerEndpointConfiguration endpointConfiguration, GatewayRetriever<? extends T> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler)
WebSubmissionExtension(Configuration configuration, GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Map<String,String> responseHeaders, CompletableFuture<String> localAddressFuture, Path jarDir, Executor executor, Time timeout)

Uses of Configuration in org.apache.flink.runtime.webmonitor.handlers

Constructors in org.apache.flink.runtime.webmonitor.handlers with parameters of type Configuration

Constructor and Description
JarListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarListInfo,EmptyMessageParameters> messageHeaders, CompletableFuture<String> localAddressFuture, File jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, java.util.function.Function<JobGraph,JobPlanInfo> planGenerator)
JarRunHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<JarRunRequestBody,JarRunResponseBody,JarRunMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, java.util.function.Supplier<ApplicationRunner> applicationRunnerSupplier)

Uses of Configuration in org.apache.flink.runtime.webmonitor.handlers.utils

Methods in org.apache.flink.runtime.webmonitor.handlers.utils with parameters of type Configuration

Modifier and Type	Method and Description
void	JarHandlerUtils.JarHandlerContext.applyToConfiguration(Configuration configuration)
JobGraph	JarHandlerUtils.JarHandlerContext.toJobGraph(PackagedProgram packagedProgram, Configuration configuration, boolean suppressOutput)
PackagedProgram	JarHandlerUtils.JarHandlerContext.toPackagedProgram(Configuration configuration)

Uses of Configuration in org.apache.flink.runtime.webmonitor.history

Methods in org.apache.flink.runtime.webmonitor.history with parameters of type Configuration

Modifier and Type	Method and Description
static Optional<URL>	HistoryServerUtils.getHistoryServerURL(Configuration configuration)
static boolean	HistoryServerUtils.isSSLEnabled(Configuration config)

Constructors in org.apache.flink.runtime.webmonitor.history with parameters of type Configuration

Constructor and Description
HistoryServer(Configuration config)
HistoryServer(Configuration config, java.util.function.Consumer<HistoryServerArchiveFetcher.ArchiveEvent> jobArchiveEventListener) Creates HistoryServer instance.

Uses of Configuration in org.apache.flink.runtime.webmonitor.utils

Constructors in org.apache.flink.runtime.webmonitor.utils with parameters of type Configuration

Constructor and Description
WebFrontendBootstrap(Router router, org.slf4j.Logger log, File directory, SSLHandlerFactory serverSSLFactory, String configuredAddress, int configuredPort, Configuration config)

Uses of Configuration in org.apache.flink.runtime.zookeeper

Constructors in org.apache.flink.runtime.zookeeper with parameters of type Configuration

Constructor and Description
ZooKeeperUtilityFactory(Configuration configuration, String path)

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

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

Modifier and Type	Method and Description
abstract void	KeyedStateReaderFunction.open(Configuration parameters) Initialization method for the function.

Uses of Configuration in org.apache.flink.state.api.input

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

Modifier and Type	Method and Description
void	KeyedStateInputFormat.configure(Configuration parameters)

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

Constructor and Description
KeyedStateInputFormat(OperatorState operatorState, StateBackend stateBackend, Configuration configuration, StateReaderOperator<?,K,N,OUT> operator) Creates an input format for reading partitioned state from an operator in a savepoint.

Uses of Configuration in org.apache.flink.state.api.input.operator.window

Methods in org.apache.flink.state.api.input.operator.window with parameters of type Configuration

Modifier and Type	Method and Description
void	EvictingWindowReaderFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.state.api.output

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

Modifier and Type	Method and Description
void	FileCopyFunction.configure(Configuration parameters)
void	SavepointOutputFormat.configure(Configuration parameters)
void	BoundedOneInputStreamTaskRunner.open(Configuration parameters)
void	OperatorSubtaskStateReducer.open(Configuration parameters)

Uses of Configuration in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime that return Configuration

Modifier and Type	Method and Description
Configuration	SavepointEnvironment.getJobConfiguration()
Configuration	SavepointEnvironment.getTaskConfiguration()

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

Modifier and Type	Method and Description
SavepointEnvironment.Builder	SavepointEnvironment.Builder.setConfiguration(Configuration configuration)

Uses of Configuration in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment that return Configuration

Modifier and Type	Method and Description
Configuration	RemoteStreamEnvironment.getClientConfiguration() Deprecated. This method is going to be removed in the next releases.
protected Configuration	StreamExecutionEnvironment.getConfiguration()

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

Modifier and Type	Method and Description
StreamExecutionEnvironment	StreamExecutionEnvironmentFactory.createExecutionEnvironment(Configuration configuration) Creates a StreamExecutionEnvironment from this factory.
static LocalStreamEnvironment	StreamExecutionEnvironment.createLocalEnvironment(Configuration configuration) Creates a LocalStreamEnvironment.
static LocalStreamEnvironment	StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration) Creates a LocalStreamEnvironment.
static StreamExecutionEnvironment	StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(Configuration conf) Creates a LocalStreamEnvironment for local program execution that also starts the web monitoring UI.
static StreamExecutionEnvironment	StreamExecutionEnvironment.createRemoteEnvironment(String host, int port, Configuration clientConfig, String... jarFiles) Creates a RemoteStreamEnvironment.
static StreamExecutionEnvironment	StreamExecutionEnvironment.getExecutionEnvironment(Configuration configuration) Creates an execution environment that represents the context in which the program is currently executed.

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

Constructor and Description
LocalStreamEnvironment(Configuration configuration) Creates a new mini cluster stream environment that configures its local executor with the given configuration.
RemoteStreamEnvironment(PipelineExecutorServiceLoader executorServiceLoader, String host, int port, Configuration clientConfiguration, String[] jarFiles, URL[] globalClasspaths, SavepointRestoreSettings savepointRestoreSettings)
RemoteStreamEnvironment(String host, int port, Configuration clientConfiguration, String... jarFiles) Creates a new RemoteStreamEnvironment that points to the master (JobManager) described by the given host name and port.
RemoteStreamEnvironment(String host, int port, Configuration clientConfiguration, String[] jarFiles, URL[] globalClasspaths) Creates a new RemoteStreamEnvironment that points to the master (JobManager) described by the given host name and port.
RemoteStreamEnvironment(String host, int port, Configuration clientConfiguration, String[] jarFiles, URL[] globalClasspaths, SavepointRestoreSettings savepointRestoreSettings) Creates a new RemoteStreamEnvironment that points to the master (JobManager) described by the given host name and port.
StreamExecutionEnvironment(Configuration configuration) Creates a new StreamExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.
StreamExecutionEnvironment(Configuration configuration, ClassLoader userClassloader) Creates a new StreamExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.
StreamExecutionEnvironment(PipelineExecutorServiceLoader executorServiceLoader, Configuration configuration, ClassLoader userClassloader) Creates a new StreamExecutionEnvironment that will use the given Configuration to configure the PipelineExecutor.

Uses of Configuration in org.apache.flink.streaming.api.functions.sink

Methods in org.apache.flink.streaming.api.functions.sink with parameters of type Configuration

Modifier and Type	Method and Description
void	SocketClientSink.open(Configuration parameters) Initialize the connection with the Socket in the server.
void	PrintSinkFunction.open(Configuration parameters)
void	OutputFormatSinkFunction.open(Configuration parameters) Deprecated.

Uses of Configuration in org.apache.flink.streaming.api.functions.source

Methods in org.apache.flink.streaming.api.functions.source with parameters of type Configuration

Modifier and Type	Method and Description
void	MultipleIdsMessageAcknowledgingSourceBase.open(Configuration parameters)
void	ContinuousFileMonitoringFunction.open(Configuration parameters)
void	FromSplittableIteratorFunction.open(Configuration parameters)
void	InputFormatSourceFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.api.functions.source.datagen

Methods in org.apache.flink.streaming.api.functions.source.datagen with parameters of type Configuration

Modifier and Type	Method and Description
void	DataGeneratorSource.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.api.functions.windowing

Methods in org.apache.flink.streaming.api.functions.windowing with parameters of type Configuration

Modifier and Type	Method and Description
void	ReduceApplyProcessWindowFunction.open(Configuration configuration)
void	ReduceApplyProcessAllWindowFunction.open(Configuration configuration)

Uses of Configuration in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph that return Configuration

Modifier and Type	Method and Description
Configuration	StreamConfig.getConfiguration()

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

Modifier and Type	Method and Description
double	StreamConfig.getManagedMemoryFractionOperatorUseCaseOfSlot(ManagedMemoryUseCase managedMemoryUseCase, Configuration taskManagerConfig, ClassLoader cl) Fraction of total managed memory in the slot that this operator should use for the given use case.

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

Constructor and Description
StreamConfig(Configuration config)

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

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

Modifier and Type	Method and Description
Configuration	AbstractUdfStreamOperator.getUserFunctionParameters() Since the streaming API does not implement any parametrization of functions via a configuration, the config returned here is actually empty.

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

Constructor and Description
SourceOperator(FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory, OperatorEventGateway operatorEventGateway, SimpleVersionedSerializer<SplitT> splitSerializer, WatermarkStrategy<OUT> watermarkStrategy, ProcessingTimeService timeService, Configuration configuration, String localHostname, boolean emitProgressiveWatermarks)

Uses of Configuration in org.apache.flink.streaming.api.operators.collect

Methods in org.apache.flink.streaming.api.operators.collect with parameters of type Configuration

Modifier and Type	Method and Description
void	CollectSinkFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.api.operators.python

Constructors in org.apache.flink.streaming.api.operators.python with parameters of type Configuration

Constructor and Description
AbstractOneInputPythonFunctionOperator(Configuration config)
AbstractPythonFunctionOperator(Configuration config)
AbstractTwoInputPythonFunctionOperator(Configuration config)
OneInputPythonFunctionOperator(Configuration config, TypeInformation<UDFIN> runnerInputTypeInfo, TypeInformation<UDFOUT> runnerOutputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonCoFlatMapOperator(Configuration config, TypeInformation<IN1> inputTypeInfo1, TypeInformation<IN2> inputTypeInfo2, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonCoMapOperator(Configuration config, TypeInformation<IN1> inputTypeInfo1, TypeInformation<IN2> inputTypeInfo2, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonFlatMapOperator(Configuration config, TypeInformation<IN> inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonKeyedCoProcessOperator(Configuration config, TypeInformation<Row> inputTypeInfo1, TypeInformation<Row> inputTypeInfo2, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonKeyedProcessOperator(Configuration config, RowTypeInfo inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonKeyedProcessOperator(Configuration config, RowTypeInfo inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo, TypeSerializer namespaceSerializer)
PythonMapOperator(Configuration config, TypeInformation<IN> inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonPartitionCustomOperator(Configuration config, TypeInformation<IN> inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonProcessOperator(Configuration config, TypeInformation<IN> inputTypeInfo, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo)
PythonTimestampsAndWatermarksOperator(Configuration config, TypeInformation<IN> inputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo, WatermarkStrategy<IN> watermarkStrategy)
TwoInputPythonFunctionOperator(Configuration config, DataStreamPythonFunctionInfo pythonFunctionInfo, String coderUrn, TypeInformation<Row> runnerInputTypeInfo, TypeInformation<RUNNER_OUT> runnerOutputTypeInfo)
TwoInputPythonFunctionOperator(Configuration config, TypeInformation<IN1> inputTypeInfo1, TypeInformation<IN2> inputTypeInfo2, TypeInformation<OUT> outputTypeInfo, DataStreamPythonFunctionInfo pythonFunctionInfo, String coderUrn)

Uses of Configuration in org.apache.flink.streaming.api.operators.sort

Methods in org.apache.flink.streaming.api.operators.sort with parameters of type Configuration

Modifier and Type

Method and Description

static <K> MultiInputSortingDataInput.SelectableSortingInputs

MultiInputSortingDataInput.wrapInputs(AbstractInvokable containingTask, StreamTaskInput<Object>[] sortingInputs, KeySelector<Object,K>[] keySelectors, TypeSerializer<Object>[] inputSerializers, TypeSerializer<K> keySerializer, StreamTaskInput<Object>[] passThroughInputs, MemoryManager memoryManager, IOManager ioManager, boolean objectReuse, double managedMemoryFraction, Configuration jobConfiguration)

Constructors in org.apache.flink.streaming.api.operators.sort with parameters of type Configuration

Constructor and Description
SortingDataInput(StreamTaskInput<T> wrappedInput, TypeSerializer<T> typeSerializer, TypeSerializer<K> keySerializer, KeySelector<T,K> keySelector, MemoryManager memoryManager, IOManager ioManager, boolean objectReuse, double managedMemoryFraction, Configuration jobConfiguration, AbstractInvokable containingTask)

Uses of Configuration in org.apache.flink.streaming.connectors.cassandra

Methods in org.apache.flink.streaming.connectors.cassandra with parameters of type Configuration

Modifier and Type	Method and Description
void	CassandraPojoSink.open(Configuration configuration)
void	AbstractCassandraTupleSink.open(Configuration configuration)
void	CassandraSinkBase.open(Configuration configuration)

Uses of Configuration in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch with parameters of type Configuration

Modifier and Type	Method and Description
void	ElasticsearchSinkBase.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.connectors.gcp.pubsub

Methods in org.apache.flink.streaming.connectors.gcp.pubsub with parameters of type Configuration

Modifier and Type	Method and Description
void	PubSubSink.open(Configuration configuration)
void	PubSubSource.open(Configuration configuration)

Uses of Configuration in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type Configuration

Modifier and Type	Method and Description
void	FlinkKafkaConsumerBase.open(Configuration configuration)
void	FlinkKafkaProducerBase.open(Configuration configuration) Initializes the connection to Kafka.
void	FlinkKafkaProducer.open(Configuration configuration) Initializes the connection to Kafka.

Uses of Configuration in org.apache.flink.streaming.connectors.kafka.table

Methods in org.apache.flink.streaming.connectors.kafka.table with parameters of type Configuration

Modifier and Type	Method and Description
void	BufferedUpsertSinkFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.connectors.kinesis

Methods in org.apache.flink.streaming.connectors.kinesis with parameters of type Configuration

Modifier and Type	Method and Description
void	FlinkKinesisProducer.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.connectors.nifi

Methods in org.apache.flink.streaming.connectors.nifi with parameters of type Configuration

Modifier and Type	Method and Description
void	NiFiSource.open(Configuration parameters)
void	NiFiSink.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.connectors.rabbitmq

Methods in org.apache.flink.streaming.connectors.rabbitmq with parameters of type Configuration

Modifier and Type	Method and Description
void	RMQSink.open(Configuration config)
void	RMQSource.open(Configuration config)

Uses of Configuration in org.apache.flink.streaming.connectors.twitter

Methods in org.apache.flink.streaming.connectors.twitter with parameters of type Configuration

Modifier and Type	Method and Description
void	TwitterSource.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.experimental

Methods in org.apache.flink.streaming.experimental with parameters of type Configuration

Modifier and Type	Method and Description
void	CollectSink.open(Configuration parameters) Initialize the connection with the Socket in the server.

Uses of Configuration in org.apache.flink.streaming.kafka.test.base

Methods in org.apache.flink.streaming.kafka.test.base with parameters of type Configuration

Modifier and Type	Method and Description
void	RollingAdditionMapper.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.runtime.io

Methods in org.apache.flink.streaming.runtime.io with parameters of type Configuration

Modifier and Type	Method and Description
static <IN1,IN2> StreamTwoInputProcessor<IN1,IN2>	StreamTwoInputProcessorFactory.create(AbstractInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, IOManager ioManager, MemoryManager memoryManager, TaskIOMetricGroup taskIOMetricGroup, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, BoundedMultiInput endOfInputAware, StreamConfig streamConfig, Configuration taskManagerConfig, Configuration jobConfig, ExecutionConfig executionConfig, ClassLoader userClassloader, Counter numRecordsIn, InflightDataRescalingDescriptor inflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, TaskInfo taskInfo)
static StreamMultipleInputProcessor	StreamMultipleInputProcessorFactory.create(AbstractInvokable ownerTask, CheckpointedInputGate[] checkpointedInputGates, StreamConfig.InputConfig[] configuredInputs, IOManager ioManager, MemoryManager memoryManager, TaskIOMetricGroup ioMetricGroup, Counter mainOperatorRecordsIn, StreamStatusMaintainer streamStatusMaintainer, MultipleInputStreamOperator<?> mainOperator, WatermarkGauge[] inputWatermarkGauges, StreamConfig streamConfig, Configuration taskManagerConfig, Configuration jobConfig, ExecutionConfig executionConfig, ClassLoader userClassloader, OperatorChain<?,?> operatorChain, InflightDataRescalingDescriptor inflightDataRescalingDescriptor, java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners, TaskInfo taskInfo)

Uses of Configuration in org.apache.flink.streaming.runtime.operators.windowing.functions

Methods in org.apache.flink.streaming.runtime.operators.windowing.functions with parameters of type Configuration

Modifier and Type	Method and Description
void	InternalAggregateProcessAllWindowFunction.open(Configuration parameters)
void	InternalSingleValueProcessAllWindowFunction.open(Configuration parameters)
void	InternalIterableProcessAllWindowFunction.open(Configuration parameters)

Uses of Configuration in org.apache.flink.streaming.tests

Methods in org.apache.flink.streaming.tests with parameters of type Configuration

Modifier and Type	Method and Description
void	SemanticsCheckMapper.open(Configuration parameters)
void	SlidingWindowCheckMapper.