Uses of Class
org.apache.hadoop.conf.Configuration
Packages that use Configuration
Package
Description
Configuration of system parameters.
Crypto related classes.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
An abstract file system API.
This package contains implementation classes for use inside
filesystems.
block caching for use in object store clients.
This package provides support for HDFS permission and ACL.
SFTP FileSystem package.
Support for the execution of a file system command.
This package is for classes to be shared across object stores; for internal
use within the hadoop-* modules only.
ViewFileSystem and ViewFileSystemOverloadScheme classes.
Support for embedded HTTP services.
This package provides user-selectable (via configuration) classes that add
functionality to the web UI.
Generic i/o code for use when reading and writing data to the network,
to databases, and to files.
Implementation of compression/decompression for the BZip2
compression algorithm.
Implementation of compression/decompression for the LZ4
compression algorithm.
Implementation of compression/decompression for the Snappy
compression algorithm.
Implementation of compression/decompression based on the popular
gzip compressed file format.
Implementation of compression/decompression based on the zStandard
compression algorithm.
Erasure codec framework.
A mechanism for selectively retrying methods that throw exceptions under
certain circumstances.
This package provides a mechanism for using different serialization frameworks
in Hadoop.
Tools to help define network clients and servers.
RPC related metrics.
Builtin metrics sinks
Network-related classes.
Classes for hadoop security.
Provides the hadoop credential provider API.
Provides the server-side framework for authentication.
Support for service-level authorization.
Filters for HTTP service security.
Support for delegation tokens.
ZooKeeper secret manager for TokenIdentifiers and DelegationKeys.
Support for services.
This package contains classes, interfaces and exceptions to launch
YARN services from the command line.
Common utilities.
This package provides utilities to interact with Curator ZooKeeper.
Support for functional programming within the Hadoop APIs.
-
Uses of Configuration in org.apache.hadoop.conf
Subclasses of Configuration in org.apache.hadoop.confMethods in org.apache.hadoop.conf that return ConfigurationModifier and TypeMethodDescriptionConfigurable.getConf()Return the configuration used by this object.Configured.getConf()protected abstract ConfigurationReconfigurableBase.getNewConf()Create a new configuration.Methods in org.apache.hadoop.conf with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidConfiguration.addResource(Configuration conf) Add a configuration resource.static voidConfiguration.dumpConfiguration(Configuration config, Writer out) Writes out all properties and their attributes (final and resource) to the givenWriter, the format of the output would be,static voidConfiguration.dumpConfiguration(Configuration config, String propertyName, Writer out) Writes properties and their attributes (final and resource) to the givenWriter.ReconfigurableBase.getChangedProperties(Configuration newConf, Configuration oldConf) ReconfigurationUtil.getChangedProperties(Configuration newConf, Configuration oldConf) ReconfigurationUtil.parseChangedProperties(Configuration newConf, Configuration oldConf) voidConfigurable.setConf(Configuration conf) Set the configuration to be used by this object.voidConfigured.setConf(Configuration conf) voidConfiguration.writeXml(String propertyName, Writer out, Configuration config) Write out the non-default properties in this configuration to the givenWriter.Constructors in org.apache.hadoop.conf with parameters of type ConfigurationModifierConstructorDescriptionConfigRedactor(Configuration conf) Configuration(Configuration other) A new configuration with the same settings cloned from another.Configured(Configuration conf) Construct a Configured.Construct a ReconfigurableBase with theConfigurationconf. -
Uses of Configuration in org.apache.hadoop.crypto
Methods in org.apache.hadoop.crypto that return ConfigurationMethods in org.apache.hadoop.crypto with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic intCryptoStreamUtils.getBufferSize(Configuration conf) Read crypto buffer size.static CryptoCodecCryptoCodec.getInstance(Configuration conf) Get crypto codec for algorithm/mode/padding in config value hadoop.security.crypto.cipher.suitestatic CryptoCodecCryptoCodec.getInstance(Configuration conf, CipherSuite cipherSuite) Get crypto codec for specified algorithm/mode/padding.static StringCryptoUtils.getJceProvider(Configuration conf) Get the security provider value specified inCommonConfigurationKeysPublic.HADOOP_SECURITY_CRYPTO_JCE_PROVIDER_KEYfrom the given conf.voidJceCtrCryptoCodec.setConf(Configuration conf) voidOpensslCtrCryptoCodec.setConf(Configuration conf) voidOpensslSm4CtrCryptoCodec.setConf(Configuration conf) -
Uses of Configuration in org.apache.hadoop.crypto.key
Methods in org.apache.hadoop.crypto.key that return ConfigurationMethods in org.apache.hadoop.crypto.key with parameters of type ConfigurationModifier and TypeMethodDescriptionJavaKeyStoreProvider.Factory.createProvider(URI providerName, Configuration conf) abstract KeyProviderKeyProviderFactory.createProvider(URI providerName, Configuration conf) UserProvider.Factory.createProvider(URI providerName, Configuration conf) static KeyProviderKeyProviderFactory.get(URI uri, Configuration conf) Create a KeyProvider based on a provided URI.static List<KeyProvider>KeyProviderFactory.getProviders(Configuration conf) static KeyProvider.OptionsKeyProvider.options(Configuration conf) A helper function to create an options object.Constructors in org.apache.hadoop.crypto.key with parameters of type ConfigurationModifierConstructorDescriptionKeyProvider(Configuration conf) Constructor.Options(Configuration conf) -
Uses of Configuration in org.apache.hadoop.crypto.key.kms
Methods in org.apache.hadoop.crypto.key.kms with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidKMSClientProvider.KMSTokenRenewer.cancel(Token<?> token, Configuration conf) KMSClientProvider.Factory.createProvider(URI providerUri, Configuration conf) This provider expects URIs in the following form : kms://<PROTO>@<AUTHORITY>/<PATH> where : - PROTO = http or https - AUTHORITY = <HOSTS>[:<PORT>] - HOSTS = <HOSTNAME>[;<HOSTS>] - HOSTNAME = string - PORT = integer This will always create aLoadBalancingKMSClientProviderif the uri is correct.longKMSClientProvider.KMSTokenRenewer.renew(Token<?> token, Configuration conf) Constructors in org.apache.hadoop.crypto.key.kms with parameters of type ConfigurationModifierConstructorDescriptionKMSClientProvider(URI uri, Configuration conf) LoadBalancingKMSClientProvider(URI providerUri, KMSClientProvider[] providers, Configuration conf) -
Uses of Configuration in org.apache.hadoop.crypto.random
Methods in org.apache.hadoop.crypto.random that return ConfigurationMethods in org.apache.hadoop.crypto.random with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.fs
Methods in org.apache.hadoop.fs that return ConfigurationModifier and TypeMethodDescriptionFilterFileSystem.getConf()GetSpaceUsed.Builder.getConf()HarFileSystem.getConf()Methods in org.apache.hadoop.fs with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic booleanFileUtil.copy(File src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf) Copy local files to a FileSystem.static booleanFileUtil.copy(FileSystem srcFS, FileStatus srcStatus, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) Copy a file/directory tree within/between filesystems.static booleanFileUtil.copy(FileSystem srcFS, Path[] srcs, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) static booleanFileUtil.copy(FileSystem srcFS, Path src, File dst, boolean deleteSource, Configuration conf) Copy FileSystem files to local files.static booleanFileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, boolean overwrite, Configuration conf) Copy files between FileSystems.static booleanFileUtil.copy(FileSystem srcFS, Path src, FileSystem dstFS, Path dst, boolean deleteSource, Configuration conf) Copy files between FileSystems.static AbstractFileSystemAbstractFileSystem.createFileSystem(URI uri, Configuration conf) Create a file system instance for the specified uri using the conf.LocalDirAllocator.createTmpFileForWrite(String pathStr, long size, Configuration conf) Creates a temporary file in the local FS.static AbstractFileSystemAbstractFileSystem.get(URI uri, Configuration conf) The main factory method for creating a file system.static FileSystemFileSystem.get(URI uri, Configuration conf) Get a FileSystem for this URI's scheme and authority.static FileSystemFileSystem.get(URI uri, Configuration conf, String user) Get a FileSystem instance based on the uri, the passed in configuration and the user.static FileSystemFileSystem.get(Configuration conf) Returns the configured FileSystem implementation.static org.apache.hadoop.tracing.TracerFsTracer.get(Configuration conf) LocalDirAllocator.getAllLocalPathsToRead(String pathStr, Configuration conf) Get all of the paths that currently exist in the working directories.static StringStorageType.getConf(Configuration conf, StorageType t, String name) Get the configured values for different StorageType.static URIFileSystem.getDefaultUri(Configuration conf) Get the default FileSystem URI from a configuration.static FileContextFileContext.getFileContext(URI defaultFsUri, Configuration aConf) Create a FileContext for specified default URI using the specified config.static FileContextFileContext.getFileContext(Configuration aConf) Create a FileContext using the passed config.static FileContextFileContext.getFileContext(AbstractFileSystem defFS, Configuration aConf) Create a FileContext with specified FS as default using the specified config.Path.getFileSystem(Configuration conf) Return the FileSystem that owns this Path.static Class<? extends FileSystem>FileSystem.getFileSystemClass(String scheme, Configuration conf) Get the FileSystem implementation class of a filesystem.protected static FileSystemFileSystem.getFSofPath(Path absOrFqPath, Configuration conf) static TrashPolicyTrashPolicy.getInstance(Configuration conf, FileSystem fs) Get an instance of the configured TrashPolicy based on the value of the configuration parameter fs.trash.classname.static TrashPolicyTrashPolicy.getInstance(Configuration conf, FileSystem fs, Path home) Deprecated.static LocalFileSystemFileSystem.getLocal(Configuration conf) Get the local FileSystem.static FileContextFileContext.getLocalFSFileContext(Configuration aConf) LocalDirAllocator.getLocalPathForWrite(String pathStr, long size, Configuration conf) Get a path from the local FS.LocalDirAllocator.getLocalPathForWrite(String pathStr, long size, Configuration conf, boolean checkWrite) Get a path from the local FS.LocalDirAllocator.getLocalPathForWrite(String pathStr, Configuration conf) Get a path from the local FS.LocalDirAllocator.getLocalPathToRead(String pathStr, Configuration conf) Get a path from the local FS for reading.static FileSystemFileSystem.getNamed(String name, Configuration conf) Deprecated.callFileSystem.get(URI, Configuration)instead.booleanLocalDirAllocator.ifExists(String pathStr, Configuration conf) We search through all the configured dirs for the file's existence and return true when we find.voidFileSystem.initialize(URI name, Configuration conf) Initialize a FileSystem.voidFilterFileSystem.initialize(URI name, Configuration conf) Called after a new FileSystem instance is constructed.voidHarFileSystem.initialize(URI name, Configuration conf) Initialize a Har filesystem per har archive.voidLocalFileSystem.initialize(URI name, Configuration conf) voidRawLocalFileSystem.initialize(URI uri, Configuration conf) voidTrashPolicy.initialize(Configuration conf, FileSystem fs) Used to setup the trash policy.abstract voidTrashPolicy.initialize(Configuration conf, FileSystem fs, Path home) Deprecated.UseTrashPolicy.initialize(Configuration, FileSystem)instead.voidTrashPolicyDefault.initialize(Configuration conf, FileSystem fs) voidTrashPolicyDefault.initialize(Configuration conf, FileSystem fs, Path home) Deprecated.static booleanTrash.moveToAppropriateTrash(FileSystem fs, Path p, Configuration conf) In case of the symlinks or mount points, one has to move the appropriate trashbin in the actual volume of the path p being deleted.static FileSystemFileSystem.newInstance(URI uri, Configuration config) Returns the FileSystem for this URI's scheme and authority.static FileSystemFileSystem.newInstance(URI uri, Configuration conf, String user) Returns the FileSystem for this URI's scheme and authority and the given user.static FileSystemFileSystem.newInstance(Configuration conf) Returns a unique configured FileSystem implementation for the default filesystem of the supplied configuration.static LocalFileSystemFileSystem.newInstanceLocal(Configuration conf) Get a unique local FileSystem object.voidChecksumFileSystem.setConf(Configuration conf) GetSpaceUsed.Builder.setConf(Configuration conf) static voidFileSystem.setDefaultUri(Configuration conf, String uri) Set the default FileSystem URI in a configuration.static voidFileSystem.setDefaultUri(Configuration conf, URI uri) Set the default FileSystem URI in a configuration.Constructors in org.apache.hadoop.fs with parameters of type ConfigurationModifierConstructorDescriptionprotectedDelegateToFileSystem(URI theUri, FileSystem theFsImpl, Configuration conf, String supportedScheme, boolean authorityRequired) DF(File path, Configuration conf) FsShell(Configuration conf) Construct a FsShell with the given configuration.Trash(Configuration conf) Construct a trash can accessor.Trash(FileSystem fs, Configuration conf) Construct a trash can accessor for the FileSystem provided. -
Uses of Configuration in org.apache.hadoop.fs.ftp
Methods in org.apache.hadoop.fs.ftp with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.fs.impl
Methods in org.apache.hadoop.fs.impl that return ConfigurationModifier and TypeMethodDescriptionAbstractFSBuilderImpl.getOptions()Get the mutable option configuration.FSBuilderSupport.getOptions()OpenFileParameters.getOptions()Methods in org.apache.hadoop.fs.impl with parameters of type ConfigurationModifier and TypeMethodDescriptionFlagSet.buildFlagSet(Class<E> enumClass, Configuration conf, String key, boolean ignoreUnknown) Build a FlagSet from a comma separated list of values.static voidFutureIOSupport.propagateOptions(FSBuilder<?, ?> builder, Configuration conf, String prefix, boolean mandatory) Deprecated.FutureIOSupport.propagateOptions(FSBuilder<T, U> builder, Configuration conf, String optionalPrefix, String mandatoryPrefix) Deprecated.OpenFileParameters.withOptions(Configuration opts) Constructors in org.apache.hadoop.fs.impl with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.fs.impl.prefetch
Methods in org.apache.hadoop.fs.impl.prefetch that return ConfigurationMethods in org.apache.hadoop.fs.impl.prefetch with parameters of type ConfigurationModifier and TypeMethodDescriptionprotected PathSingleFilePerBlockCache.getCacheFilePath(Configuration conf, LocalDirAllocator localDirAllocator) Return temporary file created based on the file path retrieved from local dir allocator.static booleanSingleFilePerBlockCache.isCacheSpaceAvailable(long fileSize, Configuration conf, LocalDirAllocator localDirAllocator) Determine if the cache space is available on the local FS.voidBlockCache.put(int blockNumber, ByteBuffer buffer, Configuration conf, LocalDirAllocator localDirAllocator) Puts the given block in this cache.voidSingleFilePerBlockCache.put(int blockNumber, ByteBuffer buffer, Configuration conf, LocalDirAllocator localDirAllocator) Puts the given block in this cache.BlockManagerParameters.withConf(Configuration configuration) Sets the configuration object. -
Uses of Configuration in org.apache.hadoop.fs.permission
Methods in org.apache.hadoop.fs.permission with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic FsPermissionFsPermission.getUMask(Configuration conf) Get the user file creation mask (umask)UMASK_LABELconfig param has umask value that is either symbolic or octal.static voidFsPermission.setUMask(Configuration conf, FsPermission umask) Set the user file creation mask (umask) -
Uses of Configuration in org.apache.hadoop.fs.sftp
Methods in org.apache.hadoop.fs.sftp with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidSFTPFileSystem.initialize(URI uriInfo, Configuration conf) -
Uses of Configuration in org.apache.hadoop.fs.shell
Methods in org.apache.hadoop.fs.shell with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic PathData[]PathData.expandAsGlob(String pattern, Configuration conf) Expand the given path as a glob pattern.CommandFactory.getInstance(String cmdName, Configuration conf) Get an instance of the requested commandConstructors in org.apache.hadoop.fs.shell with parameters of type ConfigurationModifierConstructorDescriptionprotectedCommand(Configuration conf) Constructor.CommandFactory(Configuration conf) Factory constructor for commandsCount(String[] cmd, int pos, Configuration conf) Deprecated.invoke viaFsShellprotectedFsCommand(Configuration conf) PathData(String pathString, Configuration conf) Creates an object to wrap the given parameters as fields.PathData(URI localPath, Configuration conf) Creates an object to wrap the given parameters as fields. -
Uses of Configuration in org.apache.hadoop.fs.shell.find
Methods in org.apache.hadoop.fs.shell.find that return ConfigurationModifier and TypeMethodDescriptionBaseExpression.getConf()FilterExpression.getConf()FindOptions.getConfiguration()Return theConfigurationreturn configurationConfigurationMethods in org.apache.hadoop.fs.shell.find with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidBaseExpression.setConf(Configuration conf) voidFilterExpression.setConf(Configuration conf) voidFindOptions.setConfiguration(Configuration configuration) Set theConfiguration -
Uses of Configuration in org.apache.hadoop.fs.store
Methods in org.apache.hadoop.fs.store that return ConfigurationModifier and TypeMethodDescriptionprotected ConfigurationDataBlocks.BlockFactory.getConf()Configuration.Methods in org.apache.hadoop.fs.store with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic DataBlocks.BlockFactoryDataBlocks.createFactory(String keyToBufferDir, Configuration configuration, String name) Create a factory.Constructors in org.apache.hadoop.fs.store with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.fs.viewfs
Methods in org.apache.hadoop.fs.viewfs with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic voidConfigUtil.addLink(Configuration conf, String mountTableName, String src, URI target) Add a link to the config for the specified mount tablestatic voidConfigUtil.addLink(Configuration conf, String src, URI target) Add a link to the config for the default mount tablestatic voidConfigUtil.addLinkFallback(Configuration conf, String mountTableName, URI target) Add a LinkFallback to the config for the specified mount table.static voidConfigUtil.addLinkFallback(Configuration conf, URI target) Add a LinkFallback to the config for the default mount table.static voidConfigUtil.addLinkMerge(Configuration conf, String mountTableName, URI[] targets) Add a LinkMerge to the config for the specified mount table.static voidConfigUtil.addLinkMerge(Configuration conf, URI[] targets) Add a LinkMerge to the config for the default mount table.static voidConfigUtil.addLinkMergeSlash(Configuration conf, String mountTableName, URI target) Add a LinkMergeSlash to the config for the specified mount table.static voidConfigUtil.addLinkMergeSlash(Configuration conf, URI target) Add a LinkMergeSlash to the config for the default mount table.static voidConfigUtil.addLinkNfly(Configuration conf, String mountTableName, String src, String settings, String targets) Add nfly link to configuration for the given mount table.static voidConfigUtil.addLinkNfly(Configuration conf, String mountTableName, String src, String settings, URI... targets) Add nfly link to configuration for the given mount table.static voidConfigUtil.addLinkNfly(Configuration conf, String src, URI... targets) static voidConfigUtil.addLinkRegex(Configuration conf, String mountTableName, String srcRegex, String targetStr, String interceptorSettings) Add a LinkRegex to the config for the specified mount table.FsGetter.get(URI uri, Configuration conf) Gets file system instance of given uri.static StringConfigUtil.getDefaultMountTableName(Configuration conf) Get the name of the default mount table to use.static StringConfigUtil.getHomeDirValue(Configuration conf) Get the value of the home dir conf value for default mount tablestatic StringConfigUtil.getHomeDirValue(Configuration conf, String mountTableName) Get the value of the home dir conf value for specified mount tableViewFileSystemOverloadScheme.getMountPathInfo(Path path, Configuration conf) Gets the mount path info, which contains the target file system and remaining path to pass to the target file system.FsGetter.getNewInstance(URI uri, Configuration conf) Gets new file system instance of given uri.ViewFileSystemOverloadScheme.getRawFileSystem(Path path, Configuration conf) This is an admin only API to give access to its child raw file system, if the path is link.voidViewFileSystem.initialize(URI theUri, Configuration conf) Called after a new FileSystem instance is constructed.voidViewFileSystemOverloadScheme.initialize(URI theUri, Configuration conf) static booleanConfigUtil.isNestedMountPointSupported(Configuration conf) Check the bool config whether nested mount point is supported.voidHCFSMountTableConfigLoader.load(String mountTableConfigPath, Configuration conf) Loads the mount-table configuration from hadoop compatible file system and add the configuration items to given configuration.voidMountTableConfigLoader.load(String mountTableConfigPath, Configuration conf) Loads the mount-table configuration into given configuration.static voidConfigUtil.setHomeDirConf(Configuration conf, String homedir) Add config variable for homedir for default mount tablestatic voidConfigUtil.setHomeDirConf(Configuration conf, String mountTableName, String homedir) Add config variable for homedir the specified mount tablestatic voidConfigUtil.setIsNestedMountPointSupported(Configuration conf, boolean isNestedMountPointSupported) Set the bool value isNestedMountPointSupported in config.Constructors in org.apache.hadoop.fs.viewfs with parameters of type ConfigurationModifierConstructorDescriptionprotectedInodeTree(Configuration config, String viewName, URI theUri, boolean initingUriAsFallbackOnNoMounts) Create Inode Tree from the specified mount-table specified in Config.ViewFileSystem(Configuration conf) Convenience Constructor for apps to call directly.ViewFs(Configuration conf) -
Uses of Configuration in org.apache.hadoop.ha
Fields in org.apache.hadoop.ha declared as ConfigurationMethods in org.apache.hadoop.ha with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic NodeFencerNodeFencer.create(Configuration conf, String confKey) HAServiceTarget.getHealthMonitorProxy(Configuration conf, int timeoutMs) Returns a proxy to connect to the target HA service for health monitoring.HAServiceTarget.getHealthMonitorProxy(Configuration conf, int timeoutMs, int retries) HAServiceTarget.getProxy(Configuration conf, int timeoutMs) HAServiceTarget.getZKFCProxy(Configuration conf, int timeoutMs) voidHAAdmin.setConf(Configuration conf) Constructors in org.apache.hadoop.ha with parameters of type ConfigurationModifierConstructorDescriptionFailoverController(Configuration conf, HAServiceProtocol.RequestSource source) protectedHAAdmin(Configuration conf) protectedZKFailoverController(Configuration conf, HAServiceTarget localTarget) -
Uses of Configuration in org.apache.hadoop.ha.protocolPB
Constructors in org.apache.hadoop.ha.protocolPB with parameters of type ConfigurationModifierConstructorDescriptionHAServiceProtocolClientSideTranslatorPB(InetSocketAddress addr, Configuration conf, SocketFactory socketFactory, int timeout) ZKFCProtocolClientSideTranslatorPB(InetSocketAddress addr, Configuration conf, SocketFactory socketFactory, int timeout) -
Uses of Configuration in org.apache.hadoop.http
Methods in org.apache.hadoop.http with parameters of type ConfigurationModifier and TypeMethodDescriptionprotected voidHttpServer2.addDefaultApps(org.eclipse.jetty.server.handler.ContextHandlerCollection parent, String appDir, Configuration conf) Add default apps.protected voidHttpServer2.addDefaultServlets(Configuration configuration) Add default servlets.static PropertiesHttpServer2.getFilterProperties(Configuration conf, List<String> prefixes) abstract voidFilterInitializer.initFilter(FilterContainer container, Configuration conf) Initialize a Filter to a FilterContainer.HttpServer2.Builder.setConf(Configuration conf) HttpServer2.Builder.setSSLConf(Configuration sslCnf) Specify the SSL configuration to load. -
Uses of Configuration in org.apache.hadoop.http.lib
Methods in org.apache.hadoop.http.lib with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidStaticUserWebFilter.initFilter(FilterContainer container, Configuration conf) -
Uses of Configuration in org.apache.hadoop.io
Methods in org.apache.hadoop.io that return ConfigurationModifier and TypeMethodDescriptionAbstractMapWritable.getConf()EnumSetWritable.getConf()GenericWritable.getConf()ObjectWritable.getConf()WritableComparator.getConf()Methods in org.apache.hadoop.io with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic <T extends Writable>
TWritableUtils.clone(T orig, Configuration conf) Make a copy of a writable object using serialization to a buffer.static voidIOUtils.copyBytes(InputStream in, OutputStream out, Configuration conf) Copies from one stream to another.static voidIOUtils.copyBytes(InputStream in, OutputStream out, Configuration conf, boolean close) Copies from one stream to another.protected SequenceFile.ReaderMapFile.Reader.createDataFileReader(Path dataFile, Configuration conf, SequenceFile.Reader.Option... options) Override this method to specialize the type ofSequenceFile.Readerreturned.static SequenceFile.WriterSequenceFile.createWriter(Configuration conf, FSDataOutputStream out, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(Configuration conf, FSDataOutputStream out, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(Configuration conf, SequenceFile.Writer.Option... opts) Create a new Writer with the given options.static SequenceFile.WriterSequenceFile.createWriter(FileContext fc, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, SequenceFile.Metadata metadata, EnumSet<CreateFlag> createFlag, Options.CreateOpts... opts) Construct the preferred type of SequenceFile Writer.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, boolean createParent, SequenceFile.CompressionType compressionType, CompressionCodec codec, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, CompressionCodec codec, Progressable progress, SequenceFile.Metadata metadata) Deprecated.static SequenceFile.WriterSequenceFile.createWriter(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, SequenceFile.CompressionType compressionType, Progressable progress) Deprecated.static longMapFile.fix(FileSystem fs, Path dir, Class<? extends Writable> keyClass, Class<? extends Writable> valueClass, boolean dryrun, Configuration conf) This method attempts to fix a corrupt MapFile by re-creating its index.static WritableComparatorWritableComparator.get(Class<? extends WritableComparable> c, Configuration conf) Get a comparator for aWritableComparableimplementation.static Class<?>WritableName.getClass(String name, Configuration conf) Return the class for a name.static SequenceFile.CompressionTypeSequenceFile.getDefaultCompressionType(Configuration job) Get the compression type for the reduce outputsstatic <K> KDefaultStringifier.load(Configuration conf, String keyName, Class<K> itemClass) Restores the object from the configuration.static <K> K[]DefaultStringifier.loadArray(Configuration conf, String keyName, Class<K> itemClass) Restores the array of objects from the configuration.static Class<?>ObjectWritable.loadClass(Configuration conf, String className) Find and load the class with given nameclassNameby first finding it in the specifiedconf.static WritableWritableFactories.newInstance(Class<? extends Writable> c, Configuration conf) Create a new instance of a class with a defined factory.protected voidMapFile.Reader.open(Path dir, WritableComparator comparator, Configuration conf, SequenceFile.Reader.Option... options) static ObjectObjectWritable.readObject(DataInput in, Configuration conf) static ObjectObjectWritable.readObject(DataInput in, ObjectWritable objectWritable, Configuration conf) voidAbstractMapWritable.setConf(Configuration conf) voidEnumSetWritable.setConf(Configuration conf) voidGenericWritable.setConf(Configuration conf) voidObjectWritable.setConf(Configuration conf) voidWritableComparator.setConf(Configuration conf) static voidSequenceFile.setDefaultCompressionType(Configuration job, SequenceFile.CompressionType val) Set the default compression type for sequence files.static voidMapFile.Writer.setIndexInterval(Configuration conf, int interval) Sets the index interval and stores it in conf.static <K> voidDefaultStringifier.store(Configuration conf, K item, String keyName) Stores the item in the configuration with the given keyName.static <K> voidDefaultStringifier.storeArray(Configuration conf, K[] items, String keyName) Stores the array of items in the configuration with the given keyName.static voidObjectWritable.writeObject(DataOutput out, Object instance, Class declaredClass, Configuration conf) static voidObjectWritable.writeObject(DataOutput out, Object instance, Class declaredClass, Configuration conf, boolean allowCompactArrays) Constructors in org.apache.hadoop.io with parameters of type ConfigurationModifierConstructorDescriptionDefaultStringifier(Configuration conf, Class<T> c) Merger(Configuration conf) Reader(FileSystem fs, String file, Configuration conf) Construct an array reader for the named file.Reader(FileSystem fs, String dirName, Configuration conf) Deprecated.Reader(FileSystem fs, String dirName, WritableComparator comparator, Configuration conf) Deprecated.Reader(FileSystem fs, String dirName, WritableComparator comparator, Configuration conf, boolean open) Deprecated.Reader(Path dir, Configuration conf, SequenceFile.Reader.Option... options) Reader(FileSystem fs, String dirName, Configuration conf) Deprecated.Reader(FileSystem fs, String dirName, WritableComparator comparator, Configuration conf) Deprecated.Reader(Path dir, Configuration conf, SequenceFile.Reader.Option... opts) Reader(Configuration conf, SequenceFile.Reader.Option... opts) Reader(FileSystem fs, Path file, Configuration conf) Deprecated.Use Reader(Configuration, Option...) instead.Reader(FSDataInputStream in, int buffersize, long start, long length, Configuration conf) Deprecated.Use Reader(Configuration, Reader.Option...) instead.Reader(FileSystem fs, String dirName, Configuration conf) Construct a set reader for the named set.Reader(FileSystem fs, String dirName, WritableComparator comparator, Configuration conf) Construct a set reader for the named set using the named comparator.Sorter(FileSystem fs, Class<? extends WritableComparable> keyClass, Class valClass, Configuration conf) Sort and merge files containing the named classes.Sorter(FileSystem fs, RawComparator comparator, Class keyClass, Class valClass, Configuration conf) Sort and merge using an arbitraryRawComparator.Sorter(FileSystem fs, RawComparator comparator, Class keyClass, Class valClass, Configuration conf, SequenceFile.Metadata metadata) Sort and merge using an arbitraryRawComparator.protectedWritableComparator(Class<? extends WritableComparable> keyClass, Configuration conf, boolean createInstances) Writer(Configuration conf, FileSystem fs, String file, Class<? extends Writable> valClass) Create the named file for values of the named class.Writer(Configuration conf, FileSystem fs, String file, Class<? extends Writable> valClass, SequenceFile.CompressionType compress, Progressable progress) Create the named file for values of the named class.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class<? extends Writable> valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Writer(Configuration conf, Path dir, SequenceFile.Writer.Option... options) Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, CompressionCodec codec, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...) instead.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, Class valClass, SequenceFile.CompressionType compress, Progressable progress) Deprecated.Use Writer(Configuration, Path, Option...)} instead.Writer(Configuration conf, Path dirName, SequenceFile.Writer.Option... opts) Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass) Deprecated.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, int bufferSize, short replication, long blockSize, Progressable progress, SequenceFile.Metadata metadata) Deprecated.Writer(FileSystem fs, Configuration conf, Path name, Class keyClass, Class valClass, Progressable progress, SequenceFile.Metadata metadata) Deprecated.Writer(Configuration conf, FileSystem fs, String dirName, Class<? extends WritableComparable> keyClass, SequenceFile.CompressionType compress) Create a set naming the element class and compression type.Writer(Configuration conf, FileSystem fs, String dirName, WritableComparator comparator, SequenceFile.CompressionType compress) Create a set naming the element comparator and compression type. -
Uses of Configuration in org.apache.hadoop.io.compress
Methods in org.apache.hadoop.io.compress that return ConfigurationModifier and TypeMethodDescriptionBZip2Codec.getConf()Return the configuration used by this object.DefaultCodec.getConf()Lz4Codec.getConf()Return the configuration used by this object.PassthroughCodec.getConf()SnappyCodec.getConf()Return the configuration used by this object.ZStandardCodec.getConf()Return the configuration used by this object.Methods in org.apache.hadoop.io.compress with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic List<Class<? extends CompressionCodec>>CompressionCodecFactory.getCodecClasses(Configuration conf) Get the list of codecs discovered via a Java ServiceLoader, or listed in the configuration.static intZStandardCodec.getCompressionBufferSize(Configuration conf) static intZStandardCodec.getCompressionLevel(Configuration conf) static CompressorCodecPool.getCompressor(CompressionCodec codec, Configuration conf) Get aCompressorfor the givenCompressionCodecfrom the pool or a new one.static intZStandardCodec.getDecompressionBufferSize(Configuration conf) voidCompressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configurationstatic voidCompressionCodecFactory.setCodecClasses(Configuration conf, List<Class> classes) Sets a list of codec classes in the configuration.voidBZip2Codec.setConf(Configuration conf) Set the configuration to be used by this object.voidDefaultCodec.setConf(Configuration conf) voidLz4Codec.setConf(Configuration conf) Set the configuration to be used by this object.voidPassthroughCodec.setConf(Configuration conf) voidSnappyCodec.setConf(Configuration conf) Set the configuration to be used by this object.voidZStandardCodec.setConf(Configuration conf) Set the configuration to be used by this object.Constructors in org.apache.hadoop.io.compress with parameters of type ConfigurationModifierConstructorDescriptionFind the codecs specified in the config value io.compression.codecs and register them. -
Uses of Configuration in org.apache.hadoop.io.compress.bzip2
Methods in org.apache.hadoop.io.compress.bzip2 with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic intBzip2Factory.getBlockSize(Configuration conf) static CompressorBzip2Factory.getBzip2Compressor(Configuration conf) Return the appropriate implementation of the bzip2 compressor.static Class<? extends Compressor>Bzip2Factory.getBzip2CompressorType(Configuration conf) Return the appropriate type of the bzip2 compressor.static DecompressorBzip2Factory.getBzip2Decompressor(Configuration conf) Return the appropriate implementation of the bzip2 decompressor.static Class<? extends Decompressor>Bzip2Factory.getBzip2DecompressorType(Configuration conf) Return the appropriate type of the bzip2 decompressor.static StringBzip2Factory.getLibraryName(Configuration conf) static intBzip2Factory.getWorkFactor(Configuration conf) static booleanBzip2Factory.isNativeBzip2Loaded(Configuration conf) Check if native-bzip2 code is loaded & initialized correctly and can be loaded for this job.voidBzip2Compressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configuration.voidBZip2DummyCompressor.reinit(Configuration conf) static voidBzip2Factory.setBlockSize(Configuration conf, int blockSize) static voidBzip2Factory.setWorkFactor(Configuration conf, int workFactor) Constructors in org.apache.hadoop.io.compress.bzip2 with parameters of type ConfigurationModifierConstructorDescriptionBzip2Compressor(Configuration conf) Creates a new compressor, taking settings from the configuration. -
Uses of Configuration in org.apache.hadoop.io.compress.lz4
Methods in org.apache.hadoop.io.compress.lz4 with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidLz4Compressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configuration -
Uses of Configuration in org.apache.hadoop.io.compress.snappy
Methods in org.apache.hadoop.io.compress.snappy with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidSnappyCompressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configuration -
Uses of Configuration in org.apache.hadoop.io.compress.zlib
Methods in org.apache.hadoop.io.compress.zlib with parameters of type ConfigurationModifier and TypeMethodDescriptionZlibFactory.getCompressionLevel(Configuration conf) ZlibFactory.getCompressionStrategy(Configuration conf) static CompressorZlibFactory.getZlibCompressor(Configuration conf) Return the appropriate implementation of the zlib compressor.static Class<? extends Compressor>ZlibFactory.getZlibCompressorType(Configuration conf) Return the appropriate type of the zlib compressor.static DecompressorZlibFactory.getZlibDecompressor(Configuration conf) Return the appropriate implementation of the zlib decompressor.static Class<? extends Decompressor>ZlibFactory.getZlibDecompressorType(Configuration conf) Return the appropriate type of the zlib decompressor.static DirectDecompressorZlibFactory.getZlibDirectDecompressor(Configuration conf) Return the appropriate implementation of the zlib direct decompressor.static booleanZlibFactory.isNativeZlibLoaded(Configuration conf) Check if native-zlib code is loaded & initialized correctly and can be loaded for this job.voidBuiltInGzipCompressor.reinit(Configuration conf) voidBuiltInZlibDeflater.reinit(Configuration conf) reinit the compressor with the given configuration.voidZlibCompressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configuration.static voidZlibFactory.setCompressionLevel(Configuration conf, ZlibCompressor.CompressionLevel level) static voidZlibFactory.setCompressionStrategy(Configuration conf, ZlibCompressor.CompressionStrategy strategy) Constructors in org.apache.hadoop.io.compress.zlib with parameters of type ConfigurationModifierConstructorDescriptionZlibCompressor(Configuration conf) Creates a new compressor, taking settings from the configuration. -
Uses of Configuration in org.apache.hadoop.io.compress.zstd
Methods in org.apache.hadoop.io.compress.zstd with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidZStandardCompressor.reinit(Configuration conf) Prepare the compressor to be used in a new stream with settings defined in the given Configuration. -
Uses of Configuration in org.apache.hadoop.io.erasurecode
Methods in org.apache.hadoop.io.erasurecode with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic ErasureDecoderCodecUtil.createDecoder(Configuration conf, ErasureCodecOptions options) Create decoder corresponding to given codec.static ErasureEncoderCodecUtil.createEncoder(Configuration conf, ErasureCodecOptions options) Create encoder corresponding to given codec.static RawErasureDecoderCodecUtil.createRawDecoder(Configuration conf, String codec, ErasureCoderOptions coderOptions) Create RS raw decoder according to configuration.static RawErasureEncoderCodecUtil.createRawEncoder(Configuration conf, String codec, ErasureCoderOptions coderOptions) Create RS raw encoder according to configuration. -
Uses of Configuration in org.apache.hadoop.io.erasurecode.codec
Constructors in org.apache.hadoop.io.erasurecode.codec with parameters of type ConfigurationModifierConstructorDescriptionDummyErasureCodec(Configuration conf, ErasureCodecOptions options) ErasureCodec(Configuration conf, ErasureCodecOptions options) HHXORErasureCodec(Configuration conf, ErasureCodecOptions options) RSErasureCodec(Configuration conf, ErasureCodecOptions options) XORErasureCodec(Configuration conf, ErasureCodecOptions options) -
Uses of Configuration in org.apache.hadoop.io.file.tfile
Fields in org.apache.hadoop.io.file.tfile declared as ConfigurationConstructors in org.apache.hadoop.io.file.tfile with parameters of type ConfigurationModifierConstructorDescriptionReader(FSDataInputStream fsdis, long fileLength, Configuration conf) ConstructorWriter(FSDataOutputStream fsdos, int minBlockSize, String compressName, String comparator, Configuration conf) Constructor -
Uses of Configuration in org.apache.hadoop.io.retry
Methods in org.apache.hadoop.io.retry with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic RetryPolicyRetryUtils.getDefaultRetryPolicy(Configuration conf, String retryPolicyEnabledKey, boolean defaultRetryPolicyEnabled, String retryPolicySpecKey, String defaultRetryPolicySpec, String remoteExceptionToRetry) Return the default retry policy set in conf.static RetryPolicyRetryUtils.getMultipleLinearRandomRetry(Configuration conf, String retryPolicyEnabledKey, boolean defaultRetryPolicyEnabled, String retryPolicySpecKey, String defaultRetryPolicySpec) Return the MultipleLinearRandomRetry policy specified in the conf, or null if the feature is disabled. -
Uses of Configuration in org.apache.hadoop.io.serializer
Constructors in org.apache.hadoop.io.serializer with parameters of type ConfigurationModifierConstructorDescriptionSerializations are found by reading theio.serializationsproperty fromconf, which is a comma-delimited list of classnames. -
Uses of Configuration in org.apache.hadoop.ipc
Methods in org.apache.hadoop.ipc that return ConfigurationMethods in org.apache.hadoop.ipc with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic voidServer.bind(ServerSocket socket, InetSocketAddress address, int backlog, Configuration conf, String rangeConf) ClientCache.getClient(Configuration conf) Construct & cache an IPC client with the default SocketFactory and default valueClass if no cached client exists.ClientCache.getClient(Configuration conf, SocketFactory factory) Construct & cache an IPC client with the user-provided SocketFactory if no cached client exists.ClientCache.getClient(Configuration conf, SocketFactory factory, Class<? extends Writable> valueClass) Construct & cache an IPC client with the user-provided SocketFactory if no cached client exists.static final intClient.getPingInterval(Configuration conf) Get the ping interval from configuration; If not set in the configuration, return the default value.ProtobufRpcEngine.getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) Deprecated.ProtobufRpcEngine2.getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) RpcEngine.getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) Returns a proxy for ProtocolMetaInfoPB, which uses the given connection id.WritableRpcEngine.getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) Deprecated.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the serverstatic <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the serverstatic <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout) <T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) <T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) <T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) static <T> TRPC.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) Construct a client-side proxy object with the default SocketFactory.static <T> TRPC.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.static <T> TRPC.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory) Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.static <T> TRPC.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout) Construct a client-side proxy that implements the named protocol, talking to a server at the named address.<T> ProtocolProxy<T>RpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) Construct a client-side proxy object.<T> ProtocolProxy<T>RpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Construct a client-side proxy object.<T> ProtocolProxy<T>RpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Construct a client-side proxy object with a ConnectionId.<T> ProtocolProxy<T>WritableRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) Deprecated.Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.<T> ProtocolProxy<T>WritableRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Deprecated.Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.<T> ProtocolProxy<T>WritableRpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Deprecated.Construct a client-side proxy object with a ConnectionId.static final intClient.getRpcTimeout(Configuration conf) The time after which a RPC will timeout.static intRPC.getRpcTimeout(Configuration conf) Get the RPC time from configuration; If not set in the configuration, return the default value.ProtobufRpcEngine.getServer(Class<?> protocol, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.ProtobufRpcEngine2.getServer(Class<?> protocol, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) RpcEngine.getServer(Class<?> protocol, Object instance, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct a server for a protocol implementation instance.WritableRpcEngine.getServer(Class<?> protocolClass, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.static final intClient.getTimeout(Configuration conf) Deprecated.useClient.getRpcTimeout(Configuration)insteadvoidCostProvider.init(String namespace, Configuration conf) Initialize this provider using the given configuration, examining only ones which fall within the provided namespace.voidDefaultCostProvider.init(String namespace, Configuration conf) voidWeightedTimeCostProvider.init(String namespace, Configuration conf) <T> TRpcWritable.Buffer.newInstance(Class<T> valueClass, Configuration conf) voidServer.refreshCallQueue(Configuration conf) voidServer.refreshServiceAcl(Configuration conf, PolicyProvider provider) Refresh the service authorization ACL for the service handled by this server.voidServer.refreshServiceAclWithLoadedConfiguration(Configuration conf, PolicyProvider provider) Refresh the service authorization ACL for the service handled by this server using the specified Configuration.static final voidClient.setConnectTimeout(Configuration conf, int timeout) set the connection timeout value in configurationstatic final voidClient.setPingInterval(Configuration conf, int pingInterval) set the ping interval value in configurationstatic voidRPC.setProtocolEngine(Configuration conf, Class<?> protocol, Class<?> engine) Set a protocol to use a non-default RpcEngine if one is not specified in the configuration.voidCallQueueManager.swapQueue(Class<? extends RpcScheduler> schedulerClass, Class<? extends BlockingQueue<E>> queueClassToUse, int maxSize, String ns, Configuration conf) Replaces active queue with the newly requested one and transfers all calls to the newQ before returning.static <T> ProtocolProxy<T>RPC.waitForProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.waitForProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, int rpcTimeout, RetryPolicy connectionRetryPolicy, long timeout) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.waitForProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, long connTimeout) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the serverstatic <T> TRPC.waitForProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) Get a proxy connection to a remote server.static <T> TRPC.waitForProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, int rpcTimeout, long timeout) Get a proxy connection to a remote server.static <T> TRPC.waitForProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, long connTimeout) Get a proxy connection to a remote server.Constructors in org.apache.hadoop.ipc with parameters of type ConfigurationModifierConstructorDescriptionBuilder(String context, Configuration conf) Builder(Configuration conf) CallQueueManager(Class<? extends BlockingQueue<E>> backingClass, Class<? extends RpcScheduler> schedulerClass, boolean clientBackOffEnabled, int maxQueueSize, String namespace, Configuration conf) Client(Class<? extends Writable> valueClass, Configuration conf) Construct an IPC client with the default SocketFactory.Client(Class<? extends Writable> valueClass, Configuration conf, SocketFactory factory) Construct an IPC client whose values are of the givenWritableclass.ConnectionId(InetSocketAddress address, Class<?> protocol, UserGroupInformation ticket, int rpcTimeout, RetryPolicy connectionRetryPolicy, Configuration conf) DecayRpcScheduler(int numLevels, String ns, Configuration conf) Create a decay scheduler.DefaultRpcScheduler(int priorityLevels, String namespace, Configuration conf) FairCallQueue(int priorityLevels, int capacity, String ns, boolean serverFailOverEnabled, Configuration conf) FairCallQueue(int priorityLevels, int capacity, String ns, int[] capacityWeights, boolean serverFailOverEnabled, Configuration conf) Create a FairCallQueue.FairCallQueue(int priorityLevels, int capacity, String ns, Configuration conf) protectedInvoker(Class<?> protocol, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) protectedInvoker(Class<?> protocol, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) This constructor takes a connectionId, instead of creating a new one.protectedInvoker(Class<?> protocol, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) protectedInvoker(Class<?> protocol, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) This constructor takes a connectionId, instead of creating a new one.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct an RPC server.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct an RPC server.protectedServer(String bindAddress, int port, Class<? extends Writable> paramClass, int handlerCount, int numReaders, int queueSizePerHandler, Configuration conf, String serverName, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) protectedServer(String bindAddress, int port, Class<? extends Writable> rpcRequestClass, int handlerCount, int numReaders, int queueSizePerHandler, Configuration conf, String serverName, SecretManager<? extends TokenIdentifier> secretManager) protectedServer(String bindAddress, int port, Class<? extends Writable> rpcRequestClass, int handlerCount, int numReaders, int queueSizePerHandler, Configuration conf, String serverName, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) Constructs a server listening on the named port and address.protectedServer(String bindAddress, int port, Class<? extends Writable> paramClass, int handlerCount, Configuration conf) Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port) Deprecated.Construct an RPC server.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) Deprecated.use Server#Server(Class, Object, Configuration, String, int, int, int, int, boolean, SecretManager)Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.Construct an RPC server.Server(Object instance, Configuration conf, String bindAddress, int port) Deprecated.Use #Server(Class, Object, Configuration, String, int)Server(Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager) Deprecated.use Server#Server(Class, Object, Configuration, String, int, int, int, int, boolean, SecretManager)WeightedRoundRobinMultiplexer(int aNumQueues, String ns, Configuration conf) -
Uses of Configuration in org.apache.hadoop.ipc.metrics
Methods in org.apache.hadoop.ipc.metrics with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic RpcMetricsRpcMetrics.create(Server server, Configuration conf) static TimeUnitRpcMetrics.getMetricsTimeUnit(Configuration conf) -
Uses of Configuration in org.apache.hadoop.metrics2.sink
Fields in org.apache.hadoop.metrics2.sink declared as ConfigurationModifier and TypeFieldDescriptionprotected static ConfigurationRollingFileSystemSink.suppliedConf -
Uses of Configuration in org.apache.hadoop.net
Methods in org.apache.hadoop.net that return ConfigurationModifier and TypeMethodDescriptionAbstractDNSToSwitchMapping.getConf()ScriptBasedMapping.getConf()SocksSocketFactory.getConf()TableMapping.getConf()Methods in org.apache.hadoop.net with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic SocketFactoryNetUtils.getDefaultSocketFactory(Configuration conf) Get the default socket factory as specified by the configuration parameterhadoop.rpc.socket.factory.defaultstatic NetworkTopologyNetworkTopology.getInstance(Configuration conf) Get an instance of NetworkTopology based on the value of the configuration parameter net.topology.impl.static NetworkTopologyNetworkTopology.getInstance(Configuration conf, InnerNode.Factory factory) static SocketFactoryNetUtils.getSocketFactory(Configuration conf, Class<?> clazz) Get the socket factory for the given class according to its configuration parameterhadoop.rpc.socket.factory.class.<ClassName>.static SocketFactoryNetUtils.getSocketFactoryFromProperty(Configuration conf, String propValue) Get the socket factory corresponding to the given proxy URI.static DomainNameResolverDomainNameResolverFactory.newInstance(Configuration conf, String configKey) This function gets the instance based on the config.static DomainNameResolverDomainNameResolverFactory.newInstance(Configuration conf, String host, String configKey) static DomainNameResolverDomainNameResolverFactory.newInstance(Configuration conf, URI uri, String configKey) Create a domain name resolver to convert the domain name in the config to the actual IP addresses of the Namenode/Router/RM.voidAbstractDNSToSwitchMapping.setConf(Configuration conf) voidScriptBasedMapping.RawScriptBasedMapping.setConf(Configuration conf) Set the configuration and extract the configuration parameters of interestvoidScriptBasedMapping.setConf(Configuration conf) Set the configuration to be used by this object.voidScriptBasedMappingWithDependency.setConf(Configuration conf) Set the configuration to be used by this object.voidSocksSocketFactory.setConf(Configuration conf) voidTableMapping.setConf(Configuration conf) Constructors in org.apache.hadoop.net with parameters of type ConfigurationModifierConstructorDescriptionprotectedCreate an instance, caching the configuration file.Create an instance from the given configuration -
Uses of Configuration in org.apache.hadoop.security
Methods in org.apache.hadoop.security that return ConfigurationModifier and TypeMethodDescriptionstatic ConfigurationProviderUtils.excludeIncompatibleCredentialProviders(Configuration config, Class<? extends FileSystem> fileSystemClass) There are certain integrations of the credential provider API in which a recursive dependency between the provider and the hadoop filesystem abstraction causes a problem.CompositeGroupsMapping.getConf()LdapGroupsMapping.getConf()SaslPropertiesResolver.getConf()Methods in org.apache.hadoop.security with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic ConfigurationProviderUtils.excludeIncompatibleCredentialProviders(Configuration config, Class<? extends FileSystem> fileSystemClass) There are certain integrations of the credential provider API in which a recursive dependency between the provider and the hadoop filesystem abstraction causes a problem.static intKDiag.exec(Configuration conf, String... argv) Inner entry point, with no logging or system exits.static CustomizedCallbackHandlerCustomizedCallbackHandler.get(String key, Configuration conf) SecurityUtil.getAuthenticationMethod(Configuration conf) static StringSecurityUtil.getClientPrincipal(Class<?> protocol, Configuration conf) Look up the client principal for a given protocol.AuthenticationFilterInitializer.getFilterConfigMap(Configuration conf, String prefix) HttpCrossOriginFilterInitializer.getFilterParameters(Configuration conf, String prefix) static SaslPropertiesResolverSaslPropertiesResolver.getInstance(Configuration conf) Returns an instance of SaslPropertiesResolver.AnnotatedSecurityInfo.getKerberosInfo(Class<?> protocol, Configuration conf) abstract KerberosInfoSecurityInfo.getKerberosInfo(Class<?> protocol, Configuration conf) Get the KerberosInfo for a given protocol.static KerberosInfoSecurityUtil.getKerberosInfo(Class<?> protocol, Configuration conf) Look up the KerberosInfo for a given protocol.AnnotatedSecurityInfo.getTokenInfo(Class<?> protocol, Configuration conf) abstract TokenInfoSecurityInfo.getTokenInfo(Class<?> protocol, Configuration conf) Get the TokenInfo for a given protocol.static TokenInfoSecurityUtil.getTokenInfo(Class<?> protocol, Configuration conf) Look up the TokenInfo for a given protocol.static GroupsGroups.getUserToGroupsMappingService(Configuration conf) Get the groups being used to map user-to-groups.static GroupsCreate new groups used to map user-to-groups with loaded configuration.static List<ZKUtil.ZKAuthInfo>SecurityUtil.getZKAuthInfos(Configuration conf, String configKey) Utility method to fetch ZK auth info from the configuration.static voidSaslRpcServer.init(Configuration conf) voidAuthenticationFilterInitializer.initFilter(FilterContainer container, Configuration conf) Initializes hadoop-auth AuthenticationFilter.voidHttpCrossOriginFilterInitializer.initFilter(FilterContainer container, Configuration conf) protected booleanKDiag.isSimpleAuthentication(Configuration conf) Is the authentication method of this configuration "simple"?static voidSecurityUtil.login(Configuration conf, String keytabFileKey, String userNameKey) Login as a principal specified in config.static voidSecurityUtil.login(Configuration conf, String keytabFileKey, String userNameKey, String hostname) Login as a principal specified in config.static CredentialsCredentials.readTokenStorageFile(File filename, Configuration conf) Convenience method for reading a token storage file and loading its Tokens.static CredentialsCredentials.readTokenStorageFile(Path filename, Configuration conf) Convenience method for reading a token storage file and loading its Tokens.static voidSecurityUtil.setAuthenticationMethod(UserGroupInformation.AuthenticationMethod authenticationMethod, Configuration conf) voidCompositeGroupsMapping.setConf(Configuration conf) voidIngressPortBasedResolver.setConf(Configuration conf) voidLdapGroupsMapping.setConf(Configuration conf) voidRuleBasedLdapGroupsMapping.setConf(Configuration conf) voidSaslPropertiesResolver.setConf(Configuration conf) voidShellBasedUnixGroupsMapping.setConf(Configuration conf) voidWhitelistBasedResolver.setConf(Configuration conf) static voidHadoopKerberosName.setConfiguration(Configuration conf) Set the static configuration to get and evaluate the rules.static voidSecurityUtil.setConfiguration(Configuration conf) static voidUserGroupInformation.setConfiguration(Configuration conf) Set the static configuration for UGI.voidCredentials.writeTokenStorageFile(Path filename, Configuration conf) voidCredentials.writeTokenStorageFile(Path filename, Configuration conf, Credentials.SerializedFormat format) Constructors in org.apache.hadoop.security with parameters of type ConfigurationModifierConstructorDescriptionGroups(Configuration conf) Groups(Configuration conf, Timer timer) KDiag(Configuration conf, PrintWriter out, File keytab, String principal, long minKeyLength, boolean securityRequired) SaslDigestCallbackHandler(SecretManager<TokenIdentifier> secretManager, Server.Connection connection, Configuration conf) SaslRpcClient(UserGroupInformation ugi, Class<?> protocol, InetSocketAddress serverAddr, Configuration conf) Create a SaslRpcClient that can be used by a RPC client to negotiate SASL authentication with a RPC serverShellBasedIdMapping(Configuration conf, boolean constructFullMapAtInit) Configuration for the ZooKeeper connection when SSL/TLS is enabled. -
Uses of Configuration in org.apache.hadoop.security.alias
Methods in org.apache.hadoop.security.alias that return ConfigurationMethods in org.apache.hadoop.security.alias with parameters of type ConfigurationModifier and TypeMethodDescriptionBouncyCastleFipsKeyStoreProvider.Factory.createProvider(URI providerName, Configuration conf) abstract CredentialProviderCredentialProviderFactory.createProvider(URI providerName, Configuration conf) JavaKeyStoreProvider.Factory.createProvider(URI providerName, Configuration conf) LocalBouncyCastleFipsKeyStoreProvider.Factory.createProvider(URI providerName, Configuration conf) LocalJavaKeyStoreProvider.Factory.createProvider(URI providerName, Configuration conf) UserProvider.Factory.createProvider(URI providerName, Configuration conf) static List<CredentialProvider>CredentialProviderFactory.getProviders(Configuration conf) Constructors in org.apache.hadoop.security.alias with parameters of type ConfigurationModifierConstructorDescriptionprotectedAbstractJavaKeyStoreProvider(URI uri, Configuration conf) protectedKeyStoreProvider(URI uri, Configuration conf) protectedLocalKeyStoreProvider(URI uri, Configuration conf) -
Uses of Configuration in org.apache.hadoop.security.authentication.server
Methods in org.apache.hadoop.security.authentication.server that return ConfigurationModifier and TypeMethodDescriptionprotected ConfigurationProxyUserAuthenticationFilter.getProxyuserConfiguration(javax.servlet.FilterConfig filterConfig) Methods in org.apache.hadoop.security.authentication.server with parameters of type ConfigurationModifier and TypeMethodDescriptionProxyUserAuthenticationFilterInitializer.createFilterConfig(Configuration conf) voidProxyUserAuthenticationFilterInitializer.initFilter(FilterContainer container, Configuration conf) -
Uses of Configuration in org.apache.hadoop.security.authorize
Methods in org.apache.hadoop.security.authorize that return ConfigurationMethods in org.apache.hadoop.security.authorize with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic voidProxyUsers.authorize(UserGroupInformation user, String remoteAddress, Configuration conf) Deprecated.useProxyUsers.authorize(UserGroupInformation, String)instead.voidServiceAuthorizationManager.authorize(UserGroupInformation user, Class<?> protocol, Configuration conf, InetAddress addr) Authorize the user to access the protocol being used.static voidProxyServers.refresh(Configuration conf) voidServiceAuthorizationManager.refresh(Configuration conf, PolicyProvider provider) static voidProxyUsers.refreshSuperUserGroupsConfiguration(Configuration conf) Refreshes configuration using the default Proxy user prefix for properties.static voidProxyUsers.refreshSuperUserGroupsConfiguration(Configuration conf, String proxyUserPrefix) Refreshes configuration using the specified Proxy user prefix for properties.voidServiceAuthorizationManager.refreshWithLoadedConfiguration(Configuration conf, PolicyProvider provider) voidDefaultImpersonationProvider.setConf(Configuration conf) -
Uses of Configuration in org.apache.hadoop.security.http
Methods in org.apache.hadoop.security.http with parameters of type ConfigurationModifier and TypeMethodDescriptionRestCsrfPreventionFilter.getFilterParams(Configuration conf, String confPrefix) Constructs a mapping of configuration properties to be used for filter initialization.XFrameOptionsFilter.getFilterParams(Configuration conf, String confPrefix) Constructs a mapping of configuration properties to be used for filter initialization. -
Uses of Configuration in org.apache.hadoop.security.ssl
Methods in org.apache.hadoop.security.ssl that return ConfigurationModifier and TypeMethodDescriptionFileBasedKeyStoresFactory.getConf()Returns the configuration of the factory.static ConfigurationSSLFactory.readSSLConfiguration(Configuration conf, SSLFactory.Mode mode) Methods in org.apache.hadoop.security.ssl with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic ConfigurationSSLFactory.readSSLConfiguration(Configuration conf, SSLFactory.Mode mode) voidFileBasedKeyStoresFactory.setConf(Configuration conf) Sets the configuration for the factory.Constructors in org.apache.hadoop.security.ssl with parameters of type ConfigurationModifierConstructorDescriptionSSLFactory(SSLFactory.Mode mode, Configuration conf) Creates an SSLFactory. -
Uses of Configuration in org.apache.hadoop.security.token
Methods in org.apache.hadoop.security.token with parameters of type ConfigurationModifier and TypeMethodDescriptionToken<?>DtFetcher.addDelegationTokens(Configuration conf, Credentials creds, String renewer, String url) Add any number of delegation tokens to Credentials object and return a token instance that is appropriate for aliasing, or null if none.static voidDtFileOperations.aliasTokenFile(File tokenFile, String fileFormat, Text alias, Text service, Configuration conf) Alias a token from a file and save back to file in the local filesystem.static voidDtFileOperations.appendTokenFiles(ArrayList<File> tokenFiles, String fileFormat, Configuration conf) Append tokens from list of files in local filesystem, saving to last file.voidToken.cancel(Configuration conf) Cancel this delegation token.voidToken.TrivialRenewer.cancel(Token<?> token, Configuration conf) abstract voidTokenRenewer.cancel(Token<?> token, Configuration conf) Cancel the given token.static voidDtFileOperations.doFormattedWrite(File f, String format, Credentials creds, Configuration conf) Write out a Credentials object as a local file.static voidDtFileOperations.getTokenFile(File tokenFile, String fileFormat, Text alias, Text service, String url, String renewer, Configuration conf) Fetch a token from a service and save to file in the local filesystem.static voidDtFileOperations.importTokenFile(File tokenFile, String fileFormat, Text alias, String base64, Configuration conf) Import a token from a base64 encoding into the local filesystem.static voidDtFileOperations.printTokenFile(File tokenFile, Text alias, Configuration conf, PrintStream out) Print out a Credentials file from the local filesystem.static voidDtFileOperations.removeTokenFromFile(boolean cancel, File tokenFile, String fileFormat, Text alias, Configuration conf) Remove a token from a file in the local filesystem, matching alias.longToken.renew(Configuration conf) Renew this delegation token.longToken.TrivialRenewer.renew(Token<?> token, Configuration conf) abstract longTokenRenewer.renew(Token<?> token, Configuration conf) Renew the given token.static voidDtFileOperations.renewTokenFile(File tokenFile, String fileFormat, Text alias, Configuration conf) Renew a token from a file in the local filesystem, matching alias.static voidSecretManager.update(Configuration conf) Updates the selected cryptographic algorithm and key length using the provided HadoopConfiguration. -
Uses of Configuration in org.apache.hadoop.security.token.delegation
Constructors in org.apache.hadoop.security.token.delegation with parameters of type ConfigurationModifierConstructorDescription -
Uses of Configuration in org.apache.hadoop.security.token.delegation.web
Methods in org.apache.hadoop.security.token.delegation.web that return ConfigurationModifier and TypeMethodDescriptionprotected ConfigurationDelegationTokenAuthenticationFilter.getProxyuserConfiguration(javax.servlet.FilterConfig filterConfig) Returns the proxyuser configuration.Constructors in org.apache.hadoop.security.token.delegation.web with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.service
Methods in org.apache.hadoop.service that return ConfigurationModifier and TypeMethodDescriptionAbstractService.getConfig()Service.getConfig()Get the configuration of this service.Methods in org.apache.hadoop.service with parameters of type ConfigurationModifier and TypeMethodDescriptionvoidAbstractService.init(Configuration conf) Initialize the service.voidService.init(Configuration config) Initialize the service.protected voidAbstractService.serviceInit(Configuration conf) All initialization code needed by a service.protected voidCompositeService.serviceInit(Configuration conf) protected voidAbstractService.setConfig(Configuration conf) Set the configuration for this service. -
Uses of Configuration in org.apache.hadoop.service.launcher
Methods in org.apache.hadoop.service.launcher that return ConfigurationModifier and TypeMethodDescriptionAbstractLaunchableService.bindArgs(Configuration config, List<String> args) Propagate the command line arguments.LaunchableService.bindArgs(Configuration config, List<String> args) Propagate the command line arguments.protected ConfigurationServiceLauncher.createConfiguration()Override point: create the base configuration for the service.final ConfigurationServiceLauncher.getConfiguration()Get the configuration constructed from the command line arguments.Methods in org.apache.hadoop.service.launcher with parameters of type ConfigurationModifier and TypeMethodDescriptionAbstractLaunchableService.bindArgs(Configuration config, List<String> args) Propagate the command line arguments.LaunchableService.bindArgs(Configuration config, List<String> args) Propagate the command line arguments.protected intServiceLauncher.coreServiceLaunch(Configuration conf, S instance, List<String> processedArgs, boolean addShutdownHook, boolean execute) Launch the service.protected GenericOptionsParserServiceLauncher.createGenericOptionsParser(Configuration conf, String[] argArray) Override point: create a generic options parser or subclass thereof.ServiceLauncher.extractCommandOptions(Configuration conf, List<String> args) Extract the command options and apply them to the configuration, building an array of processed arguments to hand down to the service.ServiceLauncher.instantiateService(Configuration conf) ServiceLauncher.launchService(Configuration conf, List<String> processedArgs, boolean addShutdownHook, boolean execute) Launch a service catching all exceptions and downgrading them to exit codes after logging.ServiceLauncher.launchService(Configuration conf, S instance, List<String> processedArgs, boolean addShutdownHook, boolean execute) Launch a service catching all exceptions and downgrading them to exit codes after logging.ServiceLauncher.parseCommandArgs(Configuration conf, List<String> args) Parse the command arguments, extracting the service class as the last element of the list (after extracting all the rest).Constructors in org.apache.hadoop.service.launcher with parameters of type ConfigurationModifierConstructorDescriptionMinimalGenericOptionsParser(Configuration conf, org.apache.commons.cli.Options options, String[] args) -
Uses of Configuration in org.apache.hadoop.tools
Methods in org.apache.hadoop.tools with parameters of type ConfigurationModifier and TypeMethodDescriptionprotected abstract InetSocketAddressGetGroupsBase.getProtocolAddress(Configuration conf) Must be overridden by subclasses to get the address where theGetUserMappingsProtocolimplementation is running.Constructors in org.apache.hadoop.tools with parameters of type ConfigurationModifierConstructorDescriptionprotectedGetGroupsBase(Configuration conf) Create an instance of this tool using the given configuration.protectedGetGroupsBase(Configuration conf, PrintStream out) Used exclusively for testing. -
Uses of Configuration in org.apache.hadoop.util
Methods in org.apache.hadoop.util that return ConfigurationModifier and TypeMethodDescriptionGenericOptionsParser.getConfiguration()Get the modified configurationMethods in org.apache.hadoop.util with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic <T> TReflectionUtils.copy(Configuration conf, T src, T dst) Make a copy of the writable object using serialization to a buffer.static KeyProviderKMSUtil.createKeyProvider(Configuration conf, String configKeyName) Creates a new KeyProvider from the given Configuration and configuration key name.static KeyProviderKMSUtil.createKeyProviderFromUri(Configuration conf, URI providerUri) static URIKMSUtil.getKeyProviderUri(Configuration conf) static URIKMSUtil.getKeyProviderUri(Configuration conf, String configKeyName) static URL[]GenericOptionsParser.getLibJars(Configuration conf) If libjars are set in the conf, parse the libjars.static <T> TReflectionUtils.newInstance(Class<T> theClass, Configuration conf) Create an object for the given class and initialize it from confstatic <T> TReflectionUtils.newInstance(Class<T> theClass, Configuration conf, Class<?>[] argTypes, Object... values) Create an object for the given class and initialize it from confstatic <E extends Enum<E>>
EConfigurationHelper.resolveEnum(Configuration conf, String name, Class<E> enumClass, Function<String, E> fallback) Look up an enum from the configuration option and map it to a value in the supplied enum class.static intToolRunner.run(Configuration conf, Tool tool, String[] args) Runs the givenToolbyTool.run(String[]), after parsing with the given generic arguments.protected voidJvmPauseMonitor.serviceInit(Configuration conf) static voidReflectionUtils.setConf(Object theObject, Configuration conf) Check and set 'configuration' if necessary.Constructors in org.apache.hadoop.util with parameters of type ConfigurationModifierConstructorDescriptionFindClass(Configuration conf) Create a class with a specified configurationGenericOptionsParser(Configuration conf, String[] args) Create aGenericOptionsParserto parse only the generic Hadoop arguments.GenericOptionsParser(Configuration conf, org.apache.commons.cli.Options options, String[] args) Create aGenericOptionsParserto parse given options as well as generic Hadoop options.LineReader(InputStream in, Configuration conf) Create a line reader that reads from the given stream using theio.file.buffer.sizespecified in the givenConfiguration.LineReader(InputStream in, Configuration conf, byte[] recordDelimiterBytes) Create a line reader that reads from the given stream using theio.file.buffer.sizespecified in the givenConfiguration, and using a custom delimiter of array of bytes. -
Uses of Configuration in org.apache.hadoop.util.curator
Methods in org.apache.hadoop.util.curator with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic List<org.apache.zookeeper.data.ACL>ZKCuratorManager.getZKAcls(Configuration conf) Utility method to fetch the ZK ACLs from the configuration.static List<ZKUtil.ZKAuthInfo>ZKCuratorManager.getZKAuths(Configuration conf) Utility method to fetch ZK auth info from the configuration.Constructors in org.apache.hadoop.util.curator with parameters of type Configuration -
Uses of Configuration in org.apache.hadoop.util.functional
Methods in org.apache.hadoop.util.functional with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic voidFutureIO.propagateOptions(FSBuilder<?, ?> builder, Configuration conf, String prefix, boolean mandatory) Propagate options to any builder, converting everything with the prefix to an option where, if there were 2+ dot-separated elements, it is converted to a schema.FutureIO.propagateOptions(FSBuilder<T, U> builder, Configuration conf, String optionalPrefix, String mandatoryPrefix) Propagate options to any builder, converting everything with the prefix to an option where, if there were 2+ dot-separated elements, it is converted to a schema. -
Uses of Configuration in org.apache.hadoop.util.hash
Methods in org.apache.hadoop.util.hash with parameters of type ConfigurationModifier and TypeMethodDescriptionstatic intHash.getHashType(Configuration conf) This utility method converts the name of the configured hash type to a symbolic constant.static HashHash.getInstance(Configuration conf) Get a singleton instance of hash function of a type defined in the configuration.
TrashPolicy.getInstance(Configuration, FileSystem)instead.