Uses of Class
org.apache.hadoop.conf.Configuration

Packages that use Configuration

Package	Description
org.apache.flink.addons.hbase
org.apache.flink.api.java.hadoop.mapred.utils
org.apache.flink.api.java.hadoop.mapreduce
org.apache.flink.api.java.hadoop.mapreduce.utils
org.apache.flink.formats.sequencefile
org.apache.flink.fs.s3.common
org.apache.flink.fs.s3hadoop
org.apache.flink.fs.s3presto
org.apache.flink.hcatalog
org.apache.flink.hcatalog.java
org.apache.flink.orc
org.apache.flink.runtime.security.modules
org.apache.flink.runtime.util
org.apache.flink.streaming.connectors.fs
org.apache.flink.streaming.connectors.fs.bucketing
org.apache.flink.yarn
org.apache.flink.yarn.highavailability
org.apache.hadoop.conf

Uses of Configuration in org.apache.flink.addons.hbase

Constructors in org.apache.flink.addons.hbase with parameters of type Configuration

Constructor and Description
HBaseRowInputFormat(Configuration conf, String tableName, HBaseTableSchema schema)
HBaseTableSource(Configuration conf, String tableName) The HBase configuration and the name of the table to read.

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

Methods in org.apache.flink.api.java.hadoop.mapred.utils that return 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).

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

Fields in org.apache.flink.api.java.hadoop.mapreduce declared as Configuration

Modifier and Type	Field and Description
protected Configuration	HadoopOutputFormatBase.configuration

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

Modifier and Type	Method and Description
Configuration	HadoopOutputFormatBase.getConfiguration()
Configuration	HadoopInputFormatBase.getConfiguration()

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

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

Modifier and Type	Method and Description
static void	HadoopUtils.mergeHadoopConf(Configuration hadoopConfig) Merge HadoopConfiguration into Configuration.

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

Constructors in org.apache.flink.formats.sequencefile with parameters of type Configuration

Constructor and Description
SequenceFileWriterFactory(Configuration hadoopConf, Class<K> keyClass, Class<V> valueClass) Creates a new SequenceFileWriterFactory using the given builder to assemble the SequenceFileWriter.
SequenceFileWriterFactory(Configuration hadoopConf, Class<K> keyClass, Class<V> valueClass, String compressionCodecName) Creates a new SequenceFileWriterFactory using the given builder to assemble the SequenceFileWriter.
SequenceFileWriterFactory(Configuration hadoopConf, Class<K> keyClass, Class<V> valueClass, String compressionCodecName, org.apache.hadoop.io.SequenceFile.CompressionType compressionType) Creates a new SequenceFileWriterFactory using the given builder to assemble the SequenceFileWriter.

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

Methods in org.apache.flink.fs.s3.common that return Configuration

Modifier and Type	Method and Description
Configuration	HadoopConfigLoader.getOrLoadHadoopConfig() get the loaded Hadoop config (or fall back to one loaded from the classpath).

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

Modifier and Type	Method and Description
protected abstract URI	AbstractS3FileSystemFactory.getInitURI(URI fsUri, Configuration hadoopConfig)

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

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

Modifier and Type	Method and Description
protected URI	S3FileSystemFactory.getInitURI(URI fsUri, Configuration hadoopConfig)

Constructors in org.apache.flink.fs.s3hadoop with parameters of type Configuration

Constructor and Description
HadoopS3AccessHelper(org.apache.hadoop.fs.s3a.S3AFileSystem s3a, Configuration conf)

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

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

Modifier and Type	Method and Description
protected URI	S3FileSystemFactory.getInitURI(URI fsUri, Configuration hadoopConfig)

Uses of Configuration in org.apache.flink.hcatalog

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

Modifier and Type	Method and Description
Configuration	HCatInputFormatBase.getConfiguration() Returns the Configuration of the HCatInputFormat.

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

