| Modifier and Type | Method and Description |
|---|---|
Configuration |
Configured.getConf() |
Configuration |
Configurable.getConf()
Return the configuration used by this object.
|
protected abstract Configuration |
ReconfigurableBase.getNewConf()
Create a new configuration.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Configuration.addResource(Configuration conf)
Add a configuration resource.
|
static void |
Configuration.dumpConfiguration(Configuration config,
Writer out)
Writes out all the parameters and their properties (final and resource) to
the given
Writer
The format of the output would be
{ "properties" : [ {key1,value1,key1.isFinal,key1.resource}, {key2,value2,
key2.isFinal,key2.resource}... |
static Collection<ReconfigurationUtil.PropertyChange> |
ReconfigurationUtil.getChangedProperties(Configuration newConf,
Configuration oldConf) |
Collection<ReconfigurationUtil.PropertyChange> |
ReconfigurableBase.getChangedProperties(Configuration newConf,
Configuration oldConf) |
Collection<ReconfigurationUtil.PropertyChange> |
ReconfigurationUtil.parseChangedProperties(Configuration newConf,
Configuration oldConf) |
void |
Configured.setConf(Configuration conf) |
void |
Configurable.setConf(Configuration conf)
Set the configuration to be used by this object.
|
| Constructor and Description |
|---|
ConfigRedactor(Configuration conf) |
Configuration(Configuration other)
A new configuration with the same settings cloned from another.
|
Configured(Configuration conf)
Construct a Configured.
|
ReconfigurableBase(Configuration conf)
Construct a ReconfigurableBase with the
Configuration
conf. |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
KeyProvider.getConf()
Return the provider configuration.
|
| Modifier and Type | Method and Description |
|---|---|
KeyProvider |
UserProvider.Factory.createProvider(URI providerName,
Configuration conf) |
abstract KeyProvider |
KeyProviderFactory.createProvider(URI providerName,
Configuration conf) |
KeyProvider |
JavaKeyStoreProvider.Factory.createProvider(URI providerName,
Configuration conf) |
static KeyProvider |
KeyProviderFactory.get(URI uri,
Configuration conf)
Create a KeyProvider based on a provided URI.
|
static List<KeyProvider> |
KeyProviderFactory.getProviders(Configuration conf) |
static KeyProvider.Options |
KeyProvider.options(Configuration conf)
A helper function to create an options object.
|
| Constructor and Description |
|---|
KeyProvider.Options(Configuration conf) |
KeyProvider(Configuration conf)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
KMSClientProvider.KMSTokenRenewer.cancel(Token<?> token,
Configuration conf) |
KeyProvider |
KMSClientProvider.Factory.createProvider(URI providerUri,
Configuration conf)
This provider expects URIs in the following form :
kms://
LoadBalancingKMSClientProvider that round-robins requests
across the provided list of hosts. |
long |
KMSClientProvider.KMSTokenRenewer.renew(Token<?> token,
Configuration conf) |
| Constructor and Description |
|---|
LoadBalancingKMSClientProvider(org.apache.hadoop.crypto.key.kms.KMSClientProvider[] providers,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
HarFileSystem.getConf() |
Configuration |
GetSpaceUsed.Builder.getConf() |
Configuration |
FilterFileSystem.getConf() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
FileUtil.copy(File src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
Configuration conf)
Copy local files to a FileSystem.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
FileStatus srcStatus,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf)
Copy files between FileSystems.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path[] srcs,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf) |
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
File dst,
boolean deleteSource,
Configuration conf)
Copy FileSystem files to local files.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
boolean overwrite,
Configuration conf)
Copy files between FileSystems.
|
static boolean |
FileUtil.copy(FileSystem srcFS,
Path src,
FileSystem dstFS,
Path dst,
boolean deleteSource,
Configuration conf)
Copy files between FileSystems.
|
static boolean |
FileUtil.copyMerge(FileSystem srcFS,
Path srcDir,
FileSystem dstFS,
Path dstFile,
boolean deleteSource,
Configuration conf,
String addString)
Deprecated.
|
static AbstractFileSystem |
AbstractFileSystem.createFileSystem(URI uri,
Configuration conf)
Create a file system instance for the specified uri using the conf.
|
static FileSystem |
FileSystem.get(Configuration conf)
Returns the configured filesystem implementation.
|
static FileSystem |
FileSystem.get(URI uri,
Configuration conf)
Returns the FileSystem for this URI's scheme and authority.
|
static AbstractFileSystem |
AbstractFileSystem.get(URI uri,
Configuration conf)
The main factory method for creating a file system.
|
static FileSystem |
FileSystem.get(URI uri,
Configuration conf,
String user)
Get a filesystem instance based on the uri, the passed
configuration and the user
|
static URI |
FileSystem.getDefaultUri(Configuration conf)
Get the default filesystem URI from a configuration.
|
static FileContext |
FileContext.getFileContext(AbstractFileSystem defFS,
Configuration aConf)
Create a FileContext with specified FS as default using the specified
config.
|
static FileContext |
FileContext.getFileContext(Configuration aConf)
Create a FileContext using the passed config.
|
static FileContext |
FileContext.getFileContext(URI defaultFsUri,
Configuration aConf)
Create a FileContext for specified default URI using the specified config.
|
FileSystem |
Path.getFileSystem(Configuration conf)
Return the FileSystem that owns this Path.
|
static Class<? extends FileSystem> |
FileSystem.getFileSystemClass(String scheme,
Configuration conf) |
protected static FileSystem |
FileSystem.getFSofPath(Path absOrFqPath,
Configuration conf) |
static TrashPolicy |
TrashPolicy.getInstance(Configuration conf,
FileSystem fs)
Get an instance of the configured TrashPolicy based on the value
of the configuration parameter fs.trash.classname.
|
static TrashPolicy |
TrashPolicy.getInstance(Configuration conf,
FileSystem fs,
Path home)
Deprecated.
Use
TrashPolicy.getInstance(Configuration, FileSystem) instead. |
static LocalFileSystem |
FileSystem.getLocal(Configuration conf)
Get the local file system.
|
static FileContext |
FileContext.getLocalFSFileContext(Configuration aConf) |
static FileSystem |
FileSystem.getNamed(String name,
Configuration conf)
Deprecated.
call #get(URI,Configuration) instead.
|
void |
TrashPolicy.initialize(Configuration conf,
FileSystem fs)
Used to setup the trash policy.
|
abstract void |
TrashPolicy.initialize(Configuration conf,
FileSystem fs,
Path home)
Deprecated.
Use
TrashPolicy.initialize(Configuration, FileSystem) instead. |
void |
RawLocalFileSystem.initialize(URI uri,
Configuration conf) |
void |
LocalFileSystem.initialize(URI name,
Configuration conf) |
void |
HarFileSystem.initialize(URI name,
Configuration conf)
Initialize a Har filesystem per har archive.
|
void |
FilterFileSystem.initialize(URI name,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
void |
FileSystem.initialize(URI name,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
static boolean |
Trash.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 FileSystem |
FileSystem.newInstance(Configuration conf)
Returns a unique configured filesystem implementation.
|
static FileSystem |
FileSystem.newInstance(URI uri,
Configuration conf)
Returns the FileSystem for this URI's scheme and authority.
|
static FileSystem |
FileSystem.newInstance(URI uri,
Configuration conf,
String user)
Returns the FileSystem for this URI's scheme and authority and the
passed user.
|
static LocalFileSystem |
FileSystem.newInstanceLocal(Configuration conf)
Get a unique local file system object
|
GetSpaceUsed.Builder |
GetSpaceUsed.Builder.setConf(Configuration conf) |
void |
ChecksumFileSystem.setConf(Configuration conf) |
static void |
FileSystem.setDefaultUri(Configuration conf,
String uri)
Set the default filesystem URI in a configuration.
|
static void |
FileSystem.setDefaultUri(Configuration conf,
URI uri)
Set the default filesystem URI in a configuration.
|
| Constructor and Description |
|---|
Trash(Configuration conf)
Construct a trash can accessor.
|
Trash(FileSystem fs,
Configuration conf)
Construct a trash can accessor for the FileSystem provided.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FTPFileSystem.initialize(URI uri,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
static FsPermission |
FsPermission.getUMask(Configuration conf)
Get the user file creation mask (umask)
UMASK_LABEL config param has umask value that is either symbolic
or octal. |
static void |
FsPermission.setUMask(Configuration conf,
FsPermission umask)
Set the user file creation mask (umask)
|
| Modifier and Type | Method and Description |
|---|---|
void |
SFTPFileSystem.initialize(URI uriInfo,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
FilterExpression.getConf() |
Configuration |
BaseExpression.getConf() |
Configuration |
FindOptions.getConfiguration()
Return the
Configuration return configuration Configuration |
| Modifier and Type | Method and Description |
|---|---|
void |
FilterExpression.setConf(Configuration conf) |
void |
BaseExpression.setConf(Configuration conf) |
void |
FindOptions.setConfiguration(Configuration configuration)
Set the
Configuration |
| Modifier and Type | Method and Description |
|---|---|
static void |
ConfigUtil.addLink(Configuration conf,
String mountTableName,
String src,
URI target)
Add a link to the config for the specified mount table
|
static void |
ConfigUtil.addLink(Configuration conf,
String src,
URI target)
Add a link to the config for the default mount table
|
static String |
ConfigUtil.getHomeDirValue(Configuration conf)
Get the value of the home dir conf value for default mount table
|
static String |
ConfigUtil.getHomeDirValue(Configuration conf,
String mountTableName)
Get the value of the home dir conf value for specfied mount table
|
void |
ViewFileSystem.initialize(URI theUri,
Configuration conf)
Called after a new FileSystem instance is constructed.
|
static void |
ConfigUtil.setHomeDirConf(Configuration conf,
String homedir)
Add config variable for homedir for default mount table
|
static void |
ConfigUtil.setHomeDirConf(Configuration conf,
String mountTableName,
String homedir)
Add config variable for homedir the specified mount table
|
| Constructor and Description |
|---|
ViewFileSystem(Configuration conf)
Convenience Constructor for apps to call directly
|
ViewFs(Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
HAServiceProtocol |
HAServiceTarget.getHealthMonitorProxy(Configuration conf,
int timeoutMs)
Returns a proxy to connect to the target HA service for health monitoring.
|
HAServiceProtocol |
HAServiceTarget.getProxy(Configuration conf,
int timeoutMs) |
org.apache.hadoop.ha.ZKFCProtocol |
HAServiceTarget.getZKFCProxy(Configuration conf,
int timeoutMs) |
| Constructor and Description |
|---|
ZKFCProtocolClientSideTranslatorPB(InetSocketAddress addr,
Configuration conf,
SocketFactory socketFactory,
int timeout) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
FilterInitializer.initFilter(FilterContainer container,
Configuration conf)
Initialize a Filter to a FilterContainer.
|
HttpServer2.Builder |
HttpServer2.Builder.setConf(Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
void |
StaticUserWebFilter.initFilter(FilterContainer container,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
WritableComparator.getConf() |
Configuration |
ObjectWritable.getConf() |
Configuration |
GenericWritable.getConf() |
Configuration |
EnumSetWritable.getConf() |
Configuration |
AbstractMapWritable.getConf() |
| Modifier and Type | Method and Description |
|---|---|
static <T extends Writable> |
WritableUtils.clone(T orig,
Configuration conf)
Make a copy of a writable object using serialization to a buffer.
|
static void |
IOUtils.copyBytes(InputStream in,
OutputStream out,
Configuration conf)
Copies from one stream to another.
|
static void |
IOUtils.copyBytes(InputStream in,
OutputStream out,
Configuration conf,
boolean close)
Copies from one stream to another.
|
protected SequenceFile.Reader |
MapFile.Reader.createDataFileReader(Path dataFile,
Configuration conf,
SequenceFile.Reader.Option... options)
Override this method to specialize the type of
SequenceFile.Reader returned. |
static SequenceFile.Writer |
SequenceFile.createWriter(Configuration conf,
FSDataOutputStream out,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(Configuration conf,
FSDataOutputStream out,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
SequenceFile.Metadata metadata)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(Configuration conf,
SequenceFile.Writer.Option... opts)
Create a new Writer with the given options.
|
static SequenceFile.Writer |
SequenceFile.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.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.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.Writer |
SequenceFile.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.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
Progressable progress)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
CompressionCodec codec,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
static SequenceFile.Writer |
SequenceFile.createWriter(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
SequenceFile.CompressionType compressionType,
Progressable progress)
Deprecated.
|
static long |
MapFile.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 WritableComparator |
WritableComparator.get(Class<? extends WritableComparable> c,
Configuration conf)
Get a comparator for a
WritableComparable implementation. |
static SequenceFile.CompressionType |
SequenceFile.getDefaultCompressionType(Configuration job)
Get the compression type for the reduce outputs
|
static <K> K |
DefaultStringifier.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 name className by first finding
it in the specified conf.
|
static Writable |
WritableFactories.newInstance(Class<? extends Writable> c,
Configuration conf)
Create a new instance of a class with a defined factory.
|
protected void |
MapFile.Reader.open(Path dir,
WritableComparator comparator,
Configuration conf,
SequenceFile.Reader.Option... options) |
static Object |
ObjectWritable.readObject(DataInput in,
Configuration conf)
|
static Object |
ObjectWritable.readObject(DataInput in,
ObjectWritable objectWritable,
Configuration conf)
|
void |
WritableComparator.setConf(Configuration conf) |
void |
ObjectWritable.setConf(Configuration conf) |
void |
GenericWritable.setConf(Configuration conf) |
void |
EnumSetWritable.setConf(Configuration conf) |
void |
AbstractMapWritable.setConf(Configuration conf) |
static void |
SequenceFile.setDefaultCompressionType(Configuration job,
SequenceFile.CompressionType val)
Set the default compression type for sequence files.
|
static void |
MapFile.Writer.setIndexInterval(Configuration conf,
int interval)
Sets the index interval and stores it in conf
|
static <K> void |
DefaultStringifier.store(Configuration conf,
K item,
String keyName)
Stores the item in the configuration with the given keyName.
|
static <K> void |
DefaultStringifier.storeArray(Configuration conf,
K[] items,
String keyName)
Stores the array of items in the configuration with the given keyName.
|
static void |
ObjectWritable.writeObject(DataOutput out,
Object instance,
Class declaredClass,
Configuration conf)
|
static void |
ObjectWritable.writeObject(DataOutput out,
Object instance,
Class declaredClass,
Configuration conf,
boolean allowCompactArrays)
|
| Constructor and Description |
|---|
ArrayFile.Reader(FileSystem fs,
String file,
Configuration conf)
Construct an array reader for the named file.
|
ArrayFile.Writer(Configuration conf,
FileSystem fs,
String file,
Class<? extends Writable> valClass)
Create the named file for values of the named class.
|
ArrayFile.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.
|
BloomMapFile.Reader(FileSystem fs,
String dirName,
Configuration conf)
Deprecated.
|
BloomMapFile.Reader(FileSystem fs,
String dirName,
WritableComparator comparator,
Configuration conf)
Deprecated.
|
BloomMapFile.Reader(FileSystem fs,
String dirName,
WritableComparator comparator,
Configuration conf,
boolean open)
Deprecated.
|
BloomMapFile.Reader(Path dir,
Configuration conf,
SequenceFile.Reader.Option... options) |
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class valClass)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class<? extends Writable> valClass,
SequenceFile.CompressionType compress,
CompressionCodec codec,
Progressable progress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class valClass,
SequenceFile.CompressionType compress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class valClass,
SequenceFile.CompressionType compress,
Progressable progress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass,
SequenceFile.CompressionType compress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass,
SequenceFile.CompressionType compress,
CompressionCodec codec,
Progressable progress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass,
SequenceFile.CompressionType compress,
Progressable progress)
Deprecated.
|
BloomMapFile.Writer(Configuration conf,
Path dir,
SequenceFile.Writer.Option... options) |
DefaultStringifier(Configuration conf,
Class<T> c) |
MapFile.Merger(Configuration conf) |
MapFile.Reader(FileSystem fs,
String dirName,
Configuration conf)
Deprecated.
|
MapFile.Reader(FileSystem fs,
String dirName,
WritableComparator comparator,
Configuration conf)
Deprecated.
|
MapFile.Reader(Path dir,
Configuration conf,
SequenceFile.Reader.Option... opts) |
MapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class valClass)
Deprecated.
Use Writer(Configuration, Path, Option...) instead.
|
MapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
Class valClass,
SequenceFile.CompressionType compress)
Deprecated.
Use Writer(Configuration, Path, Option...) instead.
|
MapFile.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.
|
MapFile.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.
|
MapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass)
Deprecated.
Use Writer(Configuration, Path, Option...) instead.
|
MapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass,
SequenceFile.CompressionType compress)
Deprecated.
Use Writer(Configuration, Path, Option...) instead.
|
MapFile.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.
|
MapFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
Class valClass,
SequenceFile.CompressionType compress,
Progressable progress)
Deprecated.
Use Writer(Configuration, Path, Option...)} instead.
|
MapFile.Writer(Configuration conf,
Path dirName,
SequenceFile.Writer.Option... opts) |
SequenceFile.Reader(Configuration conf,
SequenceFile.Reader.Option... opts) |
SequenceFile.Reader(FileSystem fs,
Path file,
Configuration conf)
Deprecated.
Use Reader(Configuration, Option...) instead.
|
SequenceFile.Reader(FSDataInputStream in,
int buffersize,
long start,
long length,
Configuration conf)
Deprecated.
Use Reader(Configuration, Reader.Option...) instead.
|
SequenceFile.Sorter(FileSystem fs,
Class<? extends WritableComparable> keyClass,
Class valClass,
Configuration conf)
Sort and merge files containing the named classes.
|
SequenceFile.Sorter(FileSystem fs,
RawComparator comparator,
Class keyClass,
Class valClass,
Configuration conf)
Sort and merge using an arbitrary
RawComparator. |
SequenceFile.Sorter(FileSystem fs,
RawComparator comparator,
Class keyClass,
Class valClass,
Configuration conf,
SequenceFile.Metadata metadata)
Sort and merge using an arbitrary
RawComparator. |
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass)
Deprecated.
|
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
int bufferSize,
short replication,
long blockSize,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
SequenceFile.Writer(FileSystem fs,
Configuration conf,
Path name,
Class keyClass,
Class valClass,
Progressable progress,
SequenceFile.Metadata metadata)
Deprecated.
|
SetFile.Reader(FileSystem fs,
String dirName,
Configuration conf)
Construct a set reader for the named set.
|
SetFile.Reader(FileSystem fs,
String dirName,
WritableComparator comparator,
Configuration conf)
Construct a set reader for the named set using the named comparator.
|
SetFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
Class<? extends WritableComparable> keyClass,
SequenceFile.CompressionType compress)
Create a set naming the element class and compression type.
|
SetFile.Writer(Configuration conf,
FileSystem fs,
String dirName,
WritableComparator comparator,
SequenceFile.CompressionType compress)
Create a set naming the element comparator and compression type.
|
WritableComparator(Class<? extends WritableComparable> keyClass,
Configuration conf,
boolean createInstances) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
SnappyCodec.getConf()
Return the configuration used by this object.
|
Configuration |
Lz4Codec.getConf()
Return the configuration used by this object.
|
Configuration |
DefaultCodec.getConf() |
Configuration |
BZip2Codec.getConf()
Return the configuration used by this object.
|
| Modifier and Type | Method and Description |
|---|---|
static List<Class<? extends CompressionCodec>> |
CompressionCodecFactory.getCodecClasses(Configuration conf)
Get the list of codecs discovered via a Java ServiceLoader, or
listed in the configuration.
|
static Compressor |
CodecPool.getCompressor(CompressionCodec codec,
Configuration conf)
Get a
Compressor for the given CompressionCodec from the
pool or a new one. |
void |
Compressor.reinit(Configuration conf)
Prepare the compressor to be used in a new stream with settings defined in
the given Configuration
|
static void |
CompressionCodecFactory.setCodecClasses(Configuration conf,
List<Class> classes)
Sets a list of codec classes in the configuration.
|
void |
SnappyCodec.setConf(Configuration conf)
Set the configuration to be used by this object.
|
void |
Lz4Codec.setConf(Configuration conf)
Set the configuration to be used by this object.
|
void |
DefaultCodec.setConf(Configuration conf) |
void |
BZip2Codec.setConf(Configuration conf)
Set the configuration to be used by this object.
|
| Constructor and Description |
|---|
CompressionCodecFactory(Configuration conf)
Find the codecs specified in the config value io.compression.codecs
and register them.
|
| Modifier and Type | Method and Description |
|---|---|
static int |
Bzip2Factory.getBlockSize(Configuration conf) |
static Compressor |
Bzip2Factory.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 Decompressor |
Bzip2Factory.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 String |
Bzip2Factory.getLibraryName(Configuration conf) |
static int |
Bzip2Factory.getWorkFactor(Configuration conf) |
static boolean |
Bzip2Factory.isNativeBzip2Loaded(Configuration conf)
Check if native-bzip2 code is loaded & initialized correctly and
can be loaded for this job.
|
void |
BZip2DummyCompressor.reinit(Configuration conf) |
void |
Bzip2Compressor.reinit(Configuration conf)
Prepare the compressor to be used in a new stream with settings defined in
the given Configuration.
|
static void |
Bzip2Factory.setBlockSize(Configuration conf,
int blockSize) |
static void |
Bzip2Factory.setWorkFactor(Configuration conf,
int workFactor) |
| Constructor and Description |
|---|
Bzip2Compressor(Configuration conf)
Creates a new compressor, taking settings from the configuration.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Lz4Compressor.reinit(Configuration conf)
Prepare the compressor to be used in a new stream with settings defined in
the given Configuration
|
| Modifier and Type | Method and Description |
|---|---|
void |
SnappyCompressor.reinit(Configuration conf)
Prepare the compressor to be used in a new stream with settings defined in
the given Configuration
|
| Modifier and Type | Method and Description |
|---|---|
static ZlibCompressor.CompressionLevel |
ZlibFactory.getCompressionLevel(Configuration conf) |
static ZlibCompressor.CompressionStrategy |
ZlibFactory.getCompressionStrategy(Configuration conf) |
static Compressor |
ZlibFactory.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 Decompressor |
ZlibFactory.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 DirectDecompressor |
ZlibFactory.getZlibDirectDecompressor(Configuration conf)
Return the appropriate implementation of the zlib direct decompressor.
|
static boolean |
ZlibFactory.isNativeZlibLoaded(Configuration conf)
Check if native-zlib code is loaded & initialized correctly and
can be loaded for this job.
|
void |
ZlibCompressor.reinit(Configuration conf)
Prepare the compressor to be used in a new stream with settings defined in
the given Configuration.
|
void |
BuiltInZlibDeflater.reinit(Configuration conf)
reinit the compressor with the given configuration.
|
static void |
ZlibFactory.setCompressionLevel(Configuration conf,
ZlibCompressor.CompressionLevel level) |
static void |
ZlibFactory.setCompressionStrategy(Configuration conf,
ZlibCompressor.CompressionStrategy strategy) |
| Constructor and Description |
|---|
ZlibCompressor(Configuration conf)
Creates a new compressor, taking settings from the configuration.
|
| Constructor and Description |
|---|
TFile.Reader(FSDataInputStream fsdis,
long fileLength,
Configuration conf)
Constructor
|
TFile.Writer(FSDataOutputStream fsdos,
int minBlockSize,
String compressName,
String comparator,
Configuration conf)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
static RetryPolicy |
RetryUtils.getDefaultRetryPolicy(Configuration conf,
String retryPolicyEnabledKey,
boolean defaultRetryPolicyEnabled,
String retryPolicySpecKey,
String defaultRetryPolicySpec,
String remoteExceptionToRetry)
Return the default retry policy set in conf.
|
static RetryPolicy |
RetryUtils.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.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
Server.bind(ServerSocket socket,
InetSocketAddress address,
int backlog,
Configuration conf,
String rangeConf) |
ProtocolProxy<ProtocolMetaInfoPB> |
WritableRpcEngine.getProtocolMetaInfoProxy(org.apache.hadoop.ipc.Client.ConnectionId connId,
Configuration conf,
SocketFactory factory) |
ProtocolProxy<ProtocolMetaInfoPB> |
RpcEngine.getProtocolMetaInfoProxy(org.apache.hadoop.ipc.Client.ConnectionId connId,
Configuration conf,
SocketFactory factory)
Returns a proxy for ProtocolMetaInfoPB, which uses the given connection
id.
|
ProtocolProxy<ProtocolMetaInfoPB> |
ProtobufRpcEngine.getProtocolMetaInfoProxy(org.apache.hadoop.ipc.Client.ConnectionId connId,
Configuration conf,
SocketFactory factory) |
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout) |
<T> ProtocolProxy<T> |
WritableRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object 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> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy) |
<T> ProtocolProxy<T> |
WritableRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth)
Construct a client-side proxy object 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,
AtomicBoolean fallbackToSimpleAuth)
Construct a client-side proxy object.
|
<T> ProtocolProxy<T> |
ProtobufRpcEngine.getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth) |
static int |
Client.getRpcTimeout(Configuration conf)
The time after which a RPC will timeout.
|
RPC.Server |
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) |
RPC.Server |
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)
Construct a server for a protocol implementation instance.
|
RPC.Server |
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) |
static int |
Client.getTimeout(Configuration conf)
Deprecated.
use
Client.getRpcTimeout(Configuration) instead |
<T> T |
RpcWritable.Buffer.newInstance(Class<T> valueClass,
Configuration conf) |
void |
Server.refreshCallQueue(Configuration conf) |
void |
Server.refreshServiceAcl(Configuration conf,
org.apache.hadoop.security.authorize.PolicyProvider provider)
Refresh the service authorization ACL for the service handled by this server.
|
static void |
Client.setConnectTimeout(Configuration conf,
int timeout)
set the connection timeout value in configuration
|
void |
CallQueueManager.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.
|
| Constructor and Description |
|---|
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 given
Writable
class. |
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,
Configuration conf)
Create a FairCallQueue.
|
ProtobufRpcEngine.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)
Construct an RPC server.
|
RPC.Builder(Configuration conf) |
RPC.Server(String bindAddress,
int port,
Class<? extends Writable> paramClass,
int handlerCount,
int numReaders,
int queueSizePerHandler,
Configuration conf,
String serverName,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig) |
Server(String bindAddress,
int port,
Class<? extends Writable> paramClass,
int handlerCount,
Configuration conf) |
Server(String bindAddress,
int port,
Class<? extends Writable> rpcRequestClass,
int handlerCount,
int numReaders,
int queueSizePerHandler,
Configuration conf,
String serverName,
SecretManager<? extends TokenIdentifier> secretManager) |
Server(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.
|
WeightedRoundRobinMultiplexer(int aNumQueues,
String ns,
Configuration conf) |
WritableRpcEngine.Server(Class<?> protocolClass,
Object protocolImpl,
Configuration conf,
String bindAddress,
int port)
Construct an RPC server.
|
WritableRpcEngine.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)
Construct an RPC server.
|
WritableRpcEngine.Server(Object instance,
Configuration conf,
String bindAddress,
int port)
Deprecated.
Use #Server(Class, Object, Configuration, String, int)
|
WritableRpcEngine.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)
|
| Modifier and Type | Method and Description |
|---|---|
Configuration |
TableMapping.getConf() |
Configuration |
SocksSocketFactory.getConf() |
Configuration |
ScriptBasedMapping.getConf() |
Configuration |
AbstractDNSToSwitchMapping.getConf() |
| Modifier and Type | Method and Description |
|---|---|
void |
TableMapping.setConf(Configuration conf) |
void |
SocksSocketFactory.setConf(Configuration conf) |
void |
ScriptBasedMapping.setConf(Configuration conf)
Set the configuration to be used by this object.
|
void |
ScriptBasedMapping.RawScriptBasedMapping.setConf(Configuration conf)
Set the configuration and extract the configuration parameters of interest
|
void |
AbstractDNSToSwitchMapping.setConf(Configuration conf) |
| Constructor and Description |
|---|
AbstractDNSToSwitchMapping(Configuration conf)
Create an instance, caching the configuration file.
|
ScriptBasedMapping(Configuration conf)
Create an instance from the given configuration
|
| Modifier and Type | Method and Description |
|---|---|
static Configuration |
ProviderUtils.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.
|
Configuration |
SaslPropertiesResolver.getConf() |
| Modifier and Type | Method and Description |
|---|---|
static Configuration |
ProviderUtils.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 int |
KDiag.exec(Configuration conf,
String... argv)
Inner entry point, with no logging or system exits.
|
static UserGroupInformation.AuthenticationMethod |
SecurityUtil.getAuthenticationMethod(Configuration conf) |
static Map<String,String> |
AuthenticationFilterInitializer.getFilterConfigMap(Configuration conf,
String prefix) |
protected static Map<String,String> |
HttpCrossOriginFilterInitializer.getFilterParameters(Configuration conf,
String prefix) |
static SaslPropertiesResolver |
SaslPropertiesResolver.getInstance(Configuration conf)
Returns an instance of SaslPropertiesResolver.
|
static org.apache.hadoop.security.KerberosInfo |
SecurityUtil.getKerberosInfo(Class<?> protocol,
Configuration conf)
Look up the KerberosInfo for a given protocol.
|
org.apache.hadoop.security.KerberosInfo |
AnnotatedSecurityInfo.getKerberosInfo(Class<?> protocol,
Configuration conf) |
static TokenInfo |
SecurityUtil.getTokenInfo(Class<?> protocol,
Configuration conf)
Look up the TokenInfo for a given protocol.
|
TokenInfo |
AnnotatedSecurityInfo.getTokenInfo(Class<?> protocol,
Configuration conf) |
void |
HttpCrossOriginFilterInitializer.initFilter(FilterContainer container,
Configuration conf) |
void |
AuthenticationFilterInitializer.initFilter(FilterContainer container,
Configuration conf)
Initializes hadoop-auth AuthenticationFilter.
|
protected boolean |
KDiag.isSimpleAuthentication(Configuration conf)
Is the authentication method of this configuration "simple"?
|
static void |
SecurityUtil.login(Configuration conf,
String keytabFileKey,
String userNameKey)
Login as a principal specified in config.
|
static void |
SecurityUtil.login(Configuration conf,
String keytabFileKey,
String userNameKey,
String hostname)
Login as a principal specified in config.
|
static Credentials |
Credentials.readTokenStorageFile(File filename,
Configuration conf)
Convenience method for reading a token storage file, and loading the Tokens
therein in the passed UGI
|
static Credentials |
Credentials.readTokenStorageFile(Path filename,
Configuration conf)
Convenience method for reading a token storage file, and loading the Tokens
therein in the passed UGI
|
static void |
SecurityUtil.setAuthenticationMethod(UserGroupInformation.AuthenticationMethod authenticationMethod,
Configuration conf) |
void |
WhitelistBasedResolver.setConf(Configuration conf) |
void |
SaslPropertiesResolver.setConf(Configuration conf) |
static void |
UserGroupInformation.setConfiguration(Configuration conf)
Set the static configuration for UGI.
|
void |
Credentials.writeTokenStorageFile(Path filename,
Configuration conf) |
| Constructor and Description |
|---|
KDiag(Configuration conf,
PrintWriter out,
File keytab,
String principal,
long minKeyLength,
boolean securityRequired) |
ShellBasedIdMapping(Configuration conf) |
ShellBasedIdMapping(Configuration conf,
boolean constructFullMapAtInit) |
| Modifier and Type | Method and Description |
|---|---|
CredentialProvider |
UserProvider.Factory.createProvider(URI providerName,
Configuration conf) |
CredentialProvider |
LocalJavaKeyStoreProvider.Factory.createProvider(URI providerName,
Configuration conf) |
CredentialProvider |
JavaKeyStoreProvider.Factory.createProvider(URI providerName,
Configuration conf) |
abstract CredentialProvider |
CredentialProviderFactory.createProvider(URI providerName,
Configuration conf) |
static List<CredentialProvider> |
CredentialProviderFactory.getProviders(Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
DefaultImpersonationProvider.getConf() |
| Modifier and Type | Method and Description |
|---|---|
static void |
ProxyServers.refresh(Configuration conf) |
void |
DefaultImpersonationProvider.setConf(Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
static Map<String,String> |
XFrameOptionsFilter.getFilterParams(Configuration conf,
String confPrefix)
Constructs a mapping of configuration properties to be used for filter
initialization.
|
static Map<String,String> |
RestCsrfPreventionFilter.getFilterParams(Configuration conf,
String confPrefix)
Constructs a mapping of configuration properties to be used for filter
initialization.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Token.cancel(Configuration conf)
Cancel this delegation token
|
abstract void |
TokenRenewer.cancel(Token<?> token,
Configuration conf)
Cancel the given token
|
void |
Token.TrivialRenewer.cancel(Token<?> token,
Configuration conf) |
long |
Token.renew(Configuration conf)
Renew this delegation token
|
abstract long |
TokenRenewer.renew(Token<?> token,
Configuration conf)
Renew the given token.
|
long |
Token.TrivialRenewer.renew(Token<?> token,
Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
Service.getConfig()
Get the configuration of this service.
|
Configuration |
AbstractService.getConfig() |
| Modifier and Type | Method and Description |
|---|---|
void |
Service.init(Configuration config)
Initialize the service.
|
void |
AbstractService.init(Configuration conf)
Initialize the service.
|
protected void |
CompositeService.serviceInit(Configuration conf) |
protected void |
AbstractService.serviceInit(Configuration conf)
All initialization code needed by a service.
|
protected void |
AbstractService.setConfig(Configuration conf)
Set the configuration for this service.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract InetSocketAddress |
GetGroupsBase.getProtocolAddress(Configuration conf)
Must be overridden by subclasses to get the address where the
GetUserMappingsProtocol implementation is running. |
| Constructor and Description |
|---|
GetGroupsBase(Configuration conf)
Create an instance of this tool using the given configuration.
|
GetGroupsBase(Configuration conf,
PrintStream out)
Used exclusively for testing.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> T |
ReflectionUtils.copy(Configuration conf,
T src,
T dst)
Make a copy of the writable object using serialization to a buffer
|
static <T> T |
ReflectionUtils.newInstance(Class<T> theClass,
Configuration conf)
Create an object for the given class and initialize it from conf
|
static int |
ToolRunner.run(Configuration conf,
Tool tool,
String[] args)
Runs the given
Tool by Tool.run(String[]), after
parsing with the given generic arguments. |
protected void |
NodeHealthScriptRunner.serviceInit(Configuration conf) |
static void |
ReflectionUtils.setConf(Object theObject,
Configuration conf)
Check and set 'configuration' if necessary.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.