Constructor and Description
HCatInputFormatBase(String database, String table, Configuration config) Creates a HCatInputFormat for the given database, table, and Configuration.

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

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

Constructor and Description
HCatInputFormat(String database, String table, 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
OrcTableSource.Builder	OrcTableSource.Builder.withConfiguration(Configuration config) Sets a Hadoop Configuration for the ORC reader.

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

Constructor and Description
OrcRowInputFormat(String path, String schemaString, Configuration orcConfig) Creates an OrcRowInputFormat.
OrcRowInputFormat(String path, String schemaString, Configuration orcConfig, int batchSize) Creates an OrcRowInputFormat.
OrcRowInputFormat(String path, org.apache.orc.TypeDescription orcSchema, Configuration orcConfig, int batchSize) Creates an OrcRowInputFormat.

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

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

Constructor and Description
HadoopModule(SecurityConfiguration securityConfiguration, Configuration hadoopConfiguration)

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	HadoopUtils.getHadoopConfiguration(Configuration flinkConfiguration)

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

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

Modifier and Type	Method and Description
RollingSink<T>	RollingSink.setFSConfig(Configuration config) Deprecated. Specify a custom Configuration that will be used when creating the FileSystem for writing.

Uses of Configuration in org.apache.flink.streaming.connectors.fs.bucketing

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

Modifier and Type	Method and Description
BucketingSink<T>	BucketingSink.setFSConfig(Configuration config) Specify a custom Configuration that will be used when creating the FileSystem for writing.

Uses of Configuration in org.apache.flink.yarn

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

Modifier and Type	Method and Description
static void	Utils.setTokensFor(org.apache.hadoop.yarn.api.records.ContainerLaunchContext amContainer, List<org.apache.hadoop.fs.Path> paths, Configuration conf)
static void	Utils.setupYarnClassPath(Configuration conf, Map<String,String> appMasterEnv)

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

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

Modifier and Type	Method and Description
static YarnHighAvailabilityServices	YarnHighAvailabilityServices.forSingleJobAppMaster(Configuration flinkConfig, Configuration hadoopConfig) Creates the high-availability services for a single-job Flink YARN application, to be used in the Application Master that runs both ResourceManager and JobManager.
static YarnHighAvailabilityServices	YarnHighAvailabilityServices.forYarnTaskManager(Configuration flinkConfig, Configuration hadoopConfig) Creates the high-availability services for the TaskManagers participating in a Flink YARN application.

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

Constructor and Description
AbstractYarnNonHaServices(Configuration config, Configuration hadoopConf) Creates new YARN high-availability services, configuring the file system and recovery data directory based on the working directory in the given Hadoop configuration.
YarnHighAvailabilityServices(Configuration config, Configuration hadoopConf) Creates new YARN high-availability services, configuring the file system and recovery data directory based on the working directory in the given Hadoop configuration.
YarnIntraNonHaMasterServices(Configuration config, Configuration hadoopConf) Creates new YarnIntraNonHaMasterServices for the given Flink and YARN configuration.
YarnPreConfiguredMasterNonHaServices(Configuration config, Configuration hadoopConf, HighAvailabilityServicesUtils.AddressResolution addressResolution) Creates new YarnPreConfiguredMasterHaServices for the given Flink and YARN configuration.

Uses of Configuration in org.apache.hadoop.conf

Methods in org.apache.hadoop.conf with parameters of type Configuration

Modifier and Type	Method and Description
void	Configuration.addResource(Configuration conf) Add a configuration resource.
static void	Configuration.dumpConfiguration(Configuration config, String propertyName, Writer out) Writes properties and their attributes (final and resource) to the given Writer.
static void	Configuration.dumpConfiguration(Configuration config, Writer out) Writes out all properties and their attributes (final and resource) to the given Writer, the format of the output would be,

Constructors in org.apache.hadoop.conf with parameters of type Configuration

Constructor and Description
Configuration(Configuration other) A new configuration with the same settings cloned from another.