A B C D E F G H I J K L M N O P Q R S T U V W X Y Z

A

abort() - Method in class org.apache.hadoop.security.UserGroupInformation.HadoopLoginModule
 
abortJob(JobContext, int) - Method in class org.apache.hadoop.mapred.FileOutputCommitter
Delete the temporary directory, including all of the work directories.
abortJob(JobContext, int) - Method in class org.apache.hadoop.mapred.OutputCommitter
For cleaning up the job's output after job failure.
abortJob(JobContext, JobStatus.State) - Method in class org.apache.hadoop.mapred.OutputCommitter
This method implements the new interface by calling the old method.
abortJob(JobContext, JobStatus.State) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Delete the temporary directory, including all of the work directories.
abortJob(JobContext, JobStatus.State) - Method in class org.apache.hadoop.mapreduce.OutputCommitter
For aborting an unsuccessful job's output.
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.FileOutputCommitter
 
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
Discard the task output
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
This method implements the new interface by calling the old method.
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Delete the work directory
abortTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.OutputCommitter
Discard the task output
ABSOLUTE - Static variable in class org.apache.hadoop.metrics.spi.MetricValue
Deprecated.  
AbstractDelegationTokenIdentifier - Class in org.apache.hadoop.security.token.delegation
 
AbstractDelegationTokenIdentifier() - Constructor for class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier
 
AbstractDelegationTokenIdentifier(Text, Text, Text) - Constructor for class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier
 
AbstractDelegationTokenSecretManager<TokenIdent extends AbstractDelegationTokenIdentifier> - Class in org.apache.hadoop.security.token.delegation
 
AbstractDelegationTokenSecretManager(long, long, long, long) - Constructor for class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
 
AbstractDelegationTokenSecretManager.DelegationTokenInformation - Class in org.apache.hadoop.security.token.delegation
Class to encapsulate a token's renew date and password.
AbstractDelegationTokenSecretManager.DelegationTokenInformation(long, byte[]) - Constructor for class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager.DelegationTokenInformation
 
AbstractDelegationTokenSelector<TokenIdent extends AbstractDelegationTokenIdentifier> - Class in org.apache.hadoop.security.token.delegation
Look through tokens to find the first delegation token that matches the service and return it.
AbstractDelegationTokenSelector(Text) - Constructor for class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSelector
 
AbstractGangliaSink - Class in org.apache.hadoop.metrics2.sink.ganglia
This the base class for Ganglia sink classes using metrics2.
AbstractGangliaSink() - Constructor for class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
AbstractGangliaSink.GangliaConfType - Enum in org.apache.hadoop.metrics2.sink.ganglia
define enum for various type of conf
AbstractGangliaSink.GangliaSlope - Enum in org.apache.hadoop.metrics2.sink.ganglia
ganglia slope values which equal the ordinal
AbstractMapWritable - Class in org.apache.hadoop.io
Abstract base class for MapWritable and SortedMapWritable Unlike org.apache.nutch.crawl.MapWritable, this class allows creation of MapWritable<Writable, MapWritable> so the CLASS_TO_ID and ID_TO_CLASS maps travel with the class instead of being static.
AbstractMapWritable() - Constructor for class org.apache.hadoop.io.AbstractMapWritable
constructor.
AbstractMetricsContext - Class in org.apache.hadoop.metrics.spi
Deprecated. in favor of org.apache.hadoop.metrics2 usage.
AbstractMetricsContext() - Constructor for class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Creates a new instance of AbstractMetricsContext
AbstractMetricsContext.MetricMap - Class in org.apache.hadoop.metrics.spi
Deprecated.  
AbstractMetricsContext.TagMap - Class in org.apache.hadoop.metrics.spi
Deprecated.  
AbstractMetricsSource - Class in org.apache.hadoop.metrics2.lib
A convenient base class for writing metrics sources
AbstractMetricsSource(String, MetricMutableFactory) - Constructor for class org.apache.hadoop.metrics2.lib.AbstractMetricsSource
Construct the source with name and a mutable metrics factory
AbstractMetricsSource(String) - Constructor for class org.apache.hadoop.metrics2.lib.AbstractMetricsSource
Construct the source with a name with a default factory
accept(Path) - Method in interface org.apache.hadoop.fs.PathFilter
Tests whether or not the specified abstract pathname should be included in a pathname list.
accept(Class<?>) - Method in class org.apache.hadoop.io.serializer.JavaSerialization
 
accept(Class<?>) - Method in interface org.apache.hadoop.io.serializer.Serialization
Allows clients to test whether this Serialization supports the given class.
accept(Class<?>) - Method in class org.apache.hadoop.io.serializer.WritableSerialization
 
accept(CompositeRecordReader.JoinCollector, K) - Method in interface org.apache.hadoop.mapred.join.ComposableRecordReader
While key-value pairs from this RecordReader match the given key, register them with the JoinCollector provided.
accept(CompositeRecordReader.JoinCollector, K) - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
If key provided matches that of this Composite, give JoinCollector iterator over values it may emit.
accept(CompositeRecordReader.JoinCollector, K) - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Add an iterator to the collector at the position occupied by this RecordReader over the values in this stream paired with the key provided (ie register a stream of values from this source matching K with a collector).
accept(Path) - Method in class org.apache.hadoop.mapred.OutputLogFilter
Deprecated.  
accept(Object) - Method in interface org.apache.hadoop.mapred.SequenceFileInputFilter.Filter
filter function Decide if a record should be filtered or not
accept(Object) - Method in class org.apache.hadoop.mapred.SequenceFileInputFilter.MD5Filter
Filtering method If MD5(key) % frequency==0, return true; otherwise return false
accept(Object) - Method in class org.apache.hadoop.mapred.SequenceFileInputFilter.PercentFilter
Filtering method If record# % frequency==0, return true; otherwise return false
accept(Object) - Method in class org.apache.hadoop.mapred.SequenceFileInputFilter.RegexFilter
Filtering method If key matches the regex, return true; otherwise return false
accept(Path) - Method in class org.apache.hadoop.mapred.Utils.OutputFileUtils.OutputFilesFilter
 
accept(Path) - Method in class org.apache.hadoop.mapred.Utils.OutputFileUtils.OutputLogFilter
 
accept(Object) - Method in interface org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter.Filter
filter function Decide if a record should be filtered or not
accept(Object) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter.MD5Filter
Filtering method If MD5(key) % frequency==0, return true; otherwise return false
accept(Object) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter.PercentFilter
Filtering method If record# % frequency==0, return true; otherwise return false
accept(Object) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter.RegexFilter
Filtering method If key matches the regex, return true; otherwise return false
accepts(String) - Method in class org.apache.hadoop.metrics2.MetricsFilter
Whether to accept the name
accepts(MetricsTag) - Method in class org.apache.hadoop.metrics2.MetricsFilter
Whether to accept the tag
accepts(Iterable<MetricsTag>) - Method in class org.apache.hadoop.metrics2.MetricsFilter
Whether to accept the tags
accepts(MetricsRecord) - Method in class org.apache.hadoop.metrics2.MetricsFilter
Whether to accept the record
AccessControlException - Exception in org.apache.hadoop.fs.permission
Deprecated. Use AccessControlException instead.
AccessControlException() - Constructor for exception org.apache.hadoop.fs.permission.AccessControlException
Deprecated. Default constructor is needed for unwrapping from RemoteException.
AccessControlException(String) - Constructor for exception org.apache.hadoop.fs.permission.AccessControlException
Deprecated. Constructs an AccessControlException with the specified detail message.
AccessControlException(Throwable) - Constructor for exception org.apache.hadoop.fs.permission.AccessControlException
Deprecated. Constructs a new exception with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
AccessControlException - Exception in org.apache.hadoop.security
An exception class for access control related issues.
AccessControlException() - Constructor for exception org.apache.hadoop.security.AccessControlException
Default constructor is needed for unwrapping from RemoteException.
AccessControlException(String) - Constructor for exception org.apache.hadoop.security.AccessControlException
Constructs an AccessControlException with the specified detail message.
AccessControlException(Throwable) - Constructor for exception org.apache.hadoop.security.AccessControlException
Constructs a new exception with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
AccessControlList - Class in org.apache.hadoop.security.authorize
Class representing a configured access control list.
AccessControlList() - Constructor for class org.apache.hadoop.security.authorize.AccessControlList
This constructor exists primarily for AccessControlList to be Writable.
AccessControlList(String) - Constructor for class org.apache.hadoop.security.authorize.AccessControlList
Construct a new ACL from a String representation of the same.
activateOptions() - Method in class org.apache.hadoop.mapred.TaskLogAppender
 
activeTaskTrackers() - Method in class org.apache.hadoop.mapred.JobTracker
Get the active task tracker statuses in the cluster
add(Object) - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
 
add(Object) - Method in interface org.apache.hadoop.contrib.utils.join.ResetableIterator
 
add(X) - Method in class org.apache.hadoop.mapred.join.ArrayListBackedIterator
 
add(InputSplit) - Method in class org.apache.hadoop.mapred.join.CompositeInputSplit
Add an InputSplit to this collection.
add(ComposableRecordReader<K, ? extends V>) - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Add a RecordReader to this collection.
add(TupleWritable) - Method in class org.apache.hadoop.mapred.join.JoinRecordReader.JoinDelegationIterator
 
add(V) - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader.MultiFilterDelegationIterator
 
add(T) - Method in interface org.apache.hadoop.mapred.join.ResetableIterator
Add an element to the collection of elements to iterate over.
add(U) - Method in class org.apache.hadoop.mapred.join.ResetableIterator.EMPTY
 
add(X) - Method in class org.apache.hadoop.mapred.join.StreamBackedIterator
 
add(String, MetricsBase) - Method in class org.apache.hadoop.metrics.util.MetricsRegistry
Deprecated. Add a new metrics to the registry
add(long, long) - Method in class org.apache.hadoop.metrics2.lib.MetricMutableStat
Add a number of samples and their sum to the running stat
add(long) - Method in class org.apache.hadoop.metrics2.lib.MetricMutableStat
Add a snapshot to the metric
add(String, long) - Method in class org.apache.hadoop.metrics2.lib.MetricsRegistry
Add a value to a metric by name.
add(String, long, MetricMutableFactory) - Method in class org.apache.hadoop.metrics2.lib.MetricsRegistry
Decrement a metric by name.
add(MetricsTag) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add an immutable metrics tag object
add(Metric) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add a pre-made immutable metric object
add(double) - Method in class org.apache.hadoop.metrics2.util.SampleStat
Add a sample the running stat.
add(long, double) - Method in class org.apache.hadoop.metrics2.util.SampleStat
Add some sample and a partial sum to the running stat.
add(double) - Method in class org.apache.hadoop.metrics2.util.SampleStat.MinMax
 
add(Node) - Method in class org.apache.hadoop.net.NetworkTopology
Add a leaf node Update node counter & rack counter if neccessary
add(String, List<String>) - Method in class org.apache.hadoop.security.NetgroupCache
 
add(Key) - Method in class org.apache.hadoop.util.bloom.BloomFilter
 
add(Key) - Method in class org.apache.hadoop.util.bloom.CountingBloomFilter
 
add(Key) - Method in class org.apache.hadoop.util.bloom.DynamicBloomFilter
 
add(Key) - Method in class org.apache.hadoop.util.bloom.Filter
Adds a key to this filter.
add(List<Key>) - Method in class org.apache.hadoop.util.bloom.Filter
Adds a list of keys to this filter.
add(Collection<Key>) - Method in class org.apache.hadoop.util.bloom.Filter
Adds a collection of keys to this filter.
add(Key[]) - Method in class org.apache.hadoop.util.bloom.Filter
Adds an array of keys to this filter.
add(Key) - Method in class org.apache.hadoop.util.bloom.RetouchedBloomFilter
 
add_escapes(String) - Method in exception org.apache.hadoop.record.compiler.generated.ParseException
Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.
addAll(Credentials) - Method in class org.apache.hadoop.security.Credentials
Copy all of the credentials from one credential object into another.
addArchiveToClassPath(Path, Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Deprecated. Please use DistributedCache.addArchiveToClassPath(Path, Configuration, FileSystem) instead. The FileSystem should be obtained within an appropriate doAs.
addArchiveToClassPath(Path, Configuration, FileSystem) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add an archive path to the current set of classpath entries.
addCacheArchive(URI, Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add a archives to be localized to the conf.
addCacheFile(URI, Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add a file to be localized to the conf.
addCacheInfoUpdate(TrackerDistributedCacheManager.CacheStatus) - Method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager.BaseDirManager
Update the maps baseDirSize and baseDirNumberSubDir when adding cache.
addClass(String, Class, String) - Method in class org.apache.hadoop.util.ProgramDriver
This is the method that adds the classed to the repository
addColumn(ColumnName, boolean) - Method in class org.apache.hadoop.examples.dancing.DancingLinks
Add a column to the table
addColumn(ColumnName) - Method in class org.apache.hadoop.examples.dancing.DancingLinks
Add a column to the table
addCommand(List<String>, boolean) - Static method in class org.apache.hadoop.mapred.TaskLog
Add quotes to each of the command strings and return as a single string
addContext(Context, boolean) - Method in class org.apache.hadoop.http.HttpServer
 
addContext(String, String, boolean) - Method in class org.apache.hadoop.http.HttpServer
Add a context
addCounter(String, String, int) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add an int counter metric
addCounter(String, String, long) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add an long counter metric
addDefaultApps(ContextHandlerCollection, String) - Method in class org.apache.hadoop.http.HttpServer
Add default apps.
addDefaultResource(String) - Static method in class org.apache.hadoop.conf.Configuration
Add a default resource.
addDefaults() - Method in class org.apache.hadoop.mapred.join.CompositeInputFormat
Adds the default set of identifiers to the parser.
addDefaultServlets() - Method in class org.apache.hadoop.http.HttpServer
Add default servlets.
addDependingJob(Job) - Method in class org.apache.hadoop.mapred.jobcontrol.Job
Add a job to this jobs' dependency list.
addDependingJob(ControlledJob) - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
Add a job to this jobs' dependency list.
addDoubleValue(Object, double) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
Increment the given counter by the given incremental value If the counter does not exist, one is created with value 0.
addEscapes(String) - Static method in error org.apache.hadoop.record.compiler.generated.TokenMgrError
Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string
addFalsePositive(Key) - Method in class org.apache.hadoop.util.bloom.RetouchedBloomFilter
Adds a false positive information to this retouched Bloom filter.
addFalsePositive(Collection<Key>) - Method in class org.apache.hadoop.util.bloom.RetouchedBloomFilter
Adds a collection of false positive information to this retouched Bloom filter.
addFalsePositive(List<Key>) - Method in class org.apache.hadoop.util.bloom.RetouchedBloomFilter
Adds a list of false positive information to this retouched Bloom filter.
addFalsePositive(Key[]) - Method in class org.apache.hadoop.util.bloom.RetouchedBloomFilter
Adds an array of false positive information to this retouched Bloom filter.
addField(String, TypeID) - Method in class org.apache.hadoop.record.meta.RecordTypeInfo
Add a field.
addFileset(FileSet) - Method in class org.apache.hadoop.record.compiler.ant.RccTask
Adds a fileset that can consist of one or more files
addFileSystemForTesting(URI, Configuration, FileSystem) - Static method in class org.apache.hadoop.fs.FileSystem
This method adds a file system for testing so that we can find it later.
addFileToClassPath(Path, Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Deprecated. Please use DistributedCache.addFileToClassPath(Path, Configuration, FileSystem) instead. The FileSystem should be obtained within an appropriate doAs.
addFileToClassPath(Path, Configuration, FileSystem) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add a file path to the current set of classpath entries.
addFilter(String, String, Map<String, String>) - Method in interface org.apache.hadoop.http.FilterContainer
Add a filter to the container.
addFilter(String, String, Map<String, String>) - Method in class org.apache.hadoop.http.HttpServer
Add a filter to the container.
addFilterPathMapping(String, Context) - Method in class org.apache.hadoop.http.HttpServer
Add the path spec to the filter path mapping.
addGauge(String, String, int) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add a int gauge metric
addGauge(String, String, long) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add a long gauge metric
addGauge(String, String, float) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add a float gauge metric
addGauge(String, String, double) - Method in class org.apache.hadoop.metrics2.MetricsRecordBuilder
Add a double gauge metric
addGlobalFilter(String, String, Map<String, String>) - Method in interface org.apache.hadoop.http.FilterContainer
Add a global filter to the container.
addGlobalFilter(String, String, Map<String, String>) - Method in class org.apache.hadoop.http.HttpServer
Add a global filter to the container.
addIdentifier(String, Class<?>[], Class<? extends Parser.Node>, Class<? extends ComposableRecordReader>) - Static method in class org.apache.hadoop.mapred.join.Parser.Node
For a given identifier, add a mapping to the nodetype for the parse tree and to the ComposableRecordReader to be created, including the formals required to invoke the constructor.
addInputPath(JobConf, Path) - Static method in class org.apache.hadoop.mapred.FileInputFormat
Add a Path to the list of inputs for the map-reduce job.
addInputPath(JobConf, Path, Class<? extends InputFormat>) - Static method in class org.apache.hadoop.mapred.lib.MultipleInputs
Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
addInputPath(JobConf, Path, Class<? extends InputFormat>, Class<? extends Mapper>) - Static method in class org.apache.hadoop.mapred.lib.MultipleInputs
Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
addInputPath(Job, Path) - Static method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
Add a Path to the list of inputs for the map-reduce job.
addInputPath(Job, Path, Class<? extends InputFormat>) - Static method in class org.apache.hadoop.mapreduce.lib.input.MultipleInputs
Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
addInputPath(Job, Path, Class<? extends InputFormat>, Class<? extends Mapper>) - Static method in class org.apache.hadoop.mapreduce.lib.input.MultipleInputs
Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
addInputPaths(JobConf, String) - Static method in class org.apache.hadoop.mapred.FileInputFormat
Add the given comma separated paths to the list of inputs for the map-reduce job.
addInputPaths(Job, String) - Static method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
Add the given comma separated paths to the list of inputs for the map-reduce job.
addInternalServlet(String, String, Class<? extends HttpServlet>) - Method in class org.apache.hadoop.http.HttpServer
Deprecated. this is a temporary method
addInternalServlet(String, String, Class<? extends HttpServlet>, boolean, boolean) - Method in class org.apache.hadoop.http.HttpServer
Add an internal servlet in the server, specifying whether or not to protect with Kerberos authentication.
additionalConfSpec_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
addJerseyResourcePackage(String, String) - Method in class org.apache.hadoop.http.HttpServer
Add a Jersey resource package.
addJob(Job) - Method in class org.apache.hadoop.mapred.jobcontrol.JobControl
Add a new job.
addJob(ControlledJob) - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl
Add a new job.
addJobCollection(Collection<ControlledJob>) - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl
Add a collection of jobs
addJobInProgressListener(JobInProgressListener) - Method in class org.apache.hadoop.mapred.JobTracker
 
addJobs(Collection<Job>) - Method in class org.apache.hadoop.mapred.jobcontrol.JobControl
Add a collection of jobs
addKey(DelegationKey) - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Add a previously used master key to cache (when NN restarts), should be called before activate().
addLocalArchives(Configuration, String) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add a archive that has been localized to the conf.
addLocalFiles(Configuration, String) - Static method in class org.apache.hadoop.filecache.DistributedCache
Add a file that has been localized to the conf..
addLogEvent(UserLogEvent) - Method in class org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager
Add the UserLogEvent for processing.
addLongValue(Object, long) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
Increment the given counter by the given incremental value If the counter does not exist, one is created with value 0.
addMapper(JobConf, Class<? extends Mapper<K1, V1, K2, V2>>, Class<? extends K1>, Class<? extends V1>, Class<? extends K2>, Class<? extends V2>, boolean, JobConf) - Static method in class org.apache.hadoop.mapred.lib.ChainMapper
Adds a Mapper class to the chain job's JobConf.
addMapper(JobConf, Class<? extends Mapper<K1, V1, K2, V2>>, Class<? extends K1>, Class<? extends V1>, Class<? extends K2>, Class<? extends V2>, boolean, JobConf) - Static method in class org.apache.hadoop.mapred.lib.ChainReducer
Adds a Mapper class to the chain job's JobConf.
addMultiNamedOutput(JobConf, String, Class<? extends OutputFormat>, Class<?>, Class<?>) - Static method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Adds a multi named output for the job.
addName(Class, String) - Static method in class org.apache.hadoop.io.WritableName
Add an alternate name for a class.
addNamedOutput(JobConf, String, Class<? extends OutputFormat>, Class<?>, Class<?>) - Static method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Adds a named output for the job.
addNamedOutput(Job, String, Class<? extends OutputFormat>, Class<?>, Class<?>) - Static method in class org.apache.hadoop.mapreduce.lib.output.MultipleOutputs
Adds a named output for the job.
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.DoubleValueSum
add a value to the aggregator
addNextValue(double) - Method in class org.apache.hadoop.mapred.lib.aggregate.DoubleValueSum
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMax
add a value to the aggregator
addNextValue(long) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMax
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMin
add a value to the aggregator
addNextValue(long) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMin
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueSum
add a value to the aggregator
addNextValue(long) - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueSum
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.StringValueMax
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.StringValueMin
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.UniqValueCount
add a value to the aggregator
addNextValue(Object) - Method in interface org.apache.hadoop.mapred.lib.aggregate.ValueAggregator
add a value to the aggregator
addNextValue(Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueHistogram
add the given val to the aggregator.
addOldUserLogsForDeletion(File, Configuration) - Method in class org.apache.hadoop.mapred.UserLogCleaner
Adds the job log directories for deletion with default retain hours.
addPhase(String) - Method in class org.apache.hadoop.util.Progress
Adds a named node to the tree.
addPhase() - Method in class org.apache.hadoop.util.Progress
Adds a node to the tree.
addRecord(String) - Method in interface org.apache.hadoop.metrics2.MetricsBuilder
Add a metrics record
addResource(String) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(URL) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(Path) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addResource(InputStream) - Method in class org.apache.hadoop.conf.Configuration
Add a configuration resource.
addRow(boolean[]) - Method in class org.apache.hadoop.examples.dancing.DancingLinks
Add a row to the table.
addRpcProcessingTime(int) - Method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
Add an RPC processing time sample
addRpcProcessingTime(String, int) - Method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
Add an RPC processing time sample for a particular RPC method
addRpcProcessingTime(String, int) - Method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation.Detailed
 
addRpcQueueTime(int) - Method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
Add an RPC queue time sample
addSecretKey(Text, byte[]) - Method in class org.apache.hadoop.security.Credentials
Set the key for an alias
addServlet(String, String, Class<? extends HttpServlet>) - Method in class org.apache.hadoop.http.HttpServer
Add a servlet in the server.
addSslListener(InetSocketAddress, String, String, String) - Method in class org.apache.hadoop.http.HttpServer
Deprecated. Use HttpServer.addSslListener(InetSocketAddress, Configuration, boolean)
addSslListener(InetSocketAddress, Configuration, boolean) - Method in class org.apache.hadoop.http.HttpServer
Configure an ssl listener on the server.
addSslListener(InetSocketAddress, Configuration, boolean, boolean) - Method in class org.apache.hadoop.http.HttpServer
Configure an ssl listener on the server.
addStaticResolution(String, String) - Static method in class org.apache.hadoop.net.NetUtils
Adds a static resolution for host.
addTaskEnvironment_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
addToken(Text, Token<? extends TokenIdentifier>) - Method in class org.apache.hadoop.security.Credentials
Add a token in the storage (in memory)
addToken(Token<? extends TokenIdentifier>) - Method in class org.apache.hadoop.security.UserGroupInformation
Add a token to this UGI
addTokenForJob(String, Token<JobTokenIdentifier>) - Method in class org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager
Add the job token of a job to cache
addTokenIdentifier(TokenIdentifier) - Method in class org.apache.hadoop.security.UserGroupInformation
Add a TokenIdentifier to this UGI.
addToMap(Class) - Method in class org.apache.hadoop.io.AbstractMapWritable
Add a Class to the maps if it is not already present.
addUser(String) - Method in class org.apache.hadoop.security.authorize.AccessControlList
 
adjustBeginLineColumn(int, int) - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
Method to adjust line and column numbers for the start of a token.
adjustTop() - Method in class org.apache.hadoop.util.PriorityQueue
Should be called when the Object at top changes values.
AdminAuthorizedServlet - Class in org.apache.hadoop.http
General servlet which is admin-authorized.
AdminAuthorizedServlet() - Constructor for class org.apache.hadoop.http.AdminAuthorizedServlet
 
AdminOperationsProtocol - Interface in org.apache.hadoop.mapred
Protocol for admin operations.
advance() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner
Move the cursor to the next key-value pair.
AggregateWordCount - Class in org.apache.hadoop.examples
This is an example Aggregated Hadoop Map/Reduce application.
AggregateWordCount() - Constructor for class org.apache.hadoop.examples.AggregateWordCount
 
AggregateWordCount.WordCountPlugInClass - Class in org.apache.hadoop.examples
 
AggregateWordCount.WordCountPlugInClass() - Constructor for class org.apache.hadoop.examples.AggregateWordCount.WordCountPlugInClass
 
AggregateWordHistogram - Class in org.apache.hadoop.examples
This is an example Aggregated Hadoop Map/Reduce application.
AggregateWordHistogram() - Constructor for class org.apache.hadoop.examples.AggregateWordHistogram
 
AggregateWordHistogram.AggregateWordHistogramPlugin - Class in org.apache.hadoop.examples
 
AggregateWordHistogram.AggregateWordHistogramPlugin() - Constructor for class org.apache.hadoop.examples.AggregateWordHistogram.AggregateWordHistogramPlugin
 
aggregatorDescriptorList - Variable in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase
 
allFinished() - Method in class org.apache.hadoop.mapred.jobcontrol.JobControl
 
allFinished() - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl
 
allKeys - Variable in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Access to allKeys is protected by this object lock
allocator - Variable in class org.apache.hadoop.mapred.TaskController
 
and(FsAction) - Method in enum org.apache.hadoop.fs.permission.FsAction
AND operation.
and(Filter) - Method in class org.apache.hadoop.util.bloom.BloomFilter
 
and(Filter) - Method in class org.apache.hadoop.util.bloom.CountingBloomFilter
 
and(Filter) - Method in class org.apache.hadoop.util.bloom.DynamicBloomFilter
 
and(Filter) - Method in class org.apache.hadoop.util.bloom.Filter
Peforms a logical AND between this filter and a specified filter.
anonymize(SerializedRecord) - Static method in class org.apache.hadoop.contrib.failmon.Anonymizer
Anonymize hostnames, ip addresses and file names/paths that appear in fields of a SerializedRecord.
anonymize(EventRecord) - Static method in class org.apache.hadoop.contrib.failmon.Anonymizer
Anonymize hostnames, ip addresses and file names/paths that appear in fields of an EventRecord, after it gets serialized into a SerializedRecord.
anonymize() - Method in class org.apache.hadoop.contrib.failmon.OfflineAnonymizer
Performs anonymization for the log file.
Anonymizer - Class in org.apache.hadoop.contrib.failmon
This class provides anonymization to SerializedRecord objects.
Anonymizer() - Constructor for class org.apache.hadoop.contrib.failmon.Anonymizer
 
ANONYMOUS - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationToken
Constant that identifies an anonymous request.
ANONYMOUS_ALLOWED - Static variable in class org.apache.hadoop.security.authentication.server.PseudoAuthenticationHandler
Constant for the configuration property that indicates if anonymous users are allowed.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Append to an existing file (optional operation).
append(Path) - Method in class org.apache.hadoop.fs.FileSystem
Append to an existing file (optional operation).
append(Path, int) - Method in class org.apache.hadoop.fs.FileSystem
Append to an existing file (optional operation).
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Append to an existing file (optional operation).
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.FilterFileSystem
Append to an existing file (optional operation).
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
This optional operation is not yet supported.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
This optional operation is not yet supported.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
Append to an existing file (optional operation).
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.s3.S3FileSystem
This optional operation is not yet supported.
append(Path, int, Progressable) - Method in class org.apache.hadoop.fs.s3native.NativeS3FileSystem
This optional operation is not yet supported.
append(Writable) - Method in class org.apache.hadoop.io.ArrayFile.Writer
Append a value to the file.
append(WritableComparable, Writable) - Method in class org.apache.hadoop.io.BloomMapFile.Writer
 
append(byte[], byte[]) - Method in class org.apache.hadoop.io.file.tfile.TFile.Writer
Adding a new key-value pair to the TFile.
append(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.file.tfile.TFile.Writer
Adding a new key-value pair to TFile.
append(WritableComparable, Writable) - Method in class org.apache.hadoop.io.MapFile.Writer
Append a key/value pair to the map.
append(Writable, Writable) - Method in class org.apache.hadoop.io.SequenceFile.Writer
Append a key/value pair.
append(Object, Object) - Method in class org.apache.hadoop.io.SequenceFile.Writer
Append a key/value pair.
append(WritableComparable) - Method in class org.apache.hadoop.io.SetFile.Writer
Append a key to a set.
append(byte[], int, int) - Method in class org.apache.hadoop.io.Text
Append a range of bytes to the end of the given text
append(LoggingEvent) - Method in class org.apache.hadoop.log.metrics.EventCounter
 
append(LoggingEvent) - Method in class org.apache.hadoop.mapred.TaskLogAppender
 
append(byte[], int, int) - Method in class org.apache.hadoop.record.Buffer
Append specified bytes to the buffer.
append(byte[]) - Method in class org.apache.hadoop.record.Buffer
Append specified bytes to the buffer
appendRaw(byte[], int, int, SequenceFile.ValueBytes) - Method in class org.apache.hadoop.io.SequenceFile.Writer
 
appendTo(StringBuilder) - Method in class org.apache.hadoop.mapreduce.JobID
Add the stuff after the "job" prefix to the given builder.
appendTo(StringBuilder) - Method in class org.apache.hadoop.mapreduce.TaskAttemptID
Add the unique string to the StringBuilder
appendTo(StringBuilder) - Method in class org.apache.hadoop.mapreduce.TaskID
Add the unique string to the given builder.
applyNewPermission(FileStatus) - Method in class org.apache.hadoop.fs.permission.ChmodParser
Apply permission against specified file and determine what the new mode would be
applyUMask(FsPermission) - Method in class org.apache.hadoop.fs.permission.FsPermission
Apply a umask to this permission and return a new one
applyUMask(FsPermission) - Method in class org.apache.hadoop.fs.permission.PermissionStatus
Apply umask.
approximateCount(Key) - Method in class org.apache.hadoop.util.bloom.CountingBloomFilter
This method calculates an approximate count of the key, i.e.
archiveURIs - Variable in class org.apache.hadoop.streaming.StreamJob
 
args - Variable in class org.apache.hadoop.fs.shell.Command
 
argv_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
arrangeKeys(ArrayList<String>) - Static method in class org.apache.hadoop.contrib.failmon.SerializedRecord
Arrange the keys to provide a more readable printing order: first goes the timestamp, then the hostname and then the type, followed by all other keys found.
ArrayFile - Class in org.apache.hadoop.io
A dense file-based mapping from integers to values.
ArrayFile() - Constructor for class org.apache.hadoop.io.ArrayFile
 
ArrayFile.Reader - Class in org.apache.hadoop.io
Provide access to an existing array file.
ArrayFile.Reader(FileSystem, String, Configuration) - Constructor for class org.apache.hadoop.io.ArrayFile.Reader
Construct an array reader for the named file.
ArrayFile.Writer - Class in org.apache.hadoop.io
Write a new array file.
ArrayFile.Writer(Configuration, FileSystem, String, Class<? extends Writable>) - Constructor for class org.apache.hadoop.io.ArrayFile.Writer
Create the named file for values of the named class.
ArrayFile.Writer(Configuration, FileSystem, String, Class<? extends Writable>, SequenceFile.CompressionType, Progressable) - Constructor for class org.apache.hadoop.io.ArrayFile.Writer
Create the named file for values of the named class.
ArrayListBackedIterator - Class in org.apache.hadoop.contrib.utils.join
This class provides an implementation of ResetableIterator.
ArrayListBackedIterator() - Constructor for class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
 
ArrayListBackedIterator(ArrayList<Object>) - Constructor for class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
 
ArrayListBackedIterator<X extends Writable> - Class in org.apache.hadoop.mapred.join
This class provides an implementation of ResetableIterator.
ArrayListBackedIterator() - Constructor for class org.apache.hadoop.mapred.join.ArrayListBackedIterator
 
ArrayListBackedIterator(ArrayList<X>) - Constructor for class org.apache.hadoop.mapred.join.ArrayListBackedIterator
 
arrayToString(String[]) - Static method in class org.apache.hadoop.util.StringUtils
Given an array of strings, return a comma-separated list of its elements.
ArrayWritable - Class in org.apache.hadoop.io
A Writable for arrays containing instances of a class.
ArrayWritable(Class<? extends Writable>) - Constructor for class org.apache.hadoop.io.ArrayWritable
 
ArrayWritable(Class<? extends Writable>, Writable[]) - Constructor for class org.apache.hadoop.io.ArrayWritable
 
ArrayWritable(String[]) - Constructor for class org.apache.hadoop.io.ArrayWritable
 
atEnd() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner
Is cursor at the end location?
ATTEMPT - Static variable in class org.apache.hadoop.mapreduce.TaskAttemptID
 
attemptingUser - Variable in class org.apache.hadoop.ipc.Server.Connection
 
AUTH_COOKIE - Static variable in class org.apache.hadoop.security.authentication.client.AuthenticatedURL
Name of the HTTP cookie used for the authentication token between the client and the server.
AUTH_TOKEN_VALIDITY - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Constant for the configuration property that indicates the validity of the generated token.
AUTH_TYPE - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Constant for the property that specifies the authentication handler to use.
authenticate(URL, AuthenticatedURL.Token) - Method in interface org.apache.hadoop.security.authentication.client.Authenticator
Authenticates against a URL and returns a AuthenticatedURL.Token to be used by subsequent requests.
authenticate(URL, AuthenticatedURL.Token) - Method in class org.apache.hadoop.security.authentication.client.KerberosAuthenticator
Performs SPNEGO authentication against the specified URL.
authenticate(URL, AuthenticatedURL.Token) - Method in class org.apache.hadoop.security.authentication.client.PseudoAuthenticator
Performs simple authentication against the specified URL.
authenticate(HttpServletRequest, HttpServletResponse) - Method in interface org.apache.hadoop.security.authentication.server.AuthenticationHandler
Performs an authentication step for the given HTTP client request.
authenticate(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler
It enforces the the Kerberos SPNEGO authentication sequence returning an AuthenticationToken only after the Kerberos SPNEGO sequence has completed successfully.
authenticate(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.security.authentication.server.PseudoAuthenticationHandler
Authenticates an HTTP client request.
AuthenticatedURL - Class in org.apache.hadoop.security.authentication.client
The AuthenticatedURL class enables the use of the JDK URL class against HTTP endpoints protected with the AuthenticationFilter.
AuthenticatedURL() - Constructor for class org.apache.hadoop.security.authentication.client.AuthenticatedURL
Creates an AuthenticatedURL.
AuthenticatedURL(Authenticator) - Constructor for class org.apache.hadoop.security.authentication.client.AuthenticatedURL
Creates an AuthenticatedURL.
AuthenticatedURL.Token - Class in org.apache.hadoop.security.authentication.client
Client side authentication token.
AuthenticatedURL.Token() - Constructor for class org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token
Creates a token.
AuthenticatedURL.Token(String) - Constructor for class org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token
Creates a token using an existing string representation of the token.
AuthenticationException - Exception in org.apache.hadoop.security.authentication.client
Exception thrown when an authentication error occurrs.
AuthenticationException(Throwable) - Constructor for exception org.apache.hadoop.security.authentication.client.AuthenticationException
Creates an AuthenticationException.
AuthenticationException(String) - Constructor for exception org.apache.hadoop.security.authentication.client.AuthenticationException
Creates an AuthenticationException.
AuthenticationException(String, Throwable) - Constructor for exception org.apache.hadoop.security.authentication.client.AuthenticationException
Creates an AuthenticationException.
AuthenticationFilter - Class in org.apache.hadoop.security.authentication.server
The AuthenticationFilter enables protecting web application resources with different (pluggable) authentication mechanisms.
AuthenticationFilter() - Constructor for class org.apache.hadoop.security.authentication.server.AuthenticationFilter
 
AuthenticationFilterInitializer - Class in org.apache.hadoop.security
Initializes Alfredo AuthenticationFilter which provides support for Kerberos HTTP SPENGO authentication.
AuthenticationFilterInitializer() - Constructor for class org.apache.hadoop.security.AuthenticationFilterInitializer
 
AuthenticationHandler - Interface in org.apache.hadoop.security.authentication.server
Interface for server authentication mechanisms.
authenticationMethod - Variable in enum org.apache.hadoop.security.SaslRpcServer.AuthMethod
 
AuthenticationToken - Class in org.apache.hadoop.security.authentication.server
The AuthenticationToken contains information about an authenticated HTTP client and doubles as the Principal to be returned by authenticated HttpServletRequests

The token can be serialized/deserialized to and from a string as it is sent and received in HTTP client responses and requests as a HTTP cookie (this is done by the AuthenticationFilter).

AuthenticationToken(String, String, String) - Constructor for class org.apache.hadoop.security.authentication.server.AuthenticationToken
Creates an authentication token.
Authenticator - Interface in org.apache.hadoop.security.authentication.client
Interface for client authentication mechanisms.
AUTHORIZATION - Static variable in class org.apache.hadoop.security.authentication.client.KerberosAuthenticator
HTTP header used by the SPNEGO client endpoint during an authentication sequence.
AuthorizationException - Exception in org.apache.hadoop.security.authorize
An exception class for authorization-related issues.
AuthorizationException() - Constructor for exception org.apache.hadoop.security.authorize.AuthorizationException
 
AuthorizationException(String) - Constructor for exception org.apache.hadoop.security.authorize.AuthorizationException
 
AuthorizationException(Throwable) - Constructor for exception org.apache.hadoop.security.authorize.AuthorizationException
Constructs a new exception with the specified cause and a detail message of (cause==null ? null : cause.toString()) (which typically contains the class and detail message of cause).
authorize(UserGroupInformation, ConnectionHeader, InetAddress) - Method in class org.apache.hadoop.ipc.Server
Authorize the incoming client connection.
authorize(UserGroupInformation, String, Configuration) - Static method in class org.apache.hadoop.security.authorize.ProxyUsers
Authorize the superuser which is doing doAs
authorize(UserGroupInformation, Class<?>, Configuration, InetAddress) - Static method in class org.apache.hadoop.security.authorize.ServiceAuthorizationManager
Authorize the user to access the protocol being used.
AutoInputFormat - Class in org.apache.hadoop.streaming
An InputFormat that tries to deduce the types of the input files automatically.
AutoInputFormat() - Constructor for class org.apache.hadoop.streaming.AutoInputFormat
 
available() - Method in class org.apache.hadoop.fs.FSInputChecker
 
available() - Method in class org.apache.hadoop.io.compress.DecompressorStream
 
available() - Method in class org.apache.hadoop.security.SaslInputStream
Returns the number of bytes that can be read from this input stream without blocking.

B

backup(int) - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
BASE_OUTPUT_NAME - Static variable in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
 
baseBlockSize - Static variable in interface org.apache.hadoop.io.compress.bzip2.BZip2Constants
 
baseDirManager - Variable in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
 
baseOut - Variable in class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat
 
beginColumn - Variable in class org.apache.hadoop.record.compiler.generated.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
beginLine - Variable in class org.apache.hadoop.record.compiler.generated.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
BeginToken() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
BigDecimalSplitter - Class in org.apache.hadoop.mapreduce.lib.db
Implement DBSplitter over BigDecimal values.
BigDecimalSplitter() - Constructor for class org.apache.hadoop.mapreduce.lib.db.BigDecimalSplitter
 
BinaryComparable - Class in org.apache.hadoop.io
Interface supported by WritableComparable types supporting ordering/permutation by a representative set of bytes.
BinaryComparable() - Constructor for class org.apache.hadoop.io.BinaryComparable
 
BinaryPartitioner<V> - Class in org.apache.hadoop.mapred.lib
Partition BinaryComparable keys using a configurable part of the bytes array returned by BinaryComparable.getBytes().
BinaryPartitioner() - Constructor for class org.apache.hadoop.mapred.lib.BinaryPartitioner
 
BinaryPartitioner<V> - Class in org.apache.hadoop.mapreduce.lib.partition
Partition BinaryComparable keys using a configurable part of the bytes array returned by BinaryComparable.getBytes().
BinaryPartitioner() - Constructor for class org.apache.hadoop.mapreduce.lib.partition.BinaryPartitioner
 
BinaryRecordInput - Class in org.apache.hadoop.record
 
BinaryRecordInput(InputStream) - Constructor for class org.apache.hadoop.record.BinaryRecordInput
Creates a new instance of BinaryRecordInput
BinaryRecordInput(DataInput) - Constructor for class org.apache.hadoop.record.BinaryRecordInput
Creates a new instance of BinaryRecordInput
BinaryRecordOutput - Class in org.apache.hadoop.record
 
BinaryRecordOutput(OutputStream) - Constructor for class org.apache.hadoop.record.BinaryRecordOutput
Creates a new instance of BinaryRecordOutput
BinaryRecordOutput(DataOutput) - Constructor for class org.apache.hadoop.record.BinaryRecordOutput
Creates a new instance of BinaryRecordOutput
bind(ServerSocket, InetSocketAddress, int) - Static method in class org.apache.hadoop.ipc.Server
A convenience method to bind to a given address and report better exceptions if the address is not a valid host.
blacklistedTaskTrackers() - Method in class org.apache.hadoop.mapred.JobTracker
Get the statuses of the blacklisted task trackers in the cluster.
Block - Class in org.apache.hadoop.fs.s3
Holds metadata about a block of data being stored in a FileSystemStore.
Block(long, long) - Constructor for class org.apache.hadoop.fs.s3.Block
 
BLOCK_DELIMITER - Static variable in class org.apache.hadoop.io.compress.bzip2.CBZip2InputStream
 
BlockCompressorStream - Class in org.apache.hadoop.io.compress
A CompressorStream which works with 'block-based' based compression algorithms, as opposed to 'stream-based' compression algorithms.
BlockCompressorStream(OutputStream, Compressor, int, int) - Constructor for class org.apache.hadoop.io.compress.BlockCompressorStream
Create a BlockCompressorStream.
BlockCompressorStream(OutputStream, Compressor) - Constructor for class org.apache.hadoop.io.compress.BlockCompressorStream
Create a BlockCompressorStream with given output-stream and compressor.
BlockDecompressorStream - Class in org.apache.hadoop.io.compress
A DecompressorStream which works with 'block-based' based compression algorithms, as opposed to 'stream-based' compression algorithms.
BlockDecompressorStream(InputStream, Decompressor, int) - Constructor for class org.apache.hadoop.io.compress.BlockDecompressorStream
Create a BlockDecompressorStream.
BlockDecompressorStream(InputStream, Decompressor) - Constructor for class org.apache.hadoop.io.compress.BlockDecompressorStream
Create a BlockDecompressorStream.
BlockDecompressorStream(InputStream) - Constructor for class org.apache.hadoop.io.compress.BlockDecompressorStream
 
blockExists(long) - Method in interface org.apache.hadoop.fs.s3.FileSystemStore
 
BlockLocation - Class in org.apache.hadoop.fs
 
BlockLocation() - Constructor for class org.apache.hadoop.fs.BlockLocation
Default Constructor
BlockLocation(String[], String[], long, long) - Constructor for class org.apache.hadoop.fs.BlockLocation
Constructor with host, name, offset and length
BlockLocation(String[], String[], String[], long, long) - Constructor for class org.apache.hadoop.fs.BlockLocation
Constructor with host, name, network topology, offset and length
BLOOM_FILE_NAME - Static variable in class org.apache.hadoop.io.BloomMapFile
 
BloomFilter - Class in org.apache.hadoop.util.bloom
Implements a Bloom filter, as defined by Bloom in 1970.
BloomFilter() - Constructor for class org.apache.hadoop.util.bloom.BloomFilter
Default constructor - use with readFields
BloomFilter(int, int, int) - Constructor for class org.apache.hadoop.util.bloom.BloomFilter
Constructor
BloomMapFile - Class in org.apache.hadoop.io
This class extends MapFile and provides very much the same functionality.
BloomMapFile() - Constructor for class org.apache.hadoop.io.BloomMapFile
 
BloomMapFile.Reader - Class in org.apache.hadoop.io
 
BloomMapFile.Reader(FileSystem, String, Configuration) - Constructor for class org.apache.hadoop.io.BloomMapFile.Reader
 
BloomMapFile.Reader(FileSystem, String, WritableComparator, Configuration, boolean) - Constructor for class org.apache.hadoop.io.BloomMapFile.Reader
 
BloomMapFile.Reader(FileSystem, String, WritableComparator, Configuration) - Constructor for class org.apache.hadoop.io.BloomMapFile.Reader
 
BloomMapFile.Writer - Class in org.apache.hadoop.io
 
BloomMapFile.Writer(Configuration, FileSystem, String, Class<? extends WritableComparable>, Class<? extends Writable>, SequenceFile.CompressionType, CompressionCodec, Progressable) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, Class<? extends WritableComparable>, Class, SequenceFile.CompressionType, Progressable) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, Class<? extends WritableComparable>, Class, SequenceFile.CompressionType) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, WritableComparator, Class, SequenceFile.CompressionType, CompressionCodec, Progressable) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, WritableComparator, Class, SequenceFile.CompressionType, Progressable) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, WritableComparator, Class, SequenceFile.CompressionType) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, WritableComparator, Class) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BloomMapFile.Writer(Configuration, FileSystem, String, Class<? extends WritableComparable>, Class) - Constructor for class org.apache.hadoop.io.BloomMapFile.Writer
 
BOOL - Static variable in class org.apache.hadoop.record.meta.TypeID.RIOType
 
BOOLEAN_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
BooleanSplitter - Class in org.apache.hadoop.mapreduce.lib.db
Implement DBSplitter over boolean values.
BooleanSplitter() - Constructor for class org.apache.hadoop.mapreduce.lib.db.BooleanSplitter
 
BooleanWritable - Class in org.apache.hadoop.io
A WritableComparable for booleans.
BooleanWritable() - Constructor for class org.apache.hadoop.io.BooleanWritable
 
BooleanWritable(boolean) - Constructor for class org.apache.hadoop.io.BooleanWritable
 
BooleanWritable.Comparator - Class in org.apache.hadoop.io
A Comparator optimized for BooleanWritable.
BooleanWritable.Comparator() - Constructor for class org.apache.hadoop.io.BooleanWritable.Comparator
 
BoolTypeID - Static variable in class org.apache.hadoop.record.meta.TypeID
Constant classes for the basic types, so we can share them.
bufcolumn - Variable in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
buffer - Variable in class org.apache.hadoop.io.compress.CompressorStream
 
buffer - Variable in class org.apache.hadoop.io.compress.DecompressorStream
 
buffer() - Method in class org.apache.hadoop.io.file.tfile.ByteArray
 
buffer() - Method in interface org.apache.hadoop.io.file.tfile.RawComparable
Get the underlying byte array.
buffer - Variable in class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated.  
Buffer - Class in org.apache.hadoop.record
A byte sequence that is used as a Java native type for buffer.
Buffer() - Constructor for class org.apache.hadoop.record.Buffer
Create a zero-count sequence.
Buffer(byte[]) - Constructor for class org.apache.hadoop.record.Buffer
Create a Buffer using the byte array as the initial value.
Buffer(byte[], int, int) - Constructor for class org.apache.hadoop.record.Buffer
Create a Buffer using the byte range as the initial value.
buffer - Variable in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
BUFFER - Static variable in class org.apache.hadoop.record.meta.TypeID.RIOType
 
BUFFER_SIZE - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
BUFFER_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
BufferedFSInputStream - Class in org.apache.hadoop.fs
A class optimizes reading from FSInputStream by bufferring
BufferedFSInputStream(FSInputStream, int) - Constructor for class org.apache.hadoop.fs.BufferedFSInputStream
Creates a BufferedFSInputStream with the specified buffer size, and saves its argument, the input stream in, for later use.
BufferTypeID - Static variable in class org.apache.hadoop.record.meta.TypeID
 
bufline - Variable in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
bufpos - Variable in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
buildDTServiceName(URI, int) - Static method in class org.apache.hadoop.security.SecurityUtil
create the service name for a Delegation token
buildMsgFrom(URL) - Static method in class org.apache.hadoop.mapreduce.security.SecureShuffleUtils
Shuffle specific utils - build string for encoding from URL
buildMsgFrom(HttpServletRequest) - Static method in class org.apache.hadoop.mapreduce.security.SecureShuffleUtils
Shuffle specific utils - build string for encoding from URL
buildTokenService(InetSocketAddress) - Static method in class org.apache.hadoop.security.SecurityUtil
Construct the service key for a token
BuiltInGzipDecompressor - Class in org.apache.hadoop.io.compress.zlib
A Decompressor based on the popular gzip compressed file format.
BuiltInGzipDecompressor() - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInGzipDecompressor
Creates a new (pure Java) gzip decompressor.
BuiltInZlibDeflater - Class in org.apache.hadoop.io.compress.zlib
A wrapper around java.util.zip.Deflater to make it conform to org.apache.hadoop.io.compress.Compressor interface.
BuiltInZlibDeflater(int, boolean) - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInZlibDeflater
 
BuiltInZlibDeflater(int) - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInZlibDeflater
 
BuiltInZlibDeflater() - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInZlibDeflater
 
BuiltInZlibInflater - Class in org.apache.hadoop.io.compress.zlib
A wrapper around java.util.zip.Inflater to make it conform to org.apache.hadoop.io.compress.Decompressor interface.
BuiltInZlibInflater(boolean) - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInZlibInflater
 
BuiltInZlibInflater() - Constructor for class org.apache.hadoop.io.compress.zlib.BuiltInZlibInflater
 
BYTE - Static variable in class org.apache.hadoop.record.meta.TypeID.RIOType
 
BYTE_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
ByteArray - Class in org.apache.hadoop.io.file.tfile
Adaptor class to wrap byte-array backed objects (including java byte array) as RawComparable objects.
ByteArray(BytesWritable) - Constructor for class org.apache.hadoop.io.file.tfile.ByteArray
Constructing a ByteArray from a BytesWritable.
ByteArray(byte[]) - Constructor for class org.apache.hadoop.io.file.tfile.ByteArray
Wrap a whole byte array as a RawComparable.
ByteArray(byte[], int, int) - Constructor for class org.apache.hadoop.io.file.tfile.ByteArray
Wrap a partial byte array as a RawComparable.
byteDesc(long) - Static method in class org.apache.hadoop.fs.FsShell
Deprecated. Consider using StringUtils.byteDesc(long) instead.
byteDesc(long) - Static method in class org.apache.hadoop.util.StringUtils
Return an abbreviated English-language desc of the byte length
bytesToCodePoint(ByteBuffer) - Static method in class org.apache.hadoop.io.Text
Returns the next code point at the current position in the buffer.
BytesWritable - Class in org.apache.hadoop.io
A byte sequence that is usable as a key or value.
BytesWritable() - Constructor for class org.apache.hadoop.io.BytesWritable
Create a zero-size sequence.
BytesWritable(byte[]) - Constructor for class org.apache.hadoop.io.BytesWritable
Create a BytesWritable using the byte array as the initial value.
BytesWritable.Comparator - Class in org.apache.hadoop.io
A Comparator optimized for BytesWritable.
BytesWritable.Comparator() - Constructor for class org.apache.hadoop.io.BytesWritable.Comparator
 
byteToHexString(byte[], int, int) - Static method in class org.apache.hadoop.util.StringUtils
Given an array of bytes it will convert the bytes to a hex string representation of the bytes
byteToHexString(byte[]) - Static method in class org.apache.hadoop.util.StringUtils
Same as byteToHexString(bytes, 0, bytes.length).
ByteTypeID - Static variable in class org.apache.hadoop.record.meta.TypeID
 
ByteWritable - Class in org.apache.hadoop.io
A WritableComparable for a single byte.
ByteWritable() - Constructor for class org.apache.hadoop.io.ByteWritable
 
ByteWritable(byte) - Constructor for class org.apache.hadoop.io.ByteWritable
 
ByteWritable.Comparator - Class in org.apache.hadoop.io
A Comparator optimized for ByteWritable.
ByteWritable.Comparator() - Constructor for class org.apache.hadoop.io.ByteWritable.Comparator
 
BZip2Codec - Class in org.apache.hadoop.io.compress
This class provides CompressionOutputStream and CompressionInputStream for compression and decompression.
BZip2Codec() - Constructor for class org.apache.hadoop.io.compress.BZip2Codec
Creates a new instance of BZip2Codec
BZip2Constants - Interface in org.apache.hadoop.io.compress.bzip2
Base class for both the compress and decompress classes.
BZip2DummyCompressor - Class in org.apache.hadoop.io.compress.bzip2
This is a dummy compressor for BZip2.
BZip2DummyCompressor() - Constructor for class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
BZip2DummyDecompressor - Class in org.apache.hadoop.io.compress.bzip2
This is a dummy decompressor for BZip2.
BZip2DummyDecompressor() - Constructor for class org.apache.hadoop.io.compress.bzip2.BZip2DummyDecompressor
 

C

CACHE_ARCHIVES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_ARCHIVES is not a *public* constant.
CACHE_ARCHIVES_SIZES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_ARCHIVES_SIZES is not a *public* constant.
CACHE_ARCHIVES_TIMESTAMPS - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_ARCHIVES_TIMESTAMPS is not a *public* constant.
CACHE_ARCHIVES_VISIBILITIES - Static variable in class org.apache.hadoop.mapreduce.JobContext
 
CACHE_FILE_VISIBILITIES - Static variable in class org.apache.hadoop.mapreduce.JobContext
 
CACHE_FILES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_FILES is not a *public* constant.
CACHE_FILES_SIZES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_FILES_SIZES is not a *public* constant.
CACHE_FILES_TIMESTAMPS - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_FILES_TIMESTAMPS is not a *public* constant.
CACHE_LOCALARCHIVES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_LOCALARCHIVES is not a *public* constant.
CACHE_LOCALFILES - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_LOCALFILES is not a *public* constant.
CACHE_SYMLINK - Static variable in class org.apache.hadoop.filecache.DistributedCache
Warning: DistributedCache.CACHE_SYMLINK is not a *public* constant.
cacheArchives - Variable in class org.apache.hadoop.streaming.StreamJob
 
CachedDNSToSwitchMapping - Class in org.apache.hadoop.net
A cached implementation of DNSToSwitchMapping that takes an raw DNSToSwitchMapping and stores the resolved network location in a cache.
CachedDNSToSwitchMapping(DNSToSwitchMapping) - Constructor for class org.apache.hadoop.net.CachedDNSToSwitchMapping
 
cacheFiles - Variable in class org.apache.hadoop.streaming.StreamJob
 
cacheGroupsAdd(List<String>) - Method in class org.apache.hadoop.security.Groups
 
cacheGroupsAdd(List<String>) - Method in class org.apache.hadoop.security.JniBasedUnixGroupsMapping
 
cacheGroupsAdd(List<String>) - Method in class org.apache.hadoop.security.JniBasedUnixGroupsNetgroupMapping
 
cacheGroupsAdd(List<String>) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsMapping
 
cacheGroupsAdd(List<String>) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
cacheGroupsRefresh() - Method in class org.apache.hadoop.security.JniBasedUnixGroupsMapping
 
cacheGroupsRefresh() - Method in class org.apache.hadoop.security.JniBasedUnixGroupsNetgroupMapping
 
cacheGroupsRefresh() - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsMapping
 
cacheGroupsRefresh() - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
cacheNetgroup(String) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
call(Writable, InetSocketAddress) - Method in class org.apache.hadoop.ipc.Client
Deprecated. Use Client.call(Writable, ConnectionId) instead
call(Writable, InetSocketAddress, UserGroupInformation) - Method in class org.apache.hadoop.ipc.Client
Deprecated. Use Client.call(Writable, ConnectionId) instead
call(Writable, InetSocketAddress, Class<?>, UserGroupInformation, int) - Method in class org.apache.hadoop.ipc.Client
Deprecated. Use Client.call(Writable, ConnectionId) instead
call(Writable, InetSocketAddress, Class<?>, UserGroupInformation, int, Configuration) - Method in class org.apache.hadoop.ipc.Client
Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials, rpcTimeout as timeout and conf as configuration for this connection, returning the value.
call(Writable, Client.ConnectionId) - Method in class org.apache.hadoop.ipc.Client
Make a call, passing param, to the IPC server defined by remoteId, returning the value.
call(Writable[], InetSocketAddress[]) - Method in class org.apache.hadoop.ipc.Client
Deprecated. Use Client.call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead
call(Writable[], InetSocketAddress[], Class<?>, UserGroupInformation) - Method in class org.apache.hadoop.ipc.Client
Deprecated. Use Client.call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead
call(Writable[], InetSocketAddress[], Class<?>, UserGroupInformation, Configuration) - Method in class org.apache.hadoop.ipc.Client
Makes a set of calls in parallel.
call(Method, Object[][], InetSocketAddress[], Configuration) - Static method in class org.apache.hadoop.ipc.RPC
Deprecated. Use RPC.call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration) instead
call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration) - Static method in class org.apache.hadoop.ipc.RPC
Expert: Make multiple, parallel calls to a set of servers.
call(Class<?>, Writable, long) - Method in class org.apache.hadoop.ipc.RPC.Server
 
call(Writable, long) - Method in class org.apache.hadoop.ipc.Server
Deprecated. Use Server.call(Class, Writable, long) instead
call(Class<?>, Writable, long) - Method in class org.apache.hadoop.ipc.Server
Called for each call.
camelize(String) - Static method in class org.apache.hadoop.util.StringUtils
Convert SOME_STUFF to SomeStuff
cancel() - Method in interface org.apache.hadoop.io.ReadaheadPool.ReadaheadRequest
Cancels the request for readahead.
cancel(Token<?>, Configuration) - Method in class org.apache.hadoop.mapred.JobClient.Renewer
 
cancel(Configuration) - Method in class org.apache.hadoop.security.token.Token
Cancel this delegation token
cancel(Token<?>, Configuration) - Method in class org.apache.hadoop.security.token.Token.TrivialRenewer
 
cancel(Token<?>, Configuration) - Method in class org.apache.hadoop.security.token.TokenRenewer
Cancel the given token
cancelAllReservations() - Method in class org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker
Cleanup when the TaskTracker is declared as 'lost/blacklisted' by the JobTracker.
cancelDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.hadoop.mapred.JobClient
Cancel a delegation token from the JobTracker
cancelDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.hadoop.mapred.JobTracker
Discard a current delegation token.
cancelToken(Token<TokenIdent>, String) - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Cancel a token by removing it from cache.
canCommit(TaskAttemptID, JvmContext) - Method in class org.apache.hadoop.mapred.TaskTracker
Child checking whether it can commit
canCommit(TaskAttemptID, JvmContext) - Method in interface org.apache.hadoop.mapred.TaskUmbilicalProtocol
Polling to know whether the task can go-ahead with commit
capitalize(String) - Static method in class org.apache.hadoop.util.StringUtils
Capitalize a word
captureDebugOut(List<String>, File) - Static method in class org.apache.hadoop.mapred.TaskLog
Wrap a command in a shell to capture debug script's stdout and stderr to debugout.
captureOutAndError(List<String>, File, File, long) - Static method in class org.apache.hadoop.mapred.TaskLog
Wrap a command in a shell to capture stdout and stderr to files.
captureOutAndError(List<String>, List<String>, File, File, long) - Static method in class org.apache.hadoop.mapred.TaskLog
Wrap a command in a shell to capture stdout and stderr to files.
captureOutAndError(List<String>, List<String>, File, File, long, String) - Static method in class org.apache.hadoop.mapred.TaskLog
Deprecated. pidFiles are no more used. Instead pid is exported to env variable JVM_PID.
captureOutAndError(List<String>, List<String>, File, File, long, boolean, String) - Static method in class org.apache.hadoop.mapred.TaskLog
Deprecated. pidFiles are no more used. Instead pid is exported to env variable JVM_PID.
captureOutAndError(List<String>, List<String>, File, File, long, boolean) - Static method in class org.apache.hadoop.mapred.TaskLog
Wrap a command in a shell to capture stdout and stderr to files.
CBZip2InputStream - Class in org.apache.hadoop.io.compress.bzip2
An input stream that decompresses from the BZip2 format (without the file header chars) to be read as any other stream.
CBZip2InputStream(InputStream, SplittableCompressionCodec.READ_MODE) - Constructor for class org.apache.hadoop.io.compress.bzip2.CBZip2InputStream
Constructs a new CBZip2InputStream which decompresses bytes read from the specified stream.
CBZip2InputStream(InputStream) - Constructor for class org.apache.hadoop.io.compress.bzip2.CBZip2InputStream
 
CBZip2InputStream.STATE - Enum in org.apache.hadoop.io.compress.bzip2
A state machine to keep track of current state of the de-coder
CBZip2OutputStream - Class in org.apache.hadoop.io.compress.bzip2
An output stream that compresses into the BZip2 format (without the file header chars) into another stream.
CBZip2OutputStream(OutputStream) - Constructor for class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
Constructs a new CBZip2OutputStream with a blocksize of 900k.
CBZip2OutputStream(OutputStream, int) - Constructor for class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
Constructs a new CBZip2OutputStream with specified blocksize.
ChainMapper - Class in org.apache.hadoop.mapred.lib
The ChainMapper class allows to use multiple Mapper classes within a single Map task.
ChainMapper() - Constructor for class org.apache.hadoop.mapred.lib.ChainMapper
Constructor.
ChainReducer - Class in org.apache.hadoop.mapred.lib
The ChainReducer class allows to chain multiple Mapper classes after a Reducer within the Reducer task.
ChainReducer() - Constructor for class org.apache.hadoop.mapred.lib.ChainReducer
Constructor.
changed() - Method in class org.apache.hadoop.metrics2.lib.MetricMutable
 
charAt(int) - Method in class org.apache.hadoop.io.Text
Returns the Unicode Scalar Value (32-bit integer value) for the character at position.
checkArg(T, boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check an argument for false conditions
checkArg(int, boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check an argument for false conditions
checkArg(long, boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check an argument for false conditions
checkArg(float, boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check an argument for false conditions
checkArg(double, boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check an argument for false conditions
checkDir(File) - Static method in class org.apache.hadoop.util.DiskChecker
Create the directory if it doesn't exist and
checkDir(LocalFileSystem, Path, FsPermission) - Static method in class org.apache.hadoop.util.DiskChecker
Create the local directory if necessary, check permissions and also ensure it can be read from and written into.
checkException(IOException) - Method in class org.apache.hadoop.mapred.ShuffleExceptionTracker
Parse the exception to see if it matches the regular expression you configured.
checkExistence(String) - Static method in class org.apache.hadoop.contrib.failmon.Environment
Checks whether a specific shell command is available in the system.
checkForRotation() - Method in class org.apache.hadoop.contrib.failmon.LogParser
Check whether the log file has been rotated.
checkNotNull(T, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check that a reference is not null.
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.hadoop.mapred.FileOutputFormat
 
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.hadoop.mapred.lib.db.DBOutputFormat
Check for validity of the output-specification for the job.
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.hadoop.mapred.lib.NullOutputFormat
 
checkOutputSpecs(FileSystem, JobConf) - Method in interface org.apache.hadoop.mapred.OutputFormat
Check for validity of the output-specification for the job.
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.hadoop.mapred.SequenceFileAsBinaryOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.LazyOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.NullOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.SequenceFileAsBinaryOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.mapreduce.OutputFormat
Check for validity of the output-specification for the job.
checkPath(Path) - Method in class org.apache.hadoop.fs.FileSystem
Check that a Path belongs to this FileSystem.
checkPath(Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
Check that a Path belongs to this FileSystem.
checkpoint() - Method in class org.apache.hadoop.fs.Trash
Create a trash checkpoint.
checkRestart() - Method in class org.apache.hadoop.util.QueueProcessingStatistics
 
checkState(boolean, Object) - Static method in class org.apache.hadoop.metrics2.util.Contracts
Check the state expression for false conditions
checkStream() - Method in class org.apache.hadoop.io.compress.DecompressorStream
 
checksum2long(byte[]) - Static method in class org.apache.hadoop.fs.FSInputChecker
Convert a checksum byte array to a long
CHECKSUM_CRC32 - Static variable in class org.apache.hadoop.util.DataChecksum
 
CHECKSUM_NULL - Static variable in class org.apache.hadoop.util.DataChecksum
 
ChecksumException - Exception in org.apache.hadoop.fs
Thrown for checksum errors.
ChecksumException(String, long) - Constructor for exception org.apache.hadoop.fs.ChecksumException
 
ChecksumFileSystem - Class in org.apache.hadoop.fs
Abstract Checksumed FileSystem.
ChecksumFileSystem(FileSystem) - Constructor for class org.apache.hadoop.fs.ChecksumFileSystem
 
ChecksumUtil - Class in org.apache.hadoop.util
 
ChecksumUtil() - Constructor for class org.apache.hadoop.util.ChecksumUtil
 
checkTGTAndReloginFromKeytab() - Method in class org.apache.hadoop.security.UserGroupInformation
Re-login a user from keytab if TGT is expired or is close to expiry.
checkURIs(URI[], URI[]) - Static method in class org.apache.hadoop.filecache.DistributedCache
This method checks if there is a conflict in the fragment names of the uris.
chmod(String, String) - Static method in class org.apache.hadoop.fs.FileUtil
Change the permissions on a filename.
chmod(String, String, boolean) - Static method in class org.apache.hadoop.fs.FileUtil
Change the permissions on a file / directory, recursively, if needed.
chmod(String, int) - Static method in class org.apache.hadoop.io.nativeio.NativeIO
Wrapper around chmod(2)
ChmodParser - Class in org.apache.hadoop.fs.permission
Parse a permission mode passed in from a chmod command and apply that mode against an existing file.
ChmodParser(String) - Constructor for class org.apache.hadoop.fs.permission.ChmodParser
 
chooseBlockSize(long) - Static method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
Chooses a blocksize based on the given length of the data to compress.
chooseRandom(String) - Method in class org.apache.hadoop.net.NetworkTopology
randomly choose one node from scope if scope starts with ~, choose one from the all nodes except for the ones in scope; otherwise, choose one from scope
chooseShardForDelete(DocumentID) - Method in class org.apache.hadoop.contrib.index.example.HashingDistributionPolicy
 
chooseShardForDelete(DocumentID) - Method in class org.apache.hadoop.contrib.index.example.RoundRobinDistributionPolicy
 
chooseShardForDelete(DocumentID) - Method in interface org.apache.hadoop.contrib.index.mapred.IDistributionPolicy
Choose a shard or all shards to send a delete request.
chooseShardForInsert(DocumentID) - Method in class org.apache.hadoop.contrib.index.example.HashingDistributionPolicy
 
chooseShardForInsert(DocumentID) - Method in class org.apache.hadoop.contrib.index.example.RoundRobinDistributionPolicy
 
chooseShardForInsert(DocumentID) - Method in interface org.apache.hadoop.contrib.index.mapred.IDistributionPolicy
Choose a shard to send an insert request.
cleanup() - Method in class org.apache.hadoop.contrib.failmon.Executor
 
cleanup() - Method in class org.apache.hadoop.contrib.failmon.RunOnce
 
cleanup(Log, Closeable...) - Static method in class org.apache.hadoop.io.IOUtils
Close the Closeable objects and ignore any IOException or null pointers.
cleanup() - Method in class org.apache.hadoop.io.SequenceFile.Sorter.SegmentDescriptor
The default cleanup.
cleanup(Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>.Context) - Method in class org.apache.hadoop.mapreduce.Mapper
Called once at the end of the task.
cleanup(Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT>.Context) - Method in class org.apache.hadoop.mapreduce.Reducer
Called once at the end of the task.
cleanupJob(JobContext) - Method in class org.apache.hadoop.mapred.FileOutputCommitter
Deprecated. 
cleanupJob(JobContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
Deprecated. use OutputCommitter.commitJob(JobContext) or OutputCommitter.abortJob(JobContext, int) instead
cleanupJob(JobContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
Deprecated. 
cleanupJob(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Deprecated. 
cleanupJob(JobContext) - Method in class org.apache.hadoop.mapreduce.OutputCommitter
Deprecated. use OutputCommitter.commitJob(JobContext) or OutputCommitter.abortJob(JobContext, JobStatus.State) instead
cleanUpMetrics() - Method in class org.apache.hadoop.mapred.JobInProgress
Called when the job is complete
cleanupProgress() - Method in class org.apache.hadoop.mapred.JobStatus
 
cleanupProgress() - Method in interface org.apache.hadoop.mapred.RunningJob
Get the progress of the job's cleanup-tasks, as a float between 0.0 and 1.0.
cleanupStorage() - Method in class org.apache.hadoop.mapred.TaskTracker
Removes all contents of temporary storage.
cleanupThread - Variable in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
 
clear() - Method in class org.apache.hadoop.conf.Configuration
Clears all keys from the configuration.
clear() - Method in class org.apache.hadoop.fs.HardLink.LinkStats
 
clear() - Method in class org.apache.hadoop.io.MapWritable
clear() - Method in class org.apache.hadoop.io.SortedMapWritable
clear() - Method in class org.apache.hadoop.io.Text
Clear the string to empty.
clear() - Method in class org.apache.hadoop.mapred.join.ArrayListBackedIterator
 
clear() - Method in class org.apache.hadoop.mapred.join.JoinRecordReader.JoinDelegationIterator
 
clear() - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader.MultiFilterDelegationIterator
 
clear() - Method in interface org.apache.hadoop.mapred.join.ResetableIterator
Close datasources, but do not release internal resources.
clear() - Method in class org.apache.hadoop.mapred.join.ResetableIterator.EMPTY
 
clear() - Method in class org.apache.hadoop.mapred.join.StreamBackedIterator
 
clear() - Method in class org.apache.hadoop.security.NetgroupCache
 
clear() - Method in class org.apache.hadoop.util.bloom.HashFunction
Clears this hash function.
clear() - Method in class org.apache.hadoop.util.PriorityQueue
Removes all entries from the PriorityQueue.
clearChanged() - Method in class org.apache.hadoop.metrics2.lib.MetricMutable
Clear the changed flag in the snapshot operations
CLEARMASK - Static variable in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
This constant is accessible by subclasses for historical purposes.
clearOldUserLogs(Configuration) - Method in class org.apache.hadoop.mapred.UserLogCleaner
Clears all the logs in userlogs directory.
clearOldUserLogs(Configuration) - Method in class org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogManager
Called during TaskTracker restart/re-init.
clearStatistics() - Static method in class org.apache.hadoop.fs.FileSystem
 
Client - Class in org.apache.hadoop.ipc
A client for an IPC service.
Client(Class<? extends Writable>, Configuration, SocketFactory) - Constructor for class org.apache.hadoop.ipc.Client
Construct an IPC client whose values are of the given Writable class.
Client(Class<? extends Writable>, Configuration) - Constructor for class org.apache.hadoop.ipc.Client
Construct an IPC client with the default SocketFactory
ClientTraceLog - Static variable in class org.apache.hadoop.mapred.TaskTracker
 
clone(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
 
clone(T, Configuration) - Static method in class org.apache.hadoop.io.WritableUtils
Make a copy of a writable object using serialization to a buffer.
clone() - Method in class org.apache.hadoop.mapred.JobStatus
 
clone() - Method in class org.apache.hadoop.mapred.TaskStatus
 
clone() - Method in class org.apache.hadoop.record.Buffer
 
cloneFileAttributes(Path, Path, Progressable) - Method in class org.apache.hadoop.io.SequenceFile.Sorter
Clones the attributes (like compression of the input file and creates a corresponding Writer
cloneInto(Writable, Writable) - Static method in class org.apache.hadoop.io.WritableUtils
Deprecated. use ReflectionUtils.cloneInto instead.
cloneWritableInto(Writable, Writable) - Static method in class org.apache.hadoop.util.ReflectionUtils
Deprecated. 
close() - Method in class org.apache.hadoop.contrib.failmon.LocalStore
Close the temporary local file
close() - Method in class org.apache.hadoop.contrib.index.example.IdentityLocalAnalysis
 
close() - Method in class org.apache.hadoop.contrib.index.example.LineDocLocalAnalysis
 
close() - Method in class org.apache.hadoop.contrib.index.example.LineDocRecordReader
 
close() - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
close() - Method in class org.apache.hadoop.contrib.index.lucene.ShardWriter
Close the shard writer.
close() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateCombiner
 
close() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateMapper
 
close() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateReducer
 
close() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
 
close() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
 
close() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
 
close() - Method in interface org.apache.hadoop.contrib.utils.join.ResetableIterator
 
close() - Method in class org.apache.hadoop.examples.MultiFileWordCount.MultiFileLineRecordReader
 
close() - Method in class org.apache.hadoop.examples.PiEstimator.PiReducer
Reduce task done, write output to a file.
close() - Method in class org.apache.hadoop.examples.SleepJob
 
close() - Method in class org.apache.hadoop.fs.FileSystem
No more filesystem operations are needed.
close() - Method in class org.apache.hadoop.fs.FilterFileSystem
 
close() - Method in class org.apache.hadoop.fs.FSDataOutputStream
 
close() - Method in class org.apache.hadoop.fs.FsShell
 
close() - Method in class org.apache.hadoop.fs.ftp.FTPInputStream
 
close() - Method in class org.apache.hadoop.fs.HarFileSystem
 
close() - Method in class org.apache.hadoop.fs.RawLocalFileSystem
 
close() - Method in class org.apache.hadoop.io.BloomMapFile.Writer
 
close() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2InputStream
 
close() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
 
close() - Method in class org.apache.hadoop.io.compress.CompressionInputStream
 
close() - Method in class org.apache.hadoop.io.compress.CompressionOutputStream
 
close() - Method in class org.apache.hadoop.io.compress.CompressorStream
 
close() - Method in class org.apache.hadoop.io.compress.DecompressorStream
 
close() - Method in class org.apache.hadoop.io.compress.GzipCodec.GzipOutputStream
 
close() - Method in class org.apache.hadoop.io.DefaultStringifier
 
close() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Close the reader.
close() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner
Close the scanner.
close() - Method in class org.apache.hadoop.io.file.tfile.TFile.Writer
Close the Writer.
close() - Method in class org.apache.hadoop.io.MapFile.Reader
Close the map.
close() - Method in class org.apache.hadoop.io.MapFile.Writer
Close the map.
close() - Method in class org.apache.hadoop.io.SequenceFile.Reader
Close the file.
close() - Method in interface org.apache.hadoop.io.SequenceFile.Sorter.RawKeyValueIterator
closes the iterator so that the underlying streams can be closed
close() - Method in class org.apache.hadoop.io.SequenceFile.Writer
Close the file.
close() - Method in interface org.apache.hadoop.io.serializer.Deserializer
Close the underlying input stream and clear up any resources.
close() - Method in interface org.apache.hadoop.io.serializer.Serializer
Close the underlying output stream and clear up any resources.
close() - Method in interface org.apache.hadoop.io.Stringifier
Closes this object.
close() - Method in class org.apache.hadoop.log.metrics.EventCounter
 
close() - Method in class org.apache.hadoop.mapred.JobClient
Close the JobClient.
close() - Method in class org.apache.hadoop.mapred.join.ArrayListBackedIterator
 
close() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Close all child RRs.
close() - Method in class org.apache.hadoop.mapred.join.JoinRecordReader.JoinDelegationIterator
 
close() - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader.MultiFilterDelegationIterator
 
close() - Method in interface org.apache.hadoop.mapred.join.ResetableIterator
Close datasources and release resources.
close() - Method in class org.apache.hadoop.mapred.join.ResetableIterator.EMPTY
 
close() - Method in class org.apache.hadoop.mapred.join.StreamBackedIterator
 
close() - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Forward close request to proxied RR.
close() - Method in class org.apache.hadoop.mapred.KeyValueLineRecordReader
 
close() - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorCombiner
Do nothing.
close() - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase
 
close() - Method in class org.apache.hadoop.mapred.lib.ChainMapper
Closes the ChainMapper and all the Mappers in the chain.
close() - Method in class org.apache.hadoop.mapred.lib.ChainReducer
Closes the ChainReducer, the Reducer and all the Mappers in the chain.
close() - Method in class org.apache.hadoop.mapred.lib.CombineFileRecordReader
 
close() - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBRecordReader
Close this InputSplit to future operations.
close(Reporter) - Method in class org.apache.hadoop.mapred.lib.db.DBOutputFormat.DBRecordWriter
Close this RecordWriter to future operations.
close() - Method in class org.apache.hadoop.mapred.lib.DelegatingMapper
 
close() - Method in class org.apache.hadoop.mapred.lib.FieldSelectionMapReduce
 
close() - Method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Closes all the opened named outputs.
close() - Method in class org.apache.hadoop.mapred.LineRecordReader
 
close() - Method in class org.apache.hadoop.mapred.MapReduceBase
Default implementation that does nothing.
close() - Method in interface org.apache.hadoop.mapred.RawKeyValueIterator
Closes the iterator so that the underlying streams can be closed.
close() - Method in interface org.apache.hadoop.mapred.RecordReader
Close this InputSplit to future operations.
close(Reporter) - Method in interface org.apache.hadoop.mapred.RecordWriter
Close this RecordWriter to future operations.
close() - Method in class org.apache.hadoop.mapred.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
close() - Method in class org.apache.hadoop.mapred.SequenceFileAsTextRecordReader
 
close() - Method in class org.apache.hadoop.mapred.SequenceFileRecordReader
 
close() - Method in class org.apache.hadoop.mapred.TaskLogAppender
 
close() - Method in class org.apache.hadoop.mapred.TaskTracker
Close down the TaskTracker and all its components.
close(Reporter) - Method in class org.apache.hadoop.mapred.TextOutputFormat.LineRecordWriter
 
close(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter
Close this RecordWriter to future operations.
close() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
Close the record reader.
close() - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.DelegatingRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.KeyValueLineRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.LineRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsTextRecordReader
 
close() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileRecordReader
 
close(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat.FilterRecordWriter
 
close() - Method in class org.apache.hadoop.mapreduce.lib.output.MultipleOutputs
Closes all the opened outputs.
close(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.output.TextOutputFormat.LineRecordWriter
 
close() - Method in class org.apache.hadoop.mapreduce.RecordReader
Close the record reader.
close(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.RecordWriter
Close this RecordWriter to future operations.
close() - Static method in class org.apache.hadoop.mapreduce.security.token.DelegationTokenRenewal
removing all tokens renewals
close() - Method in interface org.apache.hadoop.metrics.MetricsContext
Deprecated. Stops monitoring and also frees any buffered data, returning this object to its initial state.
close() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Stops monitoring and frees buffered data, returning this object to its initial state.
close() - Method in class org.apache.hadoop.metrics.spi.CompositeContext
Deprecated.  
close() - Method in class org.apache.hadoop.net.SocketInputStream
 
close() - Method in class org.apache.hadoop.net.SocketOutputStream
 
close() - Method in class org.apache.hadoop.security.SaslInputStream
Closes this input stream and releases any system resources associated with the stream.
close() - Method in class org.apache.hadoop.security.SaslOutputStream
Closes this output stream and releases any system resources associated with this stream.
close() - Method in class org.apache.hadoop.streaming.PipeMapper
 
close() - Method in class org.apache.hadoop.streaming.PipeReducer
 
close() - Method in class org.apache.hadoop.streaming.StreamBaseRecordReader
Close this to future operations.
close() - Method in class org.apache.hadoop.util.LineReader
Close the underlying stream.
Closeable - Interface in org.apache.hadoop.io
Deprecated. use java.io.Closeable
closeAll() - Static method in class org.apache.hadoop.fs.FileSystem
Close all cached filesystems.
closeAllForUGI(UserGroupInformation) - Static method in class org.apache.hadoop.fs.FileSystem
Close all cached filesystems for a given UGI.
closeConnection() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
closed - Variable in class org.apache.hadoop.io.compress.CompressorStream
 
closed - Variable in class org.apache.hadoop.io.compress.DecompressorStream
 
closeSocket(Socket) - Static method in class org.apache.hadoop.io.IOUtils
Closes the socket ignoring IOException
closeStream(Closeable) - Static method in class org.apache.hadoop.io.IOUtils
Closes the stream ignoring IOException.
closeWriter() - Method in class org.apache.hadoop.contrib.index.mapred.IntermediateForm
Close the Lucene index writer associated with the intermediate form, if created.
ClusterMetrics - Class in org.apache.hadoop.mapreduce
Status information on the current state of the Map-Reduce cluster.
ClusterMetrics() - Constructor for class org.apache.hadoop.mapreduce.ClusterMetrics
 
ClusterMetrics(int, int, int, int, int, int, int, int, int, int, int, int, int) - Constructor for class org.apache.hadoop.mapreduce.ClusterMetrics
 
ClusterStatus - Class in org.apache.hadoop.mapred
Status information on the current state of the Map-Reduce cluster.
cmpcl - Variable in class org.apache.hadoop.mapred.join.Parser.Node
 
code - Variable in enum org.apache.hadoop.security.SaslRpcServer.AuthMethod
The code for this method.
CodeBuffer - Class in org.apache.hadoop.record.compiler
A wrapper around StringBuffer that automatically does indentation
CodecPool - Class in org.apache.hadoop.io.compress
A global compressor/decompressor pool used to save and reuse (possibly native) compression/decompression codecs.
CodecPool() - Constructor for class org.apache.hadoop.io.compress.CodecPool
 
collate(Object[], String) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
collate(List, String) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
collect(Object, TaggedMapOutput, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
The subclass can overwrite this method to perform additional filtering and/or other processing logic before a value is collected.
collect(K, V) - Method in interface org.apache.hadoop.mapred.OutputCollector
Adds a key/value pair to the output.
collect(K, V) - Method in class org.apache.hadoop.mapred.Task.CombineOutputCollector
 
collected - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
 
column - Variable in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
combine(Object[], Object[]) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
 
combine(Object[], TupleWritable) - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
 
combine(Object[], TupleWritable) - Method in class org.apache.hadoop.mapred.join.InnerJoinRecordReader
Return true iff the tuple is full (all data sources contain this key).
combine(Object[], TupleWritable) - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader
Default implementation offers MultiFilterRecordReader.emit(org.apache.hadoop.mapred.join.TupleWritable) every Tuple from the collector (the outer join of child RRs).
combine(Object[], TupleWritable) - Method in class org.apache.hadoop.mapred.join.OuterJoinRecordReader
Emit everything from the collector.
combine(RawKeyValueIterator, OutputCollector<K, V>) - Method in class org.apache.hadoop.mapred.Task.OldCombinerRunner
 
COMBINE_CLASS_ATTR - Static variable in class org.apache.hadoop.mapreduce.JobContext
 
CombineFileInputFormat<K,V> - Class in org.apache.hadoop.mapred.lib
An abstract InputFormat that returns CombineFileSplit's in InputFormat.getSplits(JobConf, int) method.
CombineFileInputFormat() - Constructor for class org.apache.hadoop.mapred.lib.CombineFileInputFormat
default constructor
CombineFileInputFormat<K,V> - Class in org.apache.hadoop.mapreduce.lib.input
An abstract InputFormat that returns CombineFileSplit's in InputFormat.getSplits(JobContext) method.
CombineFileInputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat
default constructor
CombineFileRecordReader<K,V> - Class in org.apache.hadoop.mapred.lib
A generic RecordReader that can hand out different recordReaders for each chunk in a CombineFileSplit.
CombineFileRecordReader(JobConf, CombineFileSplit, Reporter, Class<RecordReader<K, V>>) - Constructor for class org.apache.hadoop.mapred.lib.CombineFileRecordReader
A generic RecordReader that can hand out different recordReaders for each chunk in the CombineFileSplit.
CombineFileRecordReader<K,V> - Class in org.apache.hadoop.mapreduce.lib.input
A generic RecordReader that can hand out different recordReaders for each chunk in a CombineFileSplit.
CombineFileRecordReader(CombineFileSplit, TaskAttemptContext, Class<? extends RecordReader<K, V>>) - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
A generic RecordReader that can hand out different recordReaders for each chunk in the CombineFileSplit.
CombineFileSplit - Class in org.apache.hadoop.mapred.lib
A sub-collection of input files.
CombineFileSplit() - Constructor for class org.apache.hadoop.mapred.lib.CombineFileSplit
default constructor
CombineFileSplit(JobConf, Path[], long[], long[], String[]) - Constructor for class org.apache.hadoop.mapred.lib.CombineFileSplit
 
CombineFileSplit(JobConf, Path[], long[]) - Constructor for class org.apache.hadoop.mapred.lib.CombineFileSplit
 
CombineFileSplit(CombineFileSplit) - Constructor for class org.apache.hadoop.mapred.lib.CombineFileSplit
Copy constructor
CombineFileSplit - Class in org.apache.hadoop.mapreduce.lib.input
A sub-collection of input files.
CombineFileSplit() - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
default constructor
CombineFileSplit(Path[], long[], long[], String[]) - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
 
CombineFileSplit(Path[], long[]) - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
 
CombineFileSplit(CombineFileSplit) - Constructor for class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
Copy constructor
comCmd_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
COMMA - Static variable in class org.apache.hadoop.util.StringUtils
 
COMMA_STR - Static variable in class org.apache.hadoop.util.StringUtils
 
COMMA_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
Command - Class in org.apache.hadoop.fs.shell
An abstract class for the execution of a file system command
Command(Configuration) - Constructor for class org.apache.hadoop.fs.shell.Command
Constructor
COMMAND_FILE - Static variable in class org.apache.hadoop.mapred.TaskController
 
CommandFormat - Class in org.apache.hadoop.fs.shell
Parse the args of a command and check the format of args.
CommandFormat(String, int, int, String...) - Constructor for class org.apache.hadoop.fs.shell.CommandFormat
constructor
commit() - Method in class org.apache.hadoop.security.UserGroupInformation.HadoopLoginModule
 
commitJob(JobContext) - Method in class org.apache.hadoop.mapred.FileOutputCommitter
 
commitJob(JobContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
For committing job's output after successful job completion.
commitJob(JobContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
This method implements the new interface by calling the old method.
commitJob(JobContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Delete the temporary directory, including all of the work directories.
commitJob(JobContext) - Method in class org.apache.hadoop.mapreduce.OutputCommitter
For cleaning up the job's output after job completion.
commitPending(TaskAttemptID, TaskStatus, JvmContext) - Method in class org.apache.hadoop.mapred.TaskTracker
Task is reporting that it is in commit_pending and it is waiting for the commit Response
commitPending(TaskAttemptID, TaskStatus, JvmContext) - Method in interface org.apache.hadoop.mapred.TaskUmbilicalProtocol
Report that the task is complete, but its commit is pending.
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.FileOutputCommitter
 
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
To promote the task's temporary output to final output location The task's output is moved to the job's output directory.
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapred.OutputCommitter
This method implements the new interface by calling the old method.
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Move the files from the work directory to the job output directory
commitTask(TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.OutputCommitter
To promote the task's temporary output to final output location The task's output is moved to the job's output directory.
committer - Variable in class org.apache.hadoop.mapred.Task
 
CommonConfigurationKeys - Class in org.apache.hadoop.fs
This class contains constants for configuration keys used in the common code.
CommonConfigurationKeys() - Constructor for class org.apache.hadoop.fs.CommonConfigurationKeys
 
comparator() - Method in class org.apache.hadoop.io.SortedMapWritable
COMPARATOR_JCLASS - Static variable in class org.apache.hadoop.io.file.tfile.TFile
comparator prefix: java class
COMPARATOR_MEMCMP - Static variable in class org.apache.hadoop.io.file.tfile.TFile
comparator: memcmp
COMPARATOR_OPTIONS - Static variable in class org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.examples.SecondarySort.FirstGroupingComparator
 
compare(SecondarySort.IntPair, SecondarySort.IntPair) - Method in class org.apache.hadoop.examples.SecondarySort.FirstGroupingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.examples.SecondarySort.IntPair.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.BooleanWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.BytesWritable.Comparator
Compare the buffers in serialized form.
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.ByteWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.DoubleWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.FloatWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.IntWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.LongWritable.Comparator
 
compare(WritableComparable, WritableComparable) - Method in class org.apache.hadoop.io.LongWritable.DecreasingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.LongWritable.DecreasingComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.MD5Hash.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.NullWritable.Comparator
Compare the buffers in serialized form.
compare(byte[], int, int, byte[], int, int) - Method in interface org.apache.hadoop.io.RawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.serializer.DeserializerComparator
 
compare(T, T) - Method in class org.apache.hadoop.io.serializer.JavaSerializationComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.Text.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.UTF8.Comparator
Deprecated.  
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.io.WritableComparator
Optimization hook.
compare(WritableComparable, WritableComparable) - Method in class org.apache.hadoop.io.WritableComparator
Compare two WritableComparables.
compare(Object, Object) - Method in class org.apache.hadoop.io.WritableComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.mapred.lib.KeyFieldBasedComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.record.RecordComparator
 
compare(byte[], int) - Method in class org.apache.hadoop.util.DataChecksum
Compares the checksum located at buf[offset] with the current checksum.
compare(int, int) - Method in interface org.apache.hadoop.util.IndexedSortable
Compare items at the given addresses consistent with the semantics of Comparator.compare(Object, Object).
compareBytes(byte[], int, int, byte[], int, int) - Static method in class org.apache.hadoop.io.WritableComparator
Lexicographic order of binary data.
compareBytes(byte[], int, int, byte[], int, int) - Static method in class org.apache.hadoop.record.Utils
Lexicographic order of binary data.
compareTo(Object) - Method in class org.apache.hadoop.contrib.index.mapred.DocumentID
 
compareTo(Object) - Method in class org.apache.hadoop.contrib.index.mapred.Shard
 
compareTo(Shard) - Method in class org.apache.hadoop.contrib.index.mapred.Shard
Compare to another shard.
compareTo(Object) - Method in class org.apache.hadoop.examples.MultiFileWordCount.WordOffset
 
compareTo(SecondarySort.IntPair) - Method in class org.apache.hadoop.examples.SecondarySort.IntPair
 
compareTo(Object) - Method in class org.apache.hadoop.fs.FileStatus
Compare this object to another object
compareTo(Object) - Method in class org.apache.hadoop.fs.Path
 
compareTo(BinaryComparable) - Method in class org.apache.hadoop.io.BinaryComparable
Compare bytes from {#getBytes()}.
compareTo(byte[], int, int) - Method in class org.apache.hadoop.io.BinaryComparable
Compare bytes from {#getBytes()} to those provided.
compareTo(Object) - Method in class org.apache.hadoop.io.BooleanWritable
 
compareTo(Object) - Method in class org.apache.hadoop.io.ByteWritable
Compares two ByteWritables.
compareTo(Object) - Method in class org.apache.hadoop.io.DoubleWritable
 
compareTo(byte[]) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner.Entry
Compare the entry key to another key.
compareTo(byte[], int, int) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner.Entry
Compare the entry key to another key.
compareTo(RawComparable) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner.Entry
Compare an entry with a RawComparable object.
compareTo(Utils.Version) - Method in class org.apache.hadoop.io.file.tfile.Utils.Version
Compare this version with another version.
compareTo(Object) - Method in class org.apache.hadoop.io.FloatWritable
Compares two FloatWritables.
compareTo(Object) - Method in class org.apache.hadoop.io.IntWritable
Compares two IntWritables.
compareTo(Object) - Method in class org.apache.hadoop.io.LongWritable
Compares two LongWritables.
compareTo(MD5Hash) - Method in class org.apache.hadoop.io.MD5Hash
Compares this object with the specified object for order.
compareTo(Object) - Method in class org.apache.hadoop.io.NullWritable
 
compareTo(Object) - Method in class org.apache.hadoop.io.SequenceFile.Sorter.SegmentDescriptor
 
compareTo(Object) - Method in class org.apache.hadoop.io.UTF8
Deprecated. Compare two UTF8s.
compareTo(Object) - Method in class org.apache.hadoop.io.VIntWritable
Compares two VIntWritables.
compareTo(Object) - Method in class org.apache.hadoop.io.VLongWritable
Compares two VLongWritables.
compareTo(ComposableRecordReader<K, ?>) - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Implement Comparable contract (compare key of join or head of heap with that of another).
compareTo(ComposableRecordReader<K, ?>) - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Implement Comparable contract (compare key at head of proxied RR with that of another).
compareTo(ID) - Method in class org.apache.hadoop.mapreduce.ID
Compare IDs by associated numbers
compareTo(ID) - Method in class org.apache.hadoop.mapreduce.JobID
Compare JobIds by first jtIdentifiers, then by job numbers
compareTo(ID) - Method in class org.apache.hadoop.mapreduce.TaskAttemptID
Compare TaskIds by first tipIds, then by task numbers.
compareTo(ID) - Method in class org.apache.hadoop.mapreduce.TaskID
Compare TaskInProgressIds by first jobIds, then by tip numbers.
compareTo(Object) - Method in class org.apache.hadoop.record.Buffer
Define the sort order of the Buffer.
compareTo(Object) - Method in class org.apache.hadoop.record.meta.RecordTypeInfo
This class doesn't implement Comparable as it's not meant to be used for anything besides de/serializing.
compareTo(Object) - Method in class org.apache.hadoop.record.Record
 
compareTo(Key) - Method in class org.apache.hadoop.util.bloom.Key
 
compatibleWith(Utils.Version) - Method in class org.apache.hadoop.io.file.tfile.Utils.Version
Test compatibility.
compile(String) - Static method in class org.apache.hadoop.fs.GlobPattern
Compile glob pattern string
compile(String) - Method in class org.apache.hadoop.metrics2.filter.GlobFilter
 
compile(String) - Method in class org.apache.hadoop.metrics2.filter.RegexFilter
 
compiled() - Method in class org.apache.hadoop.fs.GlobPattern
 
complete() - Method in class org.apache.hadoop.util.Progress
Completes this node, moving the parent node to its next child.
completedJobs() - Method in class org.apache.hadoop.mapred.JobTracker
 
completedTask(TaskInProgress, TaskStatus) - Method in class org.apache.hadoop.mapred.JobInProgress
A taskid assigned to this JobInProgress has reported in successfully.
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
 
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
Called when we're all done writing to the target.
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
Called when we're all done writing to the target.
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.HarFileSystem
not implemented.
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
completeLocalOutput(Path, Path) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
 
completeTask(TaskAttemptID) - Method in class org.apache.hadoop.mapred.TaskTrackerMetricsSource
 
ComposableInputFormat<K extends WritableComparable,V extends Writable> - Interface in org.apache.hadoop.mapred.join
Refinement of InputFormat requiring implementors to provide ComposableRecordReader instead of RecordReader.
ComposableRecordReader<K extends WritableComparable,V extends Writable> - Interface in org.apache.hadoop.mapred.join
Additional operations required of a RecordReader to participate in a join.
compose(Class<? extends InputFormat>, String) - Static method in class org.apache.hadoop.mapred.join.CompositeInputFormat
Convenience method for constructing composite formats.
compose(String, Class<? extends InputFormat>, String...) - Static method in class org.apache.hadoop.mapred.join.CompositeInputFormat
Convenience method for constructing composite formats.
compose(String, Class<? extends InputFormat>, Path...) - Static method in class org.apache.hadoop.mapred.join.CompositeInputFormat
Convenience method for constructing composite formats.
CompositeContext - Class in org.apache.hadoop.metrics.spi
Deprecated. in favor of org.apache.hadoop.metrics2 usage.
CompositeContext() - Constructor for class org.apache.hadoop.metrics.spi.CompositeContext
Deprecated.  
CompositeInputFormat<K extends WritableComparable> - Class in org.apache.hadoop.mapred.join
An InputFormat capable of performing joins over a set of data sources sorted and partitioned the same way.
CompositeInputFormat() - Constructor for class org.apache.hadoop.mapred.join.CompositeInputFormat
 
CompositeInputSplit - Class in org.apache.hadoop.mapred.join
This InputSplit contains a set of child InputSplits.
CompositeInputSplit() - Constructor for class org.apache.hadoop.mapred.join.CompositeInputSplit
 
CompositeInputSplit(int) - Constructor for class org.apache.hadoop.mapred.join.CompositeInputSplit
 
CompositeRecordReader<K extends WritableComparable,V extends Writable,X extends Writable> - Class in org.apache.hadoop.mapred.join
A RecordReader that can effect joins of RecordReaders sharing a common key type and partitioning.
CompositeRecordReader(int, int, Class<? extends WritableComparator>) - Constructor for class org.apache.hadoop.mapred.join.CompositeRecordReader
Create a RecordReader with capacity children to position id in the parent reader.
compress() - Method in class org.apache.hadoop.io.compress.BlockCompressorStream
 
compress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
compress(byte[], int, int) - Method in interface org.apache.hadoop.io.compress.Compressor
Fills specified buffer with compressed data.
compress() - Method in class org.apache.hadoop.io.compress.CompressorStream
 
compress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
Fills specified buffer with compressed data.
compress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.zlib.BuiltInZlibDeflater
 
compress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
 
compressedValSerializer - Variable in class org.apache.hadoop.io.SequenceFile.Writer
 
CompressedWritable - Class in org.apache.hadoop.io
A base-class for Writables which store themselves compressed and lazily inflate on field access.
CompressedWritable() - Constructor for class org.apache.hadoop.io.CompressedWritable
 
COMPRESSION_GZ - Static variable in class org.apache.hadoop.io.file.tfile.TFile
compression: gzip
COMPRESSION_LZO - Static variable in class org.apache.hadoop.io.file.tfile.TFile
compression: lzo
COMPRESSION_NONE - Static variable in class org.apache.hadoop.io.file.tfile.TFile
compression: none
COMPRESSION_SUFFIX - Static variable in class org.apache.hadoop.contrib.failmon.LocalStore
 
CompressionCodec - Interface in org.apache.hadoop.io.compress
This class encapsulates a streaming compression/decompression pair.
CompressionCodecFactory - Class in org.apache.hadoop.io.compress
A factory that will find the correct codec for a given filename.
CompressionCodecFactory(Configuration) - Constructor for class org.apache.hadoop.io.compress.CompressionCodecFactory
Find the codecs specified in the config value io.compression.codecs and register them.
CompressionInputStream - Class in org.apache.hadoop.io.compress
A compression input stream.
CompressionInputStream(InputStream) - Constructor for class org.apache.hadoop.io.compress.CompressionInputStream
Create a compression input stream that reads the decompressed bytes from the given stream.
CompressionOutputStream - Class in org.apache.hadoop.io.compress
A compression output stream.
CompressionOutputStream(OutputStream) - Constructor for class org.apache.hadoop.io.compress.CompressionOutputStream
Create a compression output stream that writes the compressed bytes to the given stream.
Compressor - Interface in org.apache.hadoop.io.compress
Specification of a stream-based 'compressor' which can be plugged into a CompressionOutputStream to compress data.
compressor - Variable in class org.apache.hadoop.io.compress.CompressorStream
 
CompressorStream - Class in org.apache.hadoop.io.compress
 
CompressorStream(OutputStream, Compressor, int) - Constructor for class org.apache.hadoop.io.compress.CompressorStream
 
CompressorStream(OutputStream, Compressor) - Constructor for class org.apache.hadoop.io.compress.CompressorStream
 
CompressorStream(OutputStream) - Constructor for class org.apache.hadoop.io.compress.CompressorStream
Allow derived classes to directly set the underlying stream.
computeHash(byte[], SecretKey) - Static method in class org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager
Compute the HMAC hash of the message using the key
computeSignature(String) - Method in class org.apache.hadoop.security.authentication.util.Signer
Returns then signature of a string.
computeSplitSize(long, long, long) - Method in class org.apache.hadoop.mapred.FileInputFormat
 
computeSplitSize(long, long, long) - Method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
 
conf - Variable in class org.apache.hadoop.mapred.SequenceFileRecordReader
 
conf - Variable in class org.apache.hadoop.mapred.Task
 
conf - Variable in class org.apache.hadoop.mapreduce.JobContext
 
conf - Variable in class org.apache.hadoop.mapreduce.lib.input.SequenceFileRecordReader
 
CONF_FILENAME_REGEX - Static variable in class org.apache.hadoop.mapred.JobHistory
 
CONF_GROUPS - Static variable in class org.apache.hadoop.security.authorize.ProxyUsers
 
CONF_HADOOP_PROXYUSER - Static variable in class org.apache.hadoop.security.authorize.ProxyUsers
 
CONF_HADOOP_PROXYUSER_RE - Static variable in class org.apache.hadoop.security.authorize.ProxyUsers
 
config_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
CONFIG_PREFIX - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Constant for the property that specifies the configuration prefix.
Configurable - Interface in org.apache.hadoop.conf
Something that may be configured with a Configuration.
Configuration - Class in org.apache.hadoop.conf
Provides access to configuration parameters.
Configuration() - Constructor for class org.apache.hadoop.conf.Configuration
A new configuration.
Configuration(boolean) - Constructor for class org.apache.hadoop.conf.Configuration
A new configuration where the behavior of reading from the default resources can be turned off.
Configuration(Configuration) - Constructor for class org.apache.hadoop.conf.Configuration
A new configuration with the same settings cloned from another.
Configuration.IntegerRanges - Class in org.apache.hadoop.conf
A class that represents a set of positive integer ranges.
Configuration.IntegerRanges() - Constructor for class org.apache.hadoop.conf.Configuration.IntegerRanges
 
Configuration.IntegerRanges(String) - Constructor for class org.apache.hadoop.conf.Configuration.IntegerRanges
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.example.IdentityLocalAnalysis
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.example.LineDocLocalAnalysis
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateCombiner
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateMapper
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdatePartitioner
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateReducer
 
configure(IndexUpdateConfiguration) - Method in class org.apache.hadoop.contrib.index.mapred.IntermediateForm
Configure using an index update configuration.
configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
 
configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
Initializes a new instance from a JobConf.
configure(JobConf) - Method in class org.apache.hadoop.examples.dancing.DistributedPentomino.PentMap
 
configure(JobConf) - Method in class org.apache.hadoop.examples.PiEstimator.PiReducer
Store job configuration.
configure(JobConf) - Method in class org.apache.hadoop.examples.SleepJob
 
configure(JobConf) - Method in interface org.apache.hadoop.mapred.JobConfigurable
Initializes a new instance from a JobConf.
configure(JobConf) - Method in class org.apache.hadoop.mapred.KeyValueTextInputFormat
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.aggregate.UserDefinedValueAggregatorDescriptor
Do nothing.
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
get the input file name.
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorCombiner
Combiner does not need to configure.
configure(JobConf) - Method in interface org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorDescriptor
Configure the object
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJobBase
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.BinaryPartitioner
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.ChainMapper
Configures the ChainMapper and all the Mappers in the chain.
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.ChainReducer
Configures the ChainReducer, the Reducer and all the Mappers in the chain.
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat
Initializes a new instance from a JobConf.
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.DelegatingMapper
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.FieldSelectionMapReduce
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.HashPartitioner
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.KeyFieldBasedComparator
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.KeyFieldBasedPartitioner
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.MultithreadedMapRunner
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.NLineInputFormat
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.RegexMapper
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.lib.TotalOrderPartitioner
Read in the partition file and build indexing data structures.
configure(JobConf) - Method in class org.apache.hadoop.mapred.MapReduceBase
Default implementation that does nothing.
configure(JobConf) - Method in class org.apache.hadoop.mapred.MapRunner
 
configure(JobConf) - Method in class org.apache.hadoop.mapred.TextInputFormat
 
configure(JobConf) - Method in class org.apache.hadoop.streaming.AutoInputFormat
 
configure(JobConf) - Method in class org.apache.hadoop.streaming.PipeMapper
 
configure(JobConf) - Method in class org.apache.hadoop.streaming.PipeMapRed
 
configure(JobConf) - Method in class org.apache.hadoop.streaming.PipeReducer
 
Configured - Class in org.apache.hadoop.conf
Base class for things that may be configured with a Configuration.
Configured() - Constructor for class org.apache.hadoop.conf.Configured
Construct a Configured.
Configured(Configuration) - Constructor for class org.apache.hadoop.conf.Configured
Construct a Configured.
configureDB(JobConf, String, String, String, String) - Static method in class org.apache.hadoop.mapred.lib.db.DBConfiguration
Sets the DB access related fields in the JobConf.
configureDB(JobConf, String, String) - Static method in class org.apache.hadoop.mapred.lib.db.DBConfiguration
Sets the DB access related fields in the JobConf.
configureDB(Configuration, String, String, String, String) - Static method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
Sets the DB access related fields in the Configuration.
configureDB(Configuration, String, String) - Static method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
Sets the DB access related fields in the JobConf.
connect(Socket, SocketAddress, int) - Static method in class org.apache.hadoop.net.NetUtils
This is a drop-in replacement for Socket.connect(SocketAddress, int).
connect(Socket, SocketAddress, SocketAddress, int) - Static method in class org.apache.hadoop.net.NetUtils
Like NetUtils.connect(Socket, SocketAddress, int) but also takes a local address and port to bind the socket to.
construct(ZlibCompressor.CompressionLevel, ZlibCompressor.CompressionStrategy, ZlibCompressor.CompressionHeader, int) - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
 
constructQuery(String, String[]) - Method in class org.apache.hadoop.mapred.lib.db.DBOutputFormat
Constructs the query used as the prepared statement to insert data.
constructQuery(String, String[]) - Method in class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat
Constructs the query used as the prepared statement to insert data.
Consts - Class in org.apache.hadoop.record.compiler
const definitions for Record I/O compiler
contains(Node) - Method in class org.apache.hadoop.net.NetworkTopology
Check if the tree contains node node
containsAll(AbstractMetricsContext.TagMap) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext.TagMap
Deprecated. Returns true if this tagmap contains every tag in other.
containsKey(Object) - Method in class org.apache.hadoop.io.MapWritable
containsKey(Object) - Method in class org.apache.hadoop.io.SortedMapWritable
containsValue(Object) - Method in class org.apache.hadoop.io.MapWritable
containsValue(Object) - Method in class org.apache.hadoop.io.SortedMapWritable
ContentSummary - Class in org.apache.hadoop.fs
Store the summary of a content (a directory or a file).
ContentSummary() - Constructor for class org.apache.hadoop.fs.ContentSummary
Constructor
ContentSummary(long, long, long) - Constructor for class org.apache.hadoop.fs.ContentSummary
Constructor
ContentSummary(long, long, long, long, long, long) - Constructor for class org.apache.hadoop.fs.ContentSummary
Constructor
context - Variable in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
context() - Method in class org.apache.hadoop.metrics2.impl.MetricsRecordImpl
 
context() - Method in interface org.apache.hadoop.metrics2.MetricsRecord
Get the context name of the metrics
CONTEXT_DESC - Static variable in class org.apache.hadoop.metrics2.lib.MetricsRegistry
description for the context tag
CONTEXT_KEY - Static variable in class org.apache.hadoop.metrics2.impl.MetricsRecordImpl
 
CONTEXT_KEY - Static variable in class org.apache.hadoop.metrics2.lib.MetricsRegistry
key for the context tag
ContextFactory - Class in org.apache.hadoop.metrics
Deprecated. in favor of org.apache.hadoop.metrics2 usage.
ContextFactory() - Constructor for class org.apache.hadoop.metrics.ContextFactory
Deprecated. Creates a new instance of ContextFactory
Continuous - Class in org.apache.hadoop.contrib.failmon
This class runs FailMon in a continuous mode on the local node.
Continuous() - Constructor for class org.apache.hadoop.contrib.failmon.Continuous
 
Contracts - Class in org.apache.hadoop.metrics2.util
Utilities for programming by contract (preconditions, postconditions etc.)
ControlledJob - Class in org.apache.hadoop.mapreduce.lib.jobcontrol
This class encapsulates a MapReduce job and its dependency.
ControlledJob(Job, List<ControlledJob>) - Constructor for class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
Construct a job.
ControlledJob(Configuration) - Constructor for class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
Construct a job.
ControlledJob.State - Enum in org.apache.hadoop.mapreduce.lib.jobcontrol
 
convertToByteStream(Checksum, int) - Static method in class org.apache.hadoop.fs.FSOutputSummer
Converts a checksum integer value to a byte stream
COOKIE_DOMAIN - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Constant for the configuration property that indicates the domain to use in the HTTP cookie.
COOKIE_PATH - Static variable in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Constant for the configuration property that indicates the path to use in the HTTP cookie.
copy(FileSystem, Path, FileSystem, Path, boolean, Configuration) - Static method in class org.apache.hadoop.fs.FileUtil
Copy files between FileSystems.
copy(FileSystem, Path[], FileSystem, Path, boolean, boolean, Configuration) - Static method in class org.apache.hadoop.fs.FileUtil
 
copy(FileSystem, Path, FileSystem, Path, boolean, boolean, Configuration) - Static method in class org.apache.hadoop.fs.FileUtil
Copy files between FileSystems.
copy(File, FileSystem, Path, boolean, Configuration) - Static method in class org.apache.hadoop.fs.FileUtil
Copy local files to a FileSystem.
copy(FileSystem, Path, File, boolean, Configuration) - Static method in class org.apache.hadoop.fs.FileUtil
Copy FileSystem files to local files.
copy(Writable) - Method in class org.apache.hadoop.io.AbstractMapWritable
Used by child copy constructors.
copy(byte[], int, int) - Method in class org.apache.hadoop.record.Buffer
Copy the specified byte array to the Buffer.
copy(Configuration, T, T) - Static method in class org.apache.hadoop.util.ReflectionUtils
Make a copy of the writable object using serialization to a buffer
copyBytes(InputStream, OutputStream, int, boolean) - Static method in class org.apache.hadoop.io.IOUtils
Copies from one stream to another.
copyBytes(InputStream, OutputStream, int) - Static method in class org.apache.hadoop.io.IOUtils
Copies from one stream to another.
copyBytes(InputStream, OutputStream, Configuration) - Static method in class org.apache.hadoop.io.IOUtils
Copies from one stream to another.
copyBytes(InputStream, OutputStream, Configuration, boolean) - Static method in class org.apache.hadoop.io.IOUtils
Copies from one stream to another.
copyBytes(InputStream, OutputStream, long, int, boolean) - Static method in class org.apache.hadoop.io.IOUtils
Copies the specified length of bytes from in to out.
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
 
copyFromLocalFile(Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
The src file is on the local disk.
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
The src file is on the local disk.
copyFromLocalFile(boolean, boolean, Path[], Path) - Method in class org.apache.hadoop.fs.FileSystem
The src files are on the local disk.
copyFromLocalFile(boolean, boolean, Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
The src file is on the local disk.
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
The src file is on the local disk.
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.HarFileSystem
not implemented.
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
copyFromLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.LocalFileSystem
 
copyMerge(FileSystem, Path, FileSystem, Path, boolean, Configuration, String) - Static method in class org.apache.hadoop.fs.FileUtil
Copy all files in a directory to one output file (merge).
copyTo(SampleStat) - Method in class org.apache.hadoop.metrics2.util.SampleStat
Copy the values to other (saves object creation and gc.)
copyToHDFS(String, String) - Static method in class org.apache.hadoop.contrib.failmon.LocalStore
Copy a local file to HDFS
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
The src file is under FS, and the dst is on the local disk.
copyToLocalFile(Path, Path, boolean) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
The src file is under FS, and the dst is on the local disk.
copyToLocalFile(Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
The src file is under FS, and the dst is on the local disk.
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.FileSystem
The src file is under FS, and the dst is on the local disk.
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
The src file is under FS, and the dst is on the local disk.
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.HarFileSystem
copies the file in the har filesystem to a local file.
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
copyToLocalFile(boolean, Path, Path) - Method in class org.apache.hadoop.fs.LocalFileSystem
 
Count - Class in org.apache.hadoop.fs.shell
Count the number of directories, files, bytes, quota, and remaining quota.
Count(String[], int, Configuration) - Constructor for class org.apache.hadoop.fs.shell.Count
Constructor
countCounters() - Method in class org.apache.hadoop.mapreduce.Counters
Returns the total number of counters, by summing the number of counters in each group.
countDirs - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
countEmptyDirs - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
Counter - Class in org.apache.hadoop.mapreduce
A named counter that tracks the progress of a map/reduce job.
Counter() - Constructor for class org.apache.hadoop.mapreduce.Counter
 
Counter(String, String) - Constructor for class org.apache.hadoop.mapreduce.Counter
 
counter(MetricCounter<Integer>, int) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for integer value counters
counter(MetricCounter<Long>, long) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for long value counters
COUNTER_GROUP - Static variable in class org.apache.hadoop.mapred.SkipBadRecords
Special counters which are written by the application and are used by the framework for detecting bad records.
COUNTER_MAP_PROCESSED_RECORDS - Static variable in class org.apache.hadoop.mapred.SkipBadRecords
Number of processed map records.
COUNTER_REDUCE_PROCESSED_GROUPS - Static variable in class org.apache.hadoop.mapred.SkipBadRecords
Number of processed reduce groups.
CounterGroup - Class in org.apache.hadoop.mapreduce
A group of Counters that logically belong together.
CounterGroup(String) - Constructor for class org.apache.hadoop.mapreduce.CounterGroup
 
CounterGroup(String, String) - Constructor for class org.apache.hadoop.mapreduce.CounterGroup
 
Counters - Class in org.apache.hadoop.mapred
A set of named counters.
Counters() - Constructor for class org.apache.hadoop.mapred.Counters
 
Counters - Class in org.apache.hadoop.mapreduce
 
Counters() - Constructor for class org.apache.hadoop.mapreduce.Counters
 
Counters(Counters) - Constructor for class org.apache.hadoop.mapreduce.Counters
 
Counters.Counter - Class in org.apache.hadoop.mapred
A counter record, comprising its name and value.
Counters.CountersExceededException - Exception in org.apache.hadoop.mapred
Counter exception thrown when the number of counters exceed the limit
Counters.CountersExceededException(String) - Constructor for exception org.apache.hadoop.mapred.Counters.CountersExceededException
 
Counters.Group - Class in org.apache.hadoop.mapred
Group of counters, comprising of counters from a particular counter Enum class.
countFilesMultLinks - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
CountingBloomFilter - Class in org.apache.hadoop.util.bloom
Implements a counting Bloom filter, as defined by Fan et al.
CountingBloomFilter() - Constructor for class org.apache.hadoop.util.bloom.CountingBloomFilter
Default constructor - use with readFields
CountingBloomFilter(int, int, int) - Constructor for class org.apache.hadoop.util.bloom.CountingBloomFilter
Constructor
countMapTasks() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the number of running map tasks.
countMultLinks - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
countNumOfAvailableNodes(String, List<Node>) - Method in class org.apache.hadoop.net.NetworkTopology
return the number of leaves in scope but not in excludedNodes if scope starts with ~, return the number of nodes that are not in scope and excludedNodes;
countOccupiedMapSlots() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the number of occupied map slots.
countOccupiedReduceSlots() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the number of occupied reduce slots.
countPhysicalFileCopies - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
countReduceTasks() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the number of running reduce tasks.
countSingleLinks - Variable in class org.apache.hadoop.fs.HardLink.LinkStats
 
CPUParser - Class in org.apache.hadoop.contrib.failmon
Objects of this class parse the /proc/cpuinfo file to gather information about present processors in the system.
CPUParser() - Constructor for class org.apache.hadoop.contrib.failmon.CPUParser
Constructs a CPUParser
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(FileSystem, Path, FsPermission) - Static method in class org.apache.hadoop.fs.FileSystem
create a file with the provided permission The permission of the file is set to be the provided permission as in setPermission, not permission&~umask It is implemented using two RPCs.
create(Path) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path.
create(Path, boolean) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path.
create(Path, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Create an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, short) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path.
create(Path, short, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, boolean, int) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path.
create(Path, boolean, int, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, boolean, int, short, long) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path.
create(Path, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.FilterFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
A stream obtained via this call must be closed before using other APIs of this class or else the invocation will block.
create(Path, int) - Method in class org.apache.hadoop.fs.HarFileSystem
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.HarFileSystem
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
create(Path, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.s3.S3FileSystem
 
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.s3native.NativeS3FileSystem
 
create(Class<?>, Object, RetryPolicy) - Static method in class org.apache.hadoop.io.retry.RetryProxy
Create a proxy for an interface of an implementation class using the same retry policy for each method in the interface.
create(Class<?>, Object, Map<String, RetryPolicy>) - Static method in class org.apache.hadoop.io.retry.RetryProxy
Create a proxy for an interface of an implementation class using the a set of retry policies specified by method name.
create(Class<?>, Object, RetryPolicy, Map<String, RetryPolicy>) - Static method in class org.apache.hadoop.io.retry.RetryProxy
 
create(String, int) - Static method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
Create an RPC instrumentation object
create(String, int, MetricsSystem) - Static method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
Create an RPC instrumentation object Mostly useful for testing.
create(String, String, MetricsSystem) - Static method in class org.apache.hadoop.metrics2.source.JvmMetricsSource
 
create(String, String) - Static method in class org.apache.hadoop.metrics2.source.JvmMetricsSource
 
CREATE_DIR - Static variable in class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
 
createAllSymlink(Configuration, File, File) - Static method in class org.apache.hadoop.filecache.DistributedCache
Deprecated. Internal to MapReduce framework. Use DistributedCacheManager instead.
createAllSymlink(Configuration, File, File) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
This method create symlinks for all files in a given dir in another directory.
createBaseListener(Configuration) - Method in class org.apache.hadoop.http.HttpServer
Create a required listener for the Jetty instance listening on the port provided.
createCompressor() - Method in class org.apache.hadoop.io.compress.BZip2Codec
This functionality is currently not supported.
createCompressor() - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a new Compressor for use by this CompressionCodec.
createCompressor() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createCompressor() - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createCompressor() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a new Compressor for use by this CompressionCodec.
createCookie(String) - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Creates the Hadoop authentiation HTTP cookie.
createDataFileReader(FileSystem, Path, Configuration) - Method in class org.apache.hadoop.io.MapFile.Reader
Override this method to specialize the type of SequenceFile.Reader returned.
createDataJoinJob(String[]) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
 
createDBRecordReader(DBInputFormat.DBInputSplit, Configuration) - Method in class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat
 
createDBRecordReader(DBInputFormat.DBInputSplit, Configuration) - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
createDBRecordReader(DBInputFormat.DBInputSplit, Configuration) - Method in class org.apache.hadoop.mapreduce.lib.db.OracleDataDrivenDBInputFormat
 
createDecompressor() - Method in class org.apache.hadoop.io.compress.BZip2Codec
This functionality is currently not supported.
createDecompressor() - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a new Decompressor for use by this CompressionCodec.
createDecompressor() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createDecompressor() - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createDecompressor() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a new Decompressor for use by this CompressionCodec.
createDefaultChannelConnector() - Static method in class org.apache.hadoop.http.HttpServer
 
createFactory() - Method in class org.apache.hadoop.security.Krb5AndCertsSslSocketConnector
 
createFileSplit(Path, long, long) - Static method in class org.apache.hadoop.mapreduce.lib.input.NLineInputFormat
NLineInputFormat uses LineRecordReader, which always reads (and consumes) at least one character out of its upper split boundary.
createForWrite(File, int) - Static method in class org.apache.hadoop.io.SecureIOUtils
Open the specified File for write access, ensuring that it does not exist.
createHardLink(File, File) - Static method in class org.apache.hadoop.fs.HardLink
Creates a hardlink
createHardLinkMult(File, String[], File) - Static method in class org.apache.hadoop.fs.HardLink
Creates hardlinks from multiple existing files within one parent directory, into one target directory.
createHardLinkMult(File, String[], File, int) - Static method in class org.apache.hadoop.fs.HardLink
 
createIdentifier() - Method in class org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenSecretManager
 
createIdentifier() - Method in class org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager
Create an empty job token identifier
createIdentifier() - Method in class org.apache.hadoop.security.token.SecretManager
Create an empty token identifier.
createImmutable(short) - Static method in class org.apache.hadoop.fs.permission.FsPermission
Create an immutable FsPermission object.
createImmutable(String, String, FsPermission) - Static method in class org.apache.hadoop.fs.permission.PermissionStatus
Create an immutable PermissionStatus object.
createInputStream(InputStream) - Method in class org.apache.hadoop.io.compress.BZip2Codec
Creates CompressionInputStream to be used to read off uncompressed data.
createInputStream(InputStream, Decompressor) - Method in class org.apache.hadoop.io.compress.BZip2Codec
This functionality is currently not supported.
createInputStream(InputStream, Decompressor, long, long, SplittableCompressionCodec.READ_MODE) - Method in class org.apache.hadoop.io.compress.BZip2Codec
Creates CompressionInputStream to be used to read off uncompressed data in one of the two reading modes.
createInputStream(InputStream) - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a stream decompressor that will read from the given input stream.
createInputStream(InputStream, Decompressor) - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a CompressionInputStream that will read from the given InputStream with the given Decompressor.
createInputStream(InputStream) - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createInputStream(InputStream, Decompressor) - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createInputStream(InputStream) - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createInputStream(InputStream, Decompressor) - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createInputStream(InputStream) - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a CompressionInputStream that will read from the given input stream.
createInputStream(InputStream, Decompressor) - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a CompressionInputStream that will read from the given InputStream with the given Decompressor.
createInputStream(InputStream, Decompressor, long, long, SplittableCompressionCodec.READ_MODE) - Method in interface org.apache.hadoop.io.compress.SplittableCompressionCodec
Create a stream as dictated by the readMode.
createInstance(String) - Static method in class org.apache.hadoop.mapred.lib.aggregate.UserDefinedValueAggregatorDescriptor
Create an instance of the given class
createInternalValue() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Create a value to be used internally for joins.
createIOException(List<IOException>) - Static method in exception org.apache.hadoop.io.MultipleIOException
A convenient method to create an IOException.
createJob(String[]) - Static method in class org.apache.hadoop.streaming.StreamJob
This method creates a streaming job from the given argument list.
createJobDirs() - Method in class org.apache.hadoop.mapred.JobLocalizer
Prepare the job directories for a given job.
createKey() - Method in class org.apache.hadoop.contrib.index.example.LineDocRecordReader
 
createKey() - Method in class org.apache.hadoop.examples.MultiFileWordCount.MultiFileLineRecordReader
 
createKey() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Create a new key value common to all child RRs.
createKey() - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Request new key from proxied RR.
createKey() - Method in class org.apache.hadoop.mapred.KeyValueLineRecordReader
 
createKey() - Method in class org.apache.hadoop.mapred.lib.CombineFileRecordReader
 
createKey() - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBRecordReader
Create an object of the appropriate type to be used as a key.
createKey() - Method in class org.apache.hadoop.mapred.LineRecordReader
 
createKey() - Method in interface org.apache.hadoop.mapred.RecordReader
Create an object of the appropriate type to be used as a key.
createKey() - Method in class org.apache.hadoop.mapred.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
createKey() - Method in class org.apache.hadoop.mapred.SequenceFileAsTextRecordReader
 
createKey() - Method in class org.apache.hadoop.mapred.SequenceFileRecordReader
 
createKey() - Method in class org.apache.hadoop.streaming.StreamBaseRecordReader
 
createLocalDirs() - Method in class org.apache.hadoop.mapred.JobLocalizer
 
createLocalTempFile(File, String, boolean) - Static method in class org.apache.hadoop.fs.FileUtil
Create a tmp file for a base file.
createLogDir(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.DefaultTaskController
 
createLogDir(TaskAttemptID, boolean) - Method in class org.apache.hadoop.mapred.TaskController
Creates task log dir
createNewFile(Path) - Method in class org.apache.hadoop.fs.FileSystem
Creates the given Path as a brand-new zero-length file.
createNonRecursive(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
createNonRecursive(Path, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. API only for 0.20-append
createNonRecursive(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. API only for 0.20-append
createNonRecursive(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
Opens an FSDataOutputStream at the indicated Path with write-progress reporting.
createOutput(String) - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
createOutputStream(OutputStream) - Method in class org.apache.hadoop.io.compress.BZip2Codec
Creates CompressionOutputStream for BZip2
createOutputStream(OutputStream, Compressor) - Method in class org.apache.hadoop.io.compress.BZip2Codec
Creates a compressor using given OutputStream.
createOutputStream(OutputStream) - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a CompressionOutputStream that will write to the given OutputStream.
createOutputStream(OutputStream, Compressor) - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Create a CompressionOutputStream that will write to the given OutputStream with the given Compressor.
createOutputStream(OutputStream) - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createOutputStream(OutputStream, Compressor) - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
createOutputStream(OutputStream) - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createOutputStream(OutputStream, Compressor) - Method in class org.apache.hadoop.io.compress.GzipCodec
 
createOutputStream(OutputStream) - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a CompressionOutputStream that will write to the given OutputStream.
createOutputStream(OutputStream, Compressor) - Method in class org.apache.hadoop.io.compress.SnappyCodec
Create a CompressionOutputStream that will write to the given OutputStream with the given Compressor.
createPassword(JobTokenIdentifier) - Method in class org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager
Create a new password/secret for the given job token identifier.
createPassword(TokenIdent) - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
 
createPassword(T) - Method in class org.apache.hadoop.security.token.SecretManager
Create the password for the given identifier.
createPassword(byte[], SecretKey) - Static method in class org.apache.hadoop.security.token.SecretManager
Compute HMAC of the identifier using the secret key and return the output as password
createPool(JobConf, List<PathFilter>) - Method in class org.apache.hadoop.mapred.lib.CombineFileInputFormat
Create a new pool and add the filters to it.
createPool(JobConf, PathFilter...) - Method in class org.apache.hadoop.mapred.lib.CombineFileInputFormat
Create a new pool and add the filters to it.
createPool(List<PathFilter>) - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat
Create a new pool and add the filters to it.
createPool(PathFilter...) - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat
Create a new pool and add the filters to it.
createProxyUser(String, UserGroupInformation) - Static method in class org.apache.hadoop.security.UserGroupInformation
Create a proxy user using username of the effective user and the ugi of the real user.
createProxyUserForTesting(String, UserGroupInformation, String[]) - Static method in class org.apache.hadoop.security.UserGroupInformation
Create a proxy user UGI for testing HDFS and MapReduce
createRecord(String) - Method in interface org.apache.hadoop.metrics.MetricsContext
Deprecated. Creates a new MetricsRecord instance with the given recordName.
createRecord(MetricsContext, String) - Static method in class org.apache.hadoop.metrics.MetricsUtil
Deprecated. Utility method to create and return new metrics record instance within the given context.
createRecord(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Creates a new AbstractMetricsRecord instance with the given recordName.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.InputFormat
Create a record reader for a given split.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
Create a record reader for a given split.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat
This is not implemented yet.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.DelegatingInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.KeyValueTextInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.NLineInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsBinaryInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsTextInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter
Create a record reader for the given split
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.mapreduce.lib.input.TextInputFormat
 
createReduceContext(Reducer<INKEY, INVALUE, OUTKEY, OUTVALUE>, Configuration, TaskAttemptID, RawKeyValueIterator, Counter, Counter, RecordWriter<OUTKEY, OUTVALUE>, OutputCommitter, StatusReporter, RawComparator<INKEY>, Class<INKEY>, Class<INVALUE>) - Static method in class org.apache.hadoop.mapred.Task
 
createRemoteUser(String) - Static method in class org.apache.hadoop.security.UserGroupInformation
Create a user from a login name.
createResetableIterator() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
The subclass can provide a different implementation on ResetableIterator.
createRunner(TaskTracker, TaskTracker.TaskInProgress, TaskTracker.RunningJob) - Method in class org.apache.hadoop.mapred.Task
Return an approprate thread runner for this task.
createScanner() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get a scanner than can scan the whole TFile.
createScanner(byte[], byte[]) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Deprecated. Use TFile.Reader.createScannerByKey(byte[], byte[]) instead.
createScanner(RawComparable, RawComparable) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Deprecated. Use TFile.Reader.createScannerByKey(RawComparable, RawComparable) instead.
createScannerByByteRange(long, long) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get a scanner that covers a portion of TFile based on byte offsets.
createScannerByKey(byte[], byte[]) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get a scanner that covers a portion of TFile based on keys.
createScannerByKey(RawComparable, RawComparable) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get a scanner that covers a specific key range.
createScannerByRecordNum(long, long) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Create a scanner that covers a range of records.
createSecretKey(byte[]) - Static method in class org.apache.hadoop.mapreduce.security.token.JobTokenSecretManager
Convert the byte[] to a secret key
createSecretKey(byte[]) - Static method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Convert the byte[] to a secret key
createSecretKey(byte[]) - Static method in class org.apache.hadoop.security.token.SecretManager
Convert the byte[] to a secret key
createSocket() - Method in class org.apache.hadoop.net.SocksSocketFactory
 
createSocket(InetAddress, int) - Method in class org.apache.hadoop.net.SocksSocketFactory
 
createSocket(InetAddress, int, InetAddress, int) - Method in class org.apache.hadoop.net.SocksSocketFactory
 
createSocket(String, int) - Method in class org.apache.hadoop.net.SocksSocketFactory
 
createSocket(String, int, InetAddress, int) - Method in class org.apache.hadoop.net.SocksSocketFactory
 
createSocket() - Method in class org.apache.hadoop.net.StandardSocketFactory
 
createSocket(InetAddress, int) - Method in class org.apache.hadoop.net.StandardSocketFactory
 
createSocket(InetAddress, int, InetAddress, int) - Method in class org.apache.hadoop.net.StandardSocketFactory
 
createSocket(String, int) - Method in class org.apache.hadoop.net.StandardSocketFactory
 
createSocket(String, int, InetAddress, int) - Method in class org.apache.hadoop.net.StandardSocketFactory
 
createSocketAddr(String) - Static method in class org.apache.hadoop.net.NetUtils
Util method to build socket addr from either: : ://:/
createSocketAddr(String, int) - Static method in class org.apache.hadoop.net.NetUtils
Util method to build socket addr from either: : ://:/
createSplitFiles(Path, Configuration, FileSystem, List<InputSplit>) - Static method in class org.apache.hadoop.mapreduce.split.JobSplitWriter
 
createSplitFiles(Path, Configuration, FileSystem, T[]) - Static method in class org.apache.hadoop.mapreduce.split.JobSplitWriter
 
createSplitFiles(Path, Configuration, FileSystem, InputSplit[]) - Static method in class org.apache.hadoop.mapreduce.split.JobSplitWriter
 
createSymlink(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
This method allows you to create symlinks in the current working directory of the task to all the cache files/archives.
createTaskAttemptLogDir(TaskAttemptID, boolean, String[]) - Static method in class org.apache.hadoop.mapred.TaskLog
Create log directory for the given attempt.
createTmpFileForWrite(String, long, Configuration) - Method in class org.apache.hadoop.fs.LocalDirAllocator
Creates a temporary file in the local FS.
createURLStreamHandler(String) - Method in class org.apache.hadoop.fs.FsUrlStreamHandlerFactory
 
createUserDirs() - Method in class org.apache.hadoop.mapred.JobLocalizer
Initialize the local directories for a particular user on this TT.
createUserForTesting(String, String[]) - Static method in class org.apache.hadoop.security.UserGroupInformation
Create a UGI for testing HDFS and MapReduce
createValue() - Method in class org.apache.hadoop.contrib.index.example.LineDocRecordReader
 
createValue() - Method in class org.apache.hadoop.examples.MultiFileWordCount.MultiFileLineRecordReader
 
createValue() - Method in class org.apache.hadoop.mapred.join.JoinRecordReader
Create an object of the appropriate type to be used as a value.
createValue() - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader
Create an object of the appropriate type to be used as a value.
createValue() - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Request new value from proxied RR.
createValue() - Method in class org.apache.hadoop.mapred.KeyValueLineRecordReader
 
createValue() - Method in class org.apache.hadoop.mapred.lib.CombineFileRecordReader
 
createValue() - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBRecordReader
Create an object of the appropriate type to be used as a value.
createValue() - Method in class org.apache.hadoop.mapred.LineRecordReader
 
createValue() - Method in interface org.apache.hadoop.mapred.RecordReader
Create an object of the appropriate type to be used as a value.
createValue() - Method in class org.apache.hadoop.mapred.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
createValue() - Method in class org.apache.hadoop.mapred.SequenceFileAsTextRecordReader
 
createValue() - Method in class org.apache.hadoop.mapred.SequenceFileRecordReader
 
createValue() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
Deprecated.  
createValue() - Method in class org.apache.hadoop.streaming.StreamBaseRecordReader
 
createValueAggregatorJob(String[]) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob
Create an Aggregate based map/reduce job.
createValueAggregatorJob(String[], Class<? extends ValueAggregatorDescriptor>[]) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob
 
createValueAggregatorJobs(String[], Class<? extends ValueAggregatorDescriptor>[]) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob
 
createValueAggregatorJobs(String[]) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorJob
 
createValueBytes() - Method in class org.apache.hadoop.io.SequenceFile.Reader
 
createWorkDir(JobConf) - Method in class org.apache.hadoop.mapred.JobLocalizer
 
createWriter(FileSystem, Configuration, Path, Class, Class) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, SequenceFile.CompressionType) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, SequenceFile.CompressionType, Progressable) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, SequenceFile.CompressionType, CompressionCodec) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, SequenceFile.CompressionType, CompressionCodec, Progressable, SequenceFile.Metadata) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, int, short, long, SequenceFile.CompressionType, CompressionCodec, Progressable, SequenceFile.Metadata) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, int, short, long, boolean, SequenceFile.CompressionType, CompressionCodec, SequenceFile.Metadata) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(FileSystem, Configuration, Path, Class, Class, SequenceFile.CompressionType, CompressionCodec, Progressable) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of SequenceFile Writer.
createWriter(Configuration, FSDataOutputStream, Class, Class, SequenceFile.CompressionType, CompressionCodec, SequenceFile.Metadata) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of 'raw' SequenceFile Writer.
createWriter(Configuration, FSDataOutputStream, Class, Class, SequenceFile.CompressionType, CompressionCodec) - Static method in class org.apache.hadoop.io.SequenceFile
Construct the preferred type of 'raw' SequenceFile Writer.
credentials - Variable in class org.apache.hadoop.mapreduce.JobContext
 
Credentials - Class in org.apache.hadoop.security
A class that provides the facilities of reading and writing secret keys and Tokens.
Credentials() - Constructor for class org.apache.hadoop.security.Credentials
 
CSTRING_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
CsvRecordInput - Class in org.apache.hadoop.record
 
CsvRecordInput(InputStream) - Constructor for class org.apache.hadoop.record.CsvRecordInput
Creates a new instance of CsvRecordInput
CsvRecordOutput - Class in org.apache.hadoop.record
 
CsvRecordOutput(OutputStream) - Constructor for class org.apache.hadoop.record.CsvRecordOutput
Creates a new instance of CsvRecordOutput
CUR_DIR - Static variable in class org.apache.hadoop.fs.Path
 
curChar - Variable in class org.apache.hadoop.record.compiler.generated.RccTokenManager
 
curReader - Variable in class org.apache.hadoop.mapred.lib.CombineFileRecordReader
 
curReader - Variable in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
current() - Method in class org.apache.hadoop.metrics2.util.TryIterator
 
CURRENT_VERSION - Static variable in class org.apache.hadoop.ipc.Server
 
currentConfig() - Method in class org.apache.hadoop.metrics2.impl.MetricsSystemImpl
 
currentConfig() - Method in enum org.apache.hadoop.metrics2.lib.DefaultMetricsSystem
 
currentConfig() - Method in interface org.apache.hadoop.metrics2.MetricsSystemMXBean
 
currentId - Variable in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Access to currentId is protected by this object lock.
currentToken - Variable in exception org.apache.hadoop.record.compiler.generated.ParseException
This is the last token that has been consumed successfully.
currentTokens - Variable in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Cache of currently valid tokens, mapping from DelegationTokenIdentifier to DelegationTokenInformation.
customize(EndPoint, Request) - Method in class org.apache.hadoop.security.Krb5AndCertsSslSocketConnector
 
CyclicIteration<K,V> - Class in org.apache.hadoop.util
Provide an cyclic Iterator for a NavigableMap.
CyclicIteration(NavigableMap<K, V>, K) - Constructor for class org.apache.hadoop.util.CyclicIteration
Construct an Iterable object, so that an Iterator can be created for iterating the given NavigableMap.

D

Daemon - Class in org.apache.hadoop.util
A thread that has called Thread.setDaemon(boolean) with true.
Daemon() - Constructor for class org.apache.hadoop.util.Daemon
Construct a daemon thread.
Daemon(Runnable) - Constructor for class org.apache.hadoop.util.Daemon
Construct a daemon thread.
Daemon(ThreadGroup, Runnable) - Constructor for class org.apache.hadoop.util.Daemon
Construct a daemon thread to be part of a specified thread group.
DancingLinks<ColumnName> - Class in org.apache.hadoop.examples.dancing
A generic solver for tile laying problems using Knuth's dancing link algorithm.
DancingLinks() - Constructor for class org.apache.hadoop.examples.dancing.DancingLinks
 
DancingLinks.SolutionAcceptor<ColumnName> - Interface in org.apache.hadoop.examples.dancing
Applications should implement this to receive the solutions to their problems.
DATA_FIELD_SEPERATOR - Static variable in class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionHelper
 
DATA_FILE_NAME - Static variable in class org.apache.hadoop.io.MapFile
The name of the data file.
DataChecksum - Class in org.apache.hadoop.util
This class provides inteface and utilities for processing checksums for DFS data transfers.
DataDrivenDBInputFormat<T extends DBWritable> - Class in org.apache.hadoop.mapreduce.lib.db
A InputFormat that reads input data from an SQL table.
DataDrivenDBInputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat
 
DataDrivenDBInputFormat.DataDrivenDBInputSplit - Class in org.apache.hadoop.mapreduce.lib.db
A InputSplit that spans a set of rows
DataDrivenDBInputFormat.DataDrivenDBInputSplit() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat.DataDrivenDBInputSplit
Default Constructor
DataDrivenDBInputFormat.DataDrivenDBInputSplit(String, String) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat.DataDrivenDBInputSplit
Convenience Constructor
DataDrivenDBRecordReader<T extends DBWritable> - Class in org.apache.hadoop.mapreduce.lib.db
A RecordReader that reads records from a SQL table, using data-driven WHERE clause splits.
DataDrivenDBRecordReader(DBInputFormat.DBInputSplit, Class<T>, Configuration, Connection, DBConfiguration, String, String[], String, String) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBRecordReader
 
datagramSocket - Variable in class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated.  
DataInputBuffer - Class in org.apache.hadoop.io
A reusable DataInput implementation that reads from an in-memory buffer.
DataInputBuffer() - Constructor for class org.apache.hadoop.io.DataInputBuffer
Constructs a new empty buffer.
DataJoinJob - Class in org.apache.hadoop.contrib.utils.join
This class implements the main function for creating a map/reduce job to join data of different sources.
DataJoinJob() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinJob
 
DataJoinMapperBase - Class in org.apache.hadoop.contrib.utils.join
This abstract class serves as the base class for the mapper class of a data join job.
DataJoinMapperBase() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
 
DataJoinReducerBase - Class in org.apache.hadoop.contrib.utils.join
This abstract class serves as the base class for the reducer class of a data join job.
DataJoinReducerBase() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
 
DataOutputBuffer - Class in org.apache.hadoop.io
A reusable DataOutput implementation that writes to an in-memory buffer.
DataOutputBuffer() - Constructor for class org.apache.hadoop.io.DataOutputBuffer
Constructs a new empty buffer.
DataOutputBuffer(int) - Constructor for class org.apache.hadoop.io.DataOutputBuffer
 
dateForm - Static variable in class org.apache.hadoop.fs.FsShell
 
DateSplitter - Class in org.apache.hadoop.mapreduce.lib.db
Implement DBSplitter over date/time values.
DateSplitter() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DateSplitter
 
dateToString(Date) - Method in class org.apache.hadoop.mapreduce.lib.db.DateSplitter
Given a Date 'd', format it as a string for use in a SQL date comparison operation.
dateToString(Date) - Method in class org.apache.hadoop.mapreduce.lib.db.OracleDateSplitter
 
DBConfiguration - Class in org.apache.hadoop.mapred.lib.db
A container for configuration property names for jobs with DB input/output.
DBConfiguration - Class in org.apache.hadoop.mapreduce.lib.db
A container for configuration property names for jobs with DB input/output.
DBConfiguration(Configuration) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
DBCountPageView - Class in org.apache.hadoop.examples
This is a demonstrative program, which uses DBInputFormat for reading the input data from a database, and DBOutputFormat for writing the data to the database.
DBCountPageView() - Constructor for class org.apache.hadoop.examples.DBCountPageView
 
DBInputFormat<T extends DBWritable> - Class in org.apache.hadoop.mapred.lib.db
A InputFormat that reads input data from an SQL table.
DBInputFormat() - Constructor for class org.apache.hadoop.mapred.lib.db.DBInputFormat
 
DBInputFormat<T extends DBWritable> - Class in org.apache.hadoop.mapreduce.lib.db
A InputFormat that reads input data from an SQL table.
DBInputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
DBInputFormat.DBInputSplit - Class in org.apache.hadoop.mapred.lib.db
A InputSplit that spans a set of rows
DBInputFormat.DBInputSplit() - Constructor for class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBInputSplit
Default Constructor
DBInputFormat.DBInputSplit(long, long) - Constructor for class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBInputSplit
Convenience Constructor
DBInputFormat.DBInputSplit - Class in org.apache.hadoop.mapreduce.lib.db
A InputSplit that spans a set of rows
DBInputFormat.DBInputSplit() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit
Default Constructor
DBInputFormat.DBInputSplit(long, long) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit
Convenience Constructor
DBInputFormat.DBRecordReader - Class in org.apache.hadoop.mapred.lib.db
A RecordReader that reads records from a SQL table.
DBInputFormat.DBRecordReader(DBInputFormat.DBInputSplit, Class<T>, JobConf) - Constructor for class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBRecordReader
 
DBInputFormat.NullDBWritable - Class in org.apache.hadoop.mapred.lib.db
A Class that does nothing, implementing DBWritable
DBInputFormat.NullDBWritable() - Constructor for class org.apache.hadoop.mapred.lib.db.DBInputFormat.NullDBWritable
 
DBInputFormat.NullDBWritable - Class in org.apache.hadoop.mapreduce.lib.db
A Class that does nothing, implementing DBWritable
DBInputFormat.NullDBWritable() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBInputFormat.NullDBWritable
 
DBOutputFormat<K extends DBWritable,V> - Class in org.apache.hadoop.mapred.lib.db
A OutputFormat that sends the reduce output to a SQL table.
DBOutputFormat() - Constructor for class org.apache.hadoop.mapred.lib.db.DBOutputFormat
 
DBOutputFormat<K extends DBWritable,V> - Class in org.apache.hadoop.mapreduce.lib.db
A OutputFormat that sends the reduce output to a SQL table.
DBOutputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat
 
DBOutputFormat.DBRecordWriter - Class in org.apache.hadoop.mapred.lib.db
A RecordWriter that writes the reduce output to a SQL table
DBOutputFormat.DBRecordWriter(Connection, PreparedStatement) - Constructor for class org.apache.hadoop.mapred.lib.db.DBOutputFormat.DBRecordWriter
 
DBOutputFormat.DBRecordWriter - Class in org.apache.hadoop.mapreduce.lib.db
A RecordWriter that writes the reduce output to a SQL table
DBOutputFormat.DBRecordWriter() - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter
 
DBOutputFormat.DBRecordWriter(Connection, PreparedStatement) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter
 
DBRecordReader<T extends DBWritable> - Class in org.apache.hadoop.mapreduce.lib.db
A RecordReader that reads records from a SQL table.
DBRecordReader(DBInputFormat.DBInputSplit, Class<T>, Configuration, Connection, DBConfiguration, String, String[], String) - Constructor for class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
DBSplitter - Interface in org.apache.hadoop.mapreduce.lib.db
DBSplitter will generate DBInputSplits to use with DataDrivenDBInputFormat.
DBWritable - Interface in org.apache.hadoop.mapred.lib.db
Objects that are read from/written to a database should implement DBWritable.
DBWritable - Interface in org.apache.hadoop.mapreduce.lib.db
Objects that are read from/written to a database should implement DBWritable.
debug_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
debugStream - Variable in class org.apache.hadoop.record.compiler.generated.RccTokenManager
 
decDfsUsed(long) - Method in class org.apache.hadoop.fs.DU
Decrease how much disk space we use.
decode(byte[]) - Static method in class org.apache.hadoop.io.Text
Converts the provided byte array to a String using the UTF-8 encoding.
decode(byte[], int, int) - Static method in class org.apache.hadoop.io.Text
 
decode(byte[], int, int, boolean) - Static method in class org.apache.hadoop.io.Text
Converts the provided byte array to a String using the UTF-8 encoding.
decodeFromUrlString(String) - Method in class org.apache.hadoop.security.token.Token
Decode the given url safe string into this token.
decodeJobHistoryFileName(String) - Static method in class org.apache.hadoop.mapred.JobHistory.JobInfo
Helper function to decode the URL of the filename of the job-history log file.
decodeVIntSize(byte) - Static method in class org.apache.hadoop.io.WritableUtils
Parse the first byte of a vint/vlong to determine the number of bytes
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.BlockDecompressorStream
 
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyDecompressor
 
decompress(byte[], int, int) - Method in interface org.apache.hadoop.io.compress.Decompressor
Fills specified buffer with uncompressed data.
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.DecompressorStream
 
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.snappy.SnappyDecompressor
Fills specified buffer with uncompressed data.
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.zlib.BuiltInGzipDecompressor
Decompress the data (gzip header, deflate stream, gzip trailer) in the provided buffer.
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.zlib.BuiltInZlibInflater
 
decompress(byte[], int, int) - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
 
Decompressor - Interface in org.apache.hadoop.io.compress
Specification of a stream-based 'de-compressor' which can be plugged into a CompressionInputStream to compress data.
decompressor - Variable in class org.apache.hadoop.io.compress.DecompressorStream
 
DecompressorStream - Class in org.apache.hadoop.io.compress
 
DecompressorStream(InputStream, Decompressor, int) - Constructor for class org.apache.hadoop.io.compress.DecompressorStream
 
DecompressorStream(InputStream, Decompressor) - Constructor for class org.apache.hadoop.io.compress.DecompressorStream
 
DecompressorStream(InputStream) - Constructor for class org.apache.hadoop.io.compress.DecompressorStream
Allow derived classes to directly set the underlying stream.
decr() - Method in class org.apache.hadoop.metrics2.lib.MetricMutableGauge
Decrement the value of the metric by 1
decr() - Method in class org.apache.hadoop.metrics2.lib.MetricMutableGaugeInt
 
decr(int) - Method in class org.apache.hadoop.metrics2.lib.MetricMutableGaugeInt
decrement by delta
decr() - Method in class org.apache.hadoop.metrics2.lib.MetricMutableGaugeLong
 
decr(long) - Method in class org.apache.hadoop.metrics2.lib.MetricMutableGaugeLong
decrement by delta
decr(String) - Method in class org.apache.hadoop.metrics2.lib.MetricsRegistry
Decrement a metric by name.
decr(String, MetricMutableFactory) - Method in class org.apache.hadoop.metrics2.lib.MetricsRegistry
Decrement a metric by name.
DEFAULT - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
DEFAULT_BLOCK_SIZE - Static variable in class org.apache.hadoop.fs.ftp.FTPFileSystem
 
DEFAULT_BUFFER_SIZE - Static variable in class org.apache.hadoop.fs.ftp.FTPFileSystem
 
DEFAULT_CONTEXT - Static variable in class org.apache.hadoop.metrics2.impl.MetricsRecordImpl
 
DEFAULT_DMAX - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
DEFAULT_HOST_LEVEL - Static variable in class org.apache.hadoop.net.NetworkTopology
 
DEFAULT_LOG_INTERVAL - Static variable in class org.apache.hadoop.contrib.failmon.Environment
 
DEFAULT_LOG_INTERVAL - Static variable in class org.apache.hadoop.contrib.failmon.Executor
 
DEFAULT_MAPRED_TASK_JAVA_OPTS - Static variable in class org.apache.hadoop.mapred.JobConf
 
DEFAULT_MR_COMBINE_RECORDS_BEFORE_PROGRESS - Static variable in class org.apache.hadoop.mapred.Task
 
DEFAULT_PATH - Static variable in class org.apache.hadoop.mapred.lib.TotalOrderPartitioner
 
DEFAULT_PATH - Static variable in class org.apache.hadoop.mapreduce.lib.partition.TotalOrderPartitioner
 
DEFAULT_PERIOD - Static variable in interface org.apache.hadoop.metrics.MetricsContext
Deprecated. Default period in seconds at which data is sent to the metrics system.
DEFAULT_POLICY_PROVIDER - Static variable in class org.apache.hadoop.security.authorize.PolicyProvider
A default PolicyProvider without any defined services.
DEFAULT_POLL_INTERVAL - Static variable in class org.apache.hadoop.contrib.failmon.Environment
 
DEFAULT_POLL_INTERVAL - Static variable in class org.apache.hadoop.contrib.failmon.Executor
 
DEFAULT_PORT - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
DEFAULT_QUEUE_NAME - Static variable in class org.apache.hadoop.mapred.JobConf
Name of the queue to which jobs will be submitted, if no queue name is mentioned.
DEFAULT_RACK - Static variable in class org.apache.hadoop.net.NetworkTopology
 
DEFAULT_SLOPE - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
DEFAULT_TMAX - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
DEFAULT_UMASK - Static variable in class org.apache.hadoop.fs.permission.FsPermission
 
DEFAULT_UNITS - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
DefaultCodec - Class in org.apache.hadoop.io.compress
 
DefaultCodec() - Constructor for class org.apache.hadoop.io.compress.DefaultCodec
 
defaultContexts - Variable in class org.apache.hadoop.http.HttpServer
 
DefaultJobHistoryParser - Class in org.apache.hadoop.mapred
Default parser for job history files.
DefaultJobHistoryParser() - Constructor for class org.apache.hadoop.mapred.DefaultJobHistoryParser
 
DefaultMetricsSystem - Enum in org.apache.hadoop.metrics2.lib
The default metrics system singleton
DefaultStringifier<T> - Class in org.apache.hadoop.io
DefaultStringifier is the default implementation of the Stringifier interface which stringifies the objects using base64 encoding of the serialized version of the objects.
DefaultStringifier(Configuration, Class<T>) - Constructor for class org.apache.hadoop.io.DefaultStringifier
 
DefaultTaskController - Class in org.apache.hadoop.mapred
The default implementation for controlling tasks.
DefaultTaskController() - Constructor for class org.apache.hadoop.mapred.DefaultTaskController
 
define(Class, WritableComparator) - Static method in class org.apache.hadoop.io.WritableComparator
Register an optimized comparator for a WritableComparable implementation.
define(Class, RecordComparator) - Static method in class org.apache.hadoop.record.RecordComparator
Register an optimized comparator for a Record implementation.
defineFilter(Context, String, String, Map<String, String>, String[]) - Method in class org.apache.hadoop.http.HttpServer
Define a filter for a context and set up default url mappings.
DelegatingInputFormat<K,V> - Class in org.apache.hadoop.mapred.lib
An InputFormat that delegates behaviour of paths to multiple other InputFormats.
DelegatingInputFormat() - Constructor for class org.apache.hadoop.mapred.lib.DelegatingInputFormat
 
DelegatingInputFormat<K,V> - Class in org.apache.hadoop.mapreduce.lib.input
An InputFormat that delegates behavior of paths to multiple other InputFormats.
DelegatingInputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.input.DelegatingInputFormat
 
DelegatingMapper<K1,V1,K2,V2> - Class in org.apache.hadoop.mapred.lib
An Mapper that delegates behaviour of paths to multiple other mappers.
DelegatingMapper() - Constructor for class org.apache.hadoop.mapred.lib.DelegatingMapper
 
DelegatingMapper<K1,V1,K2,V2> - Class in org.apache.hadoop.mapreduce.lib.input
An Mapper that delegates behavior of paths to multiple other mappers.
DelegatingMapper() - Constructor for class org.apache.hadoop.mapreduce.lib.input.DelegatingMapper
 
DelegatingRecordReader<K,V> - Class in org.apache.hadoop.mapreduce.lib.input
This is a delegating RecordReader, which delegates the functionality to the underlying record reader in TaggedInputSplit
DelegatingRecordReader(InputSplit, TaskAttemptContext) - Constructor for class org.apache.hadoop.mapreduce.lib.input.DelegatingRecordReader
Constructs the DelegatingRecordReader.
DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DELEGATION_KEY_UPDATE_INTERVAL_KEY - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DELEGATION_TOKEN_MAX_LIFETIME_KEY - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DELEGATION_TOKEN_RENEW_INTERVAL_KEY - Static variable in class org.apache.hadoop.mapred.JobTracker
 
DelegationKey - Class in org.apache.hadoop.security.token.delegation
Key used for generating and verifying delegation tokens
DelegationKey() - Constructor for class org.apache.hadoop.security.token.delegation.DelegationKey
 
DelegationKey(int, long, SecretKey) - Constructor for class org.apache.hadoop.security.token.delegation.DelegationKey
 
DelegationTokenIdentifier - Class in org.apache.hadoop.mapreduce.security.token.delegation
A delegation token identifier that is specific to MapReduce.
DelegationTokenIdentifier() - Constructor for class org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier
Create an empty delegation token identifier for reading into.
DelegationTokenIdentifier(Text, Text, Text) - Constructor for class org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier
Create a new delegation token identifier
DelegationTokenRenewal - Class in org.apache.hadoop.mapreduce.security.token
 
DelegationTokenRenewal() - Constructor for class org.apache.hadoop.mapreduce.security.token.DelegationTokenRenewal
 
DelegationTokenSecretManager - Class in org.apache.hadoop.mapreduce.security.token.delegation
A MapReduce specific delegation token secret manager.
DelegationTokenSecretManager(long, long, long, long) - Constructor for class org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenSecretManager
Create a secret manager
DelegationTokenSelector - Class in org.apache.hadoop.mapreduce.security.token.delegation
A delegation token that is specialized for MapReduce
DelegationTokenSelector() - Constructor for class org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenSelector
 
delegationTokenSequenceNumber - Variable in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
Sequence number to create DelegationTokenIdentifier.
DELETE - Static variable in class org.apache.hadoop.contrib.index.mapred.DocumentAndOp.Op
 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Implement the delete(Path, boolean) in checksum file system.
delete(Path) - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. Use delete(Path, boolean) instead
delete(Path, boolean) - Method in class org.apache.hadoop.fs.FileSystem
Delete a file.
delete(Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
Deprecated. 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.FilterFileSystem
Delete a file
delete(Path) - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
Deprecated. Use delete(Path, boolean) instead
delete(Path, boolean) - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.HarFileSystem
Not implemented.
delete(Path, boolean) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
delete(Path) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
Deprecated. 
delete(Path) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
Deprecated. 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.s3.S3FileSystem
 
delete(Path) - Method in class org.apache.hadoop.fs.s3.S3FileSystem
Deprecated. 
delete(Path) - Method in class org.apache.hadoop.fs.s3native.NativeS3FileSystem
Deprecated. 
delete(Path, boolean) - Method in class org.apache.hadoop.fs.s3native.NativeS3FileSystem
 
delete(FileSystem, String) - Static method in class org.apache.hadoop.io.BloomMapFile
 
delete(FileSystem, String) - Static method in class org.apache.hadoop.io.MapFile
Deletes the named map file.
delete(Key) - Method in class org.apache.hadoop.util.bloom.CountingBloomFilter
Removes a specified key from this counting Bloom filter.
deleteAsUser(String, String) - Method in class org.apache.hadoop.mapred.DefaultTaskController
Delete the user's files under all of the task tracker root directories.
deleteAsUser(String, String) - Method in class org.apache.hadoop.mapred.TaskController
Delete the user's files under all of the task tracker root directories.
deleteBlock(Block) - Method in interface org.apache.hadoop.fs.s3.FileSystemStore
 
deleteCacheInfoUpdate(TrackerDistributedCacheManager.CacheStatus) - Method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager.BaseDirManager
Decrement the size and sub directory count of the cache from baseDirSize and baseDirNumberSubDir.
deleteFile(String) - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
deleteINode(Path) - Method in interface org.apache.hadoop.fs.s3.FileSystemStore
 
DeleteJobEvent - Class in org.apache.hadoop.mapreduce.server.tasktracker.userlogs
This is an UserLogEvent sent when job logs should be deleted.
DeleteJobEvent(JobID) - Constructor for class org.apache.hadoop.mapreduce.server.tasktracker.userlogs.DeleteJobEvent
Create the event to delete job log directory.
deleteJobLogs(JobID) - Method in class org.apache.hadoop.mapred.UserLogCleaner
 
deleteLocalFiles() - Method in class org.apache.hadoop.mapred.JobConf
 
deleteLocalFiles(String) - Method in class org.apache.hadoop.mapred.JobConf
 
deleteLogAsUser(String, String) - Method in class org.apache.hadoop.mapred.DefaultTaskController
Delete the user's files under the userlogs directory.
deleteLogAsUser(String, String) - Method in class org.apache.hadoop.mapred.TaskController
Delete the user's files under the userlogs directory.
deleteOnExit(Path) - Method in class org.apache.hadoop.fs.FileSystem
Mark a path to be deleted when FileSystem is closed.
deleteTermIterator() - Method in class org.apache.hadoop.contrib.index.mapred.IntermediateForm
Get an iterator for the delete terms in the intermediate form.
DEPENDENT_FAILED - Static variable in class org.apache.hadoop.mapred.jobcontrol.Job
 
DEPRECATED_UMASK_LABEL - Static variable in class org.apache.hadoop.fs.permission.FsPermission
umask property label
depth() - Method in class org.apache.hadoop.fs.Path
Return the number of elements in this path.
DEPTH_THRESH - Static variable in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
This constant is accessible by subclasses for historical purposes.
DESCRIPTION - Static variable in class org.apache.hadoop.fs.shell.Count
 
description - Variable in class org.apache.hadoop.metrics2.lib.MetricMutable
description of the metric
description() - Method in class org.apache.hadoop.metrics2.Metric
Get the description of the metric
description() - Method in class org.apache.hadoop.metrics2.MetricsTag
Get the description of the tag
deserialize(InputStream) - Static method in class org.apache.hadoop.fs.s3.INode
 
deserialize(T) - Method in interface org.apache.hadoop.io.serializer.Deserializer
Deserialize the next object from the underlying input stream.
deserialize(RecordInput, String) - Method in class org.apache.hadoop.record.meta.RecordTypeInfo
Deserialize the type information for a record
deserialize(RecordInput, String) - Method in class org.apache.hadoop.record.Record
Deserialize a record with a tag (usually field name)
deserialize(RecordInput) - Method in class org.apache.hadoop.record.Record
Deserialize a record without a tag
Deserializer<T> - Interface in org.apache.hadoop.io.serializer
Provides a facility for deserializing objects of type from an InputStream.
DeserializerComparator<T> - Class in org.apache.hadoop.io.serializer
A RawComparator that uses a Deserializer to deserialize the objects to be compared so that the standard Comparator can be used to compare them.
DeserializerComparator(Deserializer<T>) - Constructor for class org.apache.hadoop.io.serializer.DeserializerComparator
 
desiredMaps() - Method in class org.apache.hadoop.mapred.JobInProgress
 
desiredReduces() - Method in class org.apache.hadoop.mapred.JobInProgress
 
desiredTasks() - Method in class org.apache.hadoop.mapred.JobInProgress
Return total number of map and reduce tasks desired by the job.
destroy() - Method in class org.apache.hadoop.http.HttpServer.QuotingInputFilter
 
destroy() - Method in class org.apache.hadoop.http.lib.StaticUserWebFilter.StaticUserFilter
 
destroy() - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Destroys the filter.
destroy() - Method in interface org.apache.hadoop.security.authentication.server.AuthenticationHandler
Destroys the authentication handler instance.
destroy() - Method in class org.apache.hadoop.security.authentication.server.KerberosAuthenticationHandler
Releases any resources initialized by the authentication handler.
destroy() - Method in class org.apache.hadoop.security.authentication.server.PseudoAuthenticationHandler
Releases any resources initialized by the authentication handler.
destroy() - Method in class org.apache.hadoop.security.Krb5AndCertsSslSocketConnector.Krb5SslFilter
 
detailed() - Method in class org.apache.hadoop.ipc.metrics.RpcInstrumentation
 
detailedUsage_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
determineCacheVisibilities(Configuration) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
Determines the visibilities of the distributed cache files and archives.
determineTimestamps(Configuration) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
Determines timestamps of files to be cached, and stores those in the configuration.
DF - Class in org.apache.hadoop.fs
Filesystem disk space usage statistics.
DF(File, Configuration) - Constructor for class org.apache.hadoop.fs.DF
 
DF(File, long) - Constructor for class org.apache.hadoop.fs.DF
 
DF_INTERVAL_DEFAULT - Static variable in class org.apache.hadoop.fs.DF
Default DF refresh interval.
dfmt(double) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
digest(byte[]) - Static method in class org.apache.hadoop.io.MD5Hash
Construct a hash value for a byte array.
digest(InputStream) - Static method in class org.apache.hadoop.io.MD5Hash
Construct a hash value for the content from the InputStream.
digest(byte[], int, int) - Static method in class org.apache.hadoop.io.MD5Hash
Construct a hash value for a byte array.
digest(String) - Static method in class org.apache.hadoop.io.MD5Hash
Construct a hash value for a String.
digest(UTF8) - Static method in class org.apache.hadoop.io.MD5Hash
Construct a hash value for a String.
DIR_FORMATS - Static variable in class org.apache.hadoop.mapreduce.lib.input.MultipleInputs
 
DIR_MAPPERS - Static variable in class org.apache.hadoop.mapreduce.lib.input.MultipleInputs
 
DIRECTORY_INODE - Static variable in class org.apache.hadoop.fs.s3.INode
 
disable_tracing() - Method in class org.apache.hadoop.record.compiler.generated.Rcc
 
DISABLED_MEMORY_LIMIT - Static variable in class org.apache.hadoop.mapred.JobConf
A value which if set for memory related configuration options, indicates that the options are turned off.
DiskChecker - Class in org.apache.hadoop.util
Class that provides utility functions for checking disk problem
DiskChecker() - Constructor for class org.apache.hadoop.util.DiskChecker
 
DiskChecker.DiskErrorException - Exception in org.apache.hadoop.util
 
DiskChecker.DiskErrorException(String) - Constructor for exception org.apache.hadoop.util.DiskChecker.DiskErrorException
 
DiskChecker.DiskOutOfSpaceException - Exception in org.apache.hadoop.util
 
DiskChecker.DiskOutOfSpaceException(String) - Constructor for exception org.apache.hadoop.util.DiskChecker.DiskOutOfSpaceException
 
displayByteArray(byte[]) - Static method in class org.apache.hadoop.io.WritableUtils
 
displayTasks(JobID, String, String) - Method in class org.apache.hadoop.mapred.JobClient
Display the information about a job's tasks, of a particular type and in a particular state
dispose() - Method in class org.apache.hadoop.security.SaslRpcClient
Release resources used by wrapped saslClient
DistributedCache - Class in org.apache.hadoop.filecache
Distribute application-specific large, read-only files efficiently.
DistributedCache() - Constructor for class org.apache.hadoop.filecache.DistributedCache
 
DistributedPentomino - Class in org.apache.hadoop.examples.dancing
Launch a distributed pentomino solver.
DistributedPentomino() - Constructor for class org.apache.hadoop.examples.dancing.DistributedPentomino
 
DistributedPentomino.PentMap - Class in org.apache.hadoop.examples.dancing
Each map takes a line, which represents a prefix move and finds all of the solutions that start with that prefix.
DistributedPentomino.PentMap() - Constructor for class org.apache.hadoop.examples.dancing.DistributedPentomino.PentMap
 
DNS - Class in org.apache.hadoop.net
A class that provides direct and reverse lookup functionalities, allowing the querying of specific network interfaces or nameservers.
DNS() - Constructor for class org.apache.hadoop.net.DNS
 
DNSToSwitchMapping - Interface in org.apache.hadoop.net
An interface that should be implemented to allow pluggable DNS-name/IP-address to RackID resolvers.
doAbort() - Method in class org.apache.hadoop.mapred.ShuffleExceptionTracker
 
doAs(PrivilegedAction<T>) - Method in class org.apache.hadoop.security.UserGroupInformation
Run the given action as the user.
doAs(PrivilegedExceptionAction<T>) - Method in class org.apache.hadoop.security.UserGroupInformation
Run the given action as the user, potentially throwing an exception.
DocumentAndOp - Class in org.apache.hadoop.contrib.index.mapred
This class represents an indexing operation.
DocumentAndOp() - Constructor for class org.apache.hadoop.contrib.index.mapred.DocumentAndOp
Constructor for no operation.
DocumentAndOp(DocumentAndOp.Op, Document) - Constructor for class org.apache.hadoop.contrib.index.mapred.DocumentAndOp
Constructor for an insert operation.
DocumentAndOp(DocumentAndOp.Op, Term) - Constructor for class org.apache.hadoop.contrib.index.mapred.DocumentAndOp
Constructor for a delete operation.
DocumentAndOp(DocumentAndOp.Op, Document, Term) - Constructor for class org.apache.hadoop.contrib.index.mapred.DocumentAndOp
Constructor for an insert, a delete or an update operation.
DocumentAndOp.Op - Class in org.apache.hadoop.contrib.index.mapred
This class represents the type of an operation - an insert, a delete or an update.
DocumentID - Class in org.apache.hadoop.contrib.index.mapred
The class represents a document id, which is of type text.
DocumentID() - Constructor for class org.apache.hadoop.contrib.index.mapred.DocumentID
Constructor.
doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.hadoop.http.HttpServer.QuotingInputFilter
 
doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.hadoop.http.lib.StaticUserWebFilter.StaticUserFilter
 
doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
If the request has a valid authentication token it allows the request to continue to the target resource, otherwise it triggers an authentication sequence using the configured AuthenticationHandler.
doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.hadoop.security.Krb5AndCertsSslSocketConnector.Krb5SslFilter
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.http.AdminAuthorizedServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.http.HttpServer.StackServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.jmx.JMXJsonServlet
Process a GET request for the specified resource.
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.log.LogLevel.Servlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.mapred.RawHistoryFileServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.mapred.TaskGraphServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.mapred.TaskLogServlet
Get the logs via http.
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.mapred.TaskTracker.MapOutputServlet
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.metrics.MetricsServlet
Deprecated.  
done(TaskUmbilicalProtocol, Task.TaskReporter) - Method in class org.apache.hadoop.mapred.Task
 
done(TaskAttemptID, JvmContext) - Method in class org.apache.hadoop.mapred.TaskTracker
The task is done.
done(TaskAttemptID, JvmContext) - Method in interface org.apache.hadoop.mapred.TaskUmbilicalProtocol
Report that the task is successfully completed.
done() - Method in class org.apache.hadoop.metrics2.util.TryIterator
Implementations of TryIterator.tryNext() must call this method when there are no more elements left in the iteration.
Done() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
done() - Method in interface org.apache.hadoop.record.Index
 
DoNotPool - Annotation Type in org.apache.hadoop.io.compress
This is a marker annotation that marks a compressor or decompressor type as not to be pooled.
doSync() - Method in class org.apache.hadoop.io.SequenceFile.Sorter.SegmentDescriptor
Do the sync checks
DOT_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
DOUBLE - Static variable in class org.apache.hadoop.record.meta.TypeID.RIOType
 
DOUBLE_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
DOUBLE_VALUE_SUM - Static variable in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
 
DoubleTypeID - Static variable in class org.apache.hadoop.record.meta.TypeID
 
DoubleValueSum - Class in org.apache.hadoop.mapred.lib.aggregate
This class implements a value aggregator that sums up a sequence of double values.
DoubleValueSum() - Constructor for class org.apache.hadoop.mapred.lib.aggregate.DoubleValueSum
The default constructor
DoubleWritable - Class in org.apache.hadoop.io
Writable for Double values.
DoubleWritable() - Constructor for class org.apache.hadoop.io.DoubleWritable
 
DoubleWritable(double) - Constructor for class org.apache.hadoop.io.DoubleWritable
 
DoubleWritable.Comparator - Class in org.apache.hadoop.io
A Comparator optimized for DoubleWritable.
DoubleWritable.Comparator() - Constructor for class org.apache.hadoop.io.DoubleWritable.Comparator
 
doUpdates(MetricsContext) - Method in class org.apache.hadoop.metrics.jvm.JvmMetrics
Deprecated. This will be called periodically (with the period being configuration dependent).
doUpdates(MetricsContext) - Method in interface org.apache.hadoop.metrics.Updater
Deprecated. Timer-based call-back from the metric library.
downgrade(JobID) - Static method in class org.apache.hadoop.mapred.JobID
Downgrade a new JobID to an old one
downgrade(TaskAttemptID) - Static method in class org.apache.hadoop.mapred.TaskAttemptID
Downgrade a new TaskAttemptID to an old one
downgrade(TaskID) - Static method in class org.apache.hadoop.mapred.TaskID
Downgrade a new TaskID to an old one
downloadCacheObject(Configuration, URI, Path, long, boolean, FsPermission) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
Download a given path to the local file system.
downloadPrivateCache(Configuration) - Static method in class org.apache.hadoop.mapred.JobLocalizer
Download the parts of the distributed cache that are private.
driver(String[]) - Static method in class org.apache.hadoop.record.compiler.generated.Rcc
 
driver(String[]) - Method in class org.apache.hadoop.util.ProgramDriver
This is a driver for the example programs.
DRIVER_CLASS_PROPERTY - Static variable in class org.apache.hadoop.mapred.lib.db.DBConfiguration
The JDBC Driver class name
DRIVER_CLASS_PROPERTY - Static variable in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
The JDBC Driver class name
DU - Class in org.apache.hadoop.fs
Filesystem disk space usage statistics.
DU(File, long) - Constructor for class org.apache.hadoop.fs.DU
Keeps track of disk usage.
DU(File, Configuration) - Constructor for class org.apache.hadoop.fs.DU
Keeps track of disk usage.
dump() - Method in interface org.apache.hadoop.fs.s3.FileSystemStore
Diagnostic method to dump all INodes to the console.
dumpConfiguration(Configuration, Writer) - Static method in class org.apache.hadoop.conf.Configuration
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}...
DumpTypedBytes - Class in org.apache.hadoop.streaming
Utility program that fetches all files that match a given pattern and dumps their content to stdout as typed bytes.
DumpTypedBytes(Configuration) - Constructor for class org.apache.hadoop.streaming.DumpTypedBytes
 
DumpTypedBytes() - Constructor for class org.apache.hadoop.streaming.DumpTypedBytes
 
DynamicBloomFilter - Class in org.apache.hadoop.util.bloom
Implements a dynamic Bloom filter, as defined in the INFOCOM 2006 paper.
DynamicBloomFilter() - Constructor for class org.apache.hadoop.util.bloom.DynamicBloomFilter
Zero-args constructor for the serialization.
DynamicBloomFilter(int, int, int, int) - Constructor for class org.apache.hadoop.util.bloom.DynamicBloomFilter
Constructor.

E

emit(TupleWritable) - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader
For each tuple emitted, return a value (typically one of the values in the tuple).
emit(TupleWritable) - Method in class org.apache.hadoop.mapred.join.OverrideRecordReader
Emit the value with the highest position in the tuple.
emitMetric(String, String, String) - Method in class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated.  
emitMetric(String, String, String) - Method in class org.apache.hadoop.metrics.ganglia.GangliaContext31
 
emitMetric(String, String, String, String, GangliaConf, AbstractGangliaSink.GangliaSlope) - Method in class org.apache.hadoop.metrics2.sink.ganglia.GangliaSink30
The method sends metrics to Ganglia servers.
emitMetric(String, String, String, String, GangliaConf, AbstractGangliaSink.GangliaSlope) - Method in class org.apache.hadoop.metrics2.sink.ganglia.GangliaSink31
The method sends metrics to Ganglia servers.
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.file.FileContext
Deprecated. Emits a metrics record to a file.
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated.  
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Sends a record to the metrics system.
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.CompositeContext
Deprecated.  
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.NoEmitMetricsContext
Deprecated. Do-nothing version of emitRecord
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.NullContext
Deprecated. Do-nothing version of emitRecord
emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.NullContextWithUpdateThread
Deprecated. Do-nothing version of emitRecord
emitToGangliaHosts() - Method in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
Sends Ganglia Metrics to the configured hosts
EMPTY_ARRAY - Static variable in class org.apache.hadoop.mapred.TaskCompletionEvent
 
EMPTY_TASK_SPLIT - Static variable in class org.apache.hadoop.mapreduce.split.JobSplit
 
emptyText - Static variable in class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionHelper
 
enable_tracing() - Method in class org.apache.hadoop.record.compiler.generated.Rcc
 
encode(String) - Static method in class org.apache.hadoop.io.Text
Converts the provided String to bytes using the UTF-8 encoding.
encode(String, boolean) - Static method in class org.apache.hadoop.io.Text
Converts the provided String to bytes using the UTF-8 encoding.
encodeJobHistoryFileName(String) - Static method in class org.apache.hadoop.mapred.JobHistory.JobInfo
Helper function to encode the URL of the filename of the job-history log file.
encodeJobHistoryFilePath(String) - Static method in class org.apache.hadoop.mapred.JobHistory.JobInfo
Helper function to encode the URL of the path of the job-history log file.
encodeToUrlString() - Method in class org.apache.hadoop.security.token.Token
Encode this token as a url safe string
end() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
end() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyDecompressor
 
end() - Method in interface org.apache.hadoop.io.compress.Compressor
Closes the compressor and discards any unprocessed input.
end() - Method in interface org.apache.hadoop.io.compress.Decompressor
Closes the decompressor and discards any unprocessed input.
end() - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
Closes the compressor and discards any unprocessed input.
end() - Method in class org.apache.hadoop.io.compress.snappy.SnappyDecompressor
Resets decompressor and input and output buffers so that a new set of input data can be processed.
end() - Method in class org.apache.hadoop.io.compress.zlib.BuiltInGzipDecompressor
Closes the decompressor and discards any unprocessed input.
end() - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
 
end() - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
 
END_OF_BLOCK - Static variable in interface org.apache.hadoop.io.compress.bzip2.BZip2Constants
End of a BZip2 block
END_OF_STREAM - Static variable in interface org.apache.hadoop.io.compress.bzip2.BZip2Constants
End of BZip2 stream.
endColumn - Variable in class org.apache.hadoop.record.compiler.generated.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
endCycle(int) - Method in class org.apache.hadoop.util.QueueProcessingStatistics
 
endLine - Variable in class org.apache.hadoop.record.compiler.generated.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
endMap(String) - Method in class org.apache.hadoop.record.BinaryRecordInput
 
endMap(TreeMap, String) - Method in class org.apache.hadoop.record.BinaryRecordOutput
 
endMap(String) - Method in class org.apache.hadoop.record.CsvRecordInput
 
endMap(TreeMap, String) - Method in class org.apache.hadoop.record.CsvRecordOutput
 
endMap(String) - Method in interface org.apache.hadoop.record.RecordInput
Check the mark for end of the serialized map.
endMap(TreeMap, String) - Method in interface org.apache.hadoop.record.RecordOutput
Mark the end of a serialized map.
endMap(String) - Method in class org.apache.hadoop.record.XmlRecordInput
 
endMap(TreeMap, String) - Method in class org.apache.hadoop.record.XmlRecordOutput
 
endMap(String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordInput
 
endMap(TreeMap, String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordOutput
 
endRecord(String) - Method in class org.apache.hadoop.record.BinaryRecordInput
 
endRecord(Record, String) - Method in class org.apache.hadoop.record.BinaryRecordOutput
 
endRecord(String) - Method in class org.apache.hadoop.record.CsvRecordInput
 
endRecord(Record, String) - Method in class org.apache.hadoop.record.CsvRecordOutput
 
endRecord(String) - Method in interface org.apache.hadoop.record.RecordInput
Check the mark for end of the serialized record.
endRecord(Record, String) - Method in interface org.apache.hadoop.record.RecordOutput
Mark the end of a serialized record.
endRecord(String) - Method in class org.apache.hadoop.record.XmlRecordInput
 
endRecord(Record, String) - Method in class org.apache.hadoop.record.XmlRecordOutput
 
endRecord(String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordInput
 
endRecord(Record, String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordOutput
 
endVector(String) - Method in class org.apache.hadoop.record.BinaryRecordInput
 
endVector(ArrayList, String) - Method in class org.apache.hadoop.record.BinaryRecordOutput
 
endVector(String) - Method in class org.apache.hadoop.record.CsvRecordInput
 
endVector(ArrayList, String) - Method in class org.apache.hadoop.record.CsvRecordOutput
 
endVector(String) - Method in interface org.apache.hadoop.record.RecordInput
Check the mark for end of the serialized vector.
endVector(ArrayList, String) - Method in interface org.apache.hadoop.record.RecordOutput
Mark the end of a serialized vector.
endVector(String) - Method in class org.apache.hadoop.record.XmlRecordInput
 
endVector(ArrayList, String) - Method in class org.apache.hadoop.record.XmlRecordOutput
 
endVector(String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordInput
 
endVector(ArrayList, String) - Method in class org.apache.hadoop.typedbytes.TypedBytesRecordOutput
 
ensureInflated() - Method in class org.apache.hadoop.io.CompressedWritable
Must be called by all methods which access fields to ensure that the data has been uncompressed.
entry() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner
Get an entry to access the key and value.
entrySet() - Method in class org.apache.hadoop.io.MapWritable
entrySet() - Method in class org.apache.hadoop.io.SortedMapWritable
env_ - Variable in class org.apache.hadoop.streaming.StreamJob
 
Environment - Class in org.apache.hadoop.contrib.failmon
This class provides various methods for interaction with the configuration and the operating system environment.
Environment() - Constructor for class org.apache.hadoop.contrib.failmon.Environment
 
Environment - Class in org.apache.hadoop.streaming
This is a class used to get the current environment on the host machines running the map/reduce.
Environment() - Constructor for class org.apache.hadoop.streaming.Environment
 
eof - Variable in class org.apache.hadoop.io.compress.DecompressorStream
 
EOF - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
eol - Variable in exception org.apache.hadoop.record.compiler.generated.ParseException
The end of line string for this machine.
EOS_DELIMITER - Static variable in class org.apache.hadoop.io.compress.bzip2.CBZip2InputStream
 
EQUAL - Static variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
equals(Object) - Method in class org.apache.hadoop.contrib.index.mapred.Shard
 
equals(Object) - Method in class org.apache.hadoop.examples.MultiFileWordCount.WordOffset
 
equals(Object) - Method in class org.apache.hadoop.examples.SecondarySort.IntPair
 
equals(Object) - Method in class org.apache.hadoop.fs.FileChecksum
Return true if both the algorithms and the values are the same.
equals(Object) - Method in class org.apache.hadoop.fs.FileStatus
Compare if this object is equal to another object
equals(Object) - Method in class org.apache.hadoop.fs.Path
 
equals(Object) - Method in class org.apache.hadoop.fs.permission.FsPermission
equals(Object) - Method in class org.apache.hadoop.io.BinaryComparable
Return true if bytes from {#getBytes()} match.
equals(Object) - Method in class org.apache.hadoop.io.BooleanWritable
 
equals(Object) - Method in class org.apache.hadoop.io.BytesWritable
Are the two byte sequences equal?
equals(Object) - Method in class org.apache.hadoop.io.ByteWritable
Returns true iff o is a ByteWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.DoubleWritable
Returns true iff o is a DoubleWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner.Entry
Compare whether this and other points to the same key value.
equals(Object) - Method in class org.apache.hadoop.io.file.tfile.Utils.Version
 
equals(Object) - Method in class org.apache.hadoop.io.FloatWritable
Returns true iff o is a FloatWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.IntWritable
Returns true iff o is a IntWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.LongWritable
Returns true iff o is a LongWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.MD5Hash
Returns true iff o is an MD5Hash whose digest contains the same values.
equals(Object) - Method in class org.apache.hadoop.io.NullWritable
 
equals(Object) - Method in class org.apache.hadoop.io.retry.RetryPolicies.MultipleLinearRandomRetry
 
equals(SequenceFile.Metadata) - Method in class org.apache.hadoop.io.SequenceFile.Metadata
 
equals(Object) - Method in class org.apache.hadoop.io.SequenceFile.Sorter.SegmentDescriptor
 
equals(Object) - Method in class org.apache.hadoop.io.Text
Returns true iff o is a Text with the same contents.
equals(Object) - Method in class org.apache.hadoop.io.UTF8
Deprecated. Returns true iff o is a UTF8 with the same contents.
equals(Object) - Method in class org.apache.hadoop.io.VIntWritable
Returns true iff o is a VIntWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.io.VLongWritable
Returns true iff o is a VLongWritable with the same value.
equals(Object) - Method in class org.apache.hadoop.mapred.Counters
 
equals(Object) - Method in class org.apache.hadoop.mapred.Counters.Group
Checks for (content) equality of Groups
equals(Object) - Method in class org.apache.hadoop.mapred.join.TupleWritable
equals(Object) - Method in class org.apache.hadoop.mapred.join.WrappedRecordReader
Return true iff compareTo(other) retn true.
equals(Object) - Method in class org.apache.hadoop.mapred.TaskCompletionEvent
 
equals(Object) - Method in class org.apache.hadoop.mapred.TaskReport
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.Counter
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.CounterGroup
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.Counters
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.ID
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.JobID
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.TaskAttemptID
 
equals(Object) - Method in class org.apache.hadoop.mapreduce.TaskID
 
equals(Object) - Method in class org.apache.hadoop.metrics2.impl.MetricsRecordImpl
 
equals(Object) - Method in class org.apache.hadoop.metrics2.Metric
 
equals(Object) - Method in class org.apache.hadoop.metrics2.MetricsTag
 
equals(Object) - Method in class org.apache.hadoop.net.SocksSocketFactory
 
equals(Object) - Method in class org.apache.hadoop.net.StandardSocketFactory
 
equals(Object) - Method in class org.apache.hadoop.record.Buffer
 
equals(Object) - Method in class org.apache.hadoop.record.meta.FieldTypeInfo
Two FieldTypeInfos are equal if ach of their fields matches
equals(FieldTypeInfo) - Method in class org.apache.hadoop.record.meta.FieldTypeInfo
 
equals(Object) - Method in class org.apache.hadoop.record.meta.MapTypeID
Two map typeIDs are equal if their constituent elements have the same type
equals(Object) - Method in class org.apache.hadoop.record.meta.TypeID
Two base typeIDs are equal if they refer to the same type
equals(Object) - Method in class org.apache.hadoop.record.meta.VectorTypeID
Two vector typeIDs are equal if their constituent elements have the same type
equals(Object) - Method in class org.apache.hadoop.security.authentication.client.AuthenticatedURL.Token
Return if two token instances are equal.
equals(Object) - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier
equals(Object) - Method in class org.apache.hadoop.security.token.Token
 
equals(Object) - Method in class org.apache.hadoop.security.UserGroupInformation
Compare the subjects to see if they are equal to each other.
equals(Object) - Method in class org.apache.hadoop.util.bloom.Key
 
Errno - Enum in org.apache.hadoop.io.nativeio
Enum representing POSIX errno values.
ESCAPE_CHAR - Static variable in class org.apache.hadoop.util.StringUtils
 
escapeHTML(String) - Static method in class org.apache.hadoop.util.StringUtils
Escapes HTML Special characters present in the string.
escapeString(String) - Static method in class org.apache.hadoop.util.StringUtils
Escape commas in the string using the default escape char
escapeString(String, char, char) - Static method in class org.apache.hadoop.util.StringUtils
Escape charToEscape in the string with the escape char escapeChar
escapeString(String, char, char[]) - Static method in class org.apache.hadoop.util.StringUtils
 
estimate(int, long, JobConf) - Static method in class org.apache.hadoop.examples.PiEstimator
Run a map/reduce job for estimating Pi.
EventCounter - Class in org.apache.hadoop.log
Deprecated. use EventCounter instead
EventCounter() - Constructor for class org.apache.hadoop.log.EventCounter
Deprecated.  
EventCounter - Class in org.apache.hadoop.log.metrics
A log4J Appender that simply counts logging events in three levels: fatal, error and warn.
EventCounter() - Constructor for class org.apache.hadoop.log.metrics.EventCounter
 
EventCounter - Class in org.apache.hadoop.metrics.jvm
Deprecated. use EventCounter instead
EventCounter() - Constructor for class org.apache.hadoop.metrics.jvm.EventCounter
Deprecated.  
EventRecord - Class in org.apache.hadoop.contrib.failmon
Objects of this class represent metrics collected for a specific hardware source.
EventRecord(String, Object[], Calendar, String, String, String, String) - Constructor for class org.apache.hadoop.contrib.failmon.EventRecord
Create the EventRecord given the most common properties among different metric types.
EventRecord() - Constructor for class org.apache.hadoop.contrib.failmon.EventRecord
Create the EventRecord with no fields other than "invalid" as the hostname.
ExampleDriver - Class in org.apache.hadoop.examples
A description of an example program based on its class and a human-readable description.
ExampleDriver() - Constructor for class org.apache.hadoop.examples.ExampleDriver
 
exception() - Method in class org.apache.hadoop.mapred.ShuffleExceptionTracker
Mark the request as an exception occurred.
execCommand(String...) - Static method in class org.apache.hadoop.util.Shell
Static method to execute a shell command.
execCommand(Map<String, String>, String[], long) - Static method in class org.apache.hadoop.util.Shell
Static method to execute a shell command.
execCommand(Map<String, String>, String...) - Static method in class org.apache.hadoop.util.Shell
Static method to execute a shell command.
execShellGetUnixGroups(String) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
execShellGetUserForNetgroup(String) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
execute() - Method in class org.apache.hadoop.record.compiler.ant.RccTask
Invoke the Hadoop record compiler on each record definition file
execute() - Method in class org.apache.hadoop.util.Shell.ShellCommandExecutor
Execute the shell command.
executeQuery(String) - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
executeQuery(String) - Method in class org.apache.hadoop.mapreduce.lib.db.MySQLDataDrivenDBRecordReader
 
executeQuery(String) - Method in class org.apache.hadoop.mapreduce.lib.db.MySQLDBRecordReader
 
Executor - Class in org.apache.hadoop.contrib.failmon
This class executes monitoring jobs on all nodes of the cluster, on which we intend to gather failure metrics.
Executor(Configuration) - Constructor for class org.apache.hadoop.contrib.failmon.Executor
Create an instance of the class and read the configuration file to determine the set of jobs that will be run and the maximum interval for which the thread can sleep before it wakes up to execute a monitoring job on the node.
exists(Path) - Method in class org.apache.hadoop.fs.FileSystem
Check if exists.
exists(Path) - Method in class org.apache.hadoop.fs.LocalFileSystem
Get file status.
exitTaskTracker(Throwable) - Method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager.CleanupThread
Exit the task tracker because of a fatal error.
exitUsage(boolean) - Method in class org.apache.hadoop.streaming.StreamJob
 
ExpandBuff(boolean) - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
expectedTokenSequences - Variable in exception org.apache.hadoop.record.compiler.generated.ParseException
Each entry in this array is an array of integers.
exponentialBackoffRetry(int, long, TimeUnit) - Static method in class org.apache.hadoop.io.retry.RetryPolicies
Keep trying a limited number of times, waiting a growing amount of time between attempts, and then fail by re-throwing the exception.
expunge() - Method in class org.apache.hadoop.fs.Trash
Delete old checkpoints.
extractOutputKeyValue(String, String, String, List<Integer>, List<Integer>, int, boolean, boolean) - Method in class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionHelper
 
extractToken(HttpURLConnection, AuthenticatedURL.Token) - Static method in class org.apache.hadoop.security.authentication.client.AuthenticatedURL
Helper method that extracts an authentication token received from a connection.

F

fail(String) - Method in class org.apache.hadoop.streaming.StreamJob
 
FAILED - Static variable in class org.apache.hadoop.mapred.jobcontrol.Job
 
FAILED - Static variable in class org.apache.hadoop.mapred.JobStatus
 
failedJobs() - Method in class org.apache.hadoop.mapred.JobTracker
 
failedTask(TaskInProgress, TaskAttemptID, String, TaskStatus.Phase, TaskStatus.State, String) - Method in class org.apache.hadoop.mapred.JobInProgress
Fail a task with a given reason, but without a status object.
failJob(JobInProgress) - Method in class org.apache.hadoop.mapred.JobTracker
Fail a job and inform the listeners.
failJob(String) - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
 
failTask(TaskAttemptID) - Method in class org.apache.hadoop.mapreduce.Job
Fail indicated task attempt.
fatalError(TaskAttemptID, String, JvmContext) - Method in class org.apache.hadoop.mapred.TaskTracker
A child task had a fatal error.
fatalError(TaskAttemptID, String, JvmContext) - Method in interface org.apache.hadoop.mapred.TaskUmbilicalProtocol
Report that the task encounted a fatal error.
fetchServiceTicket(URL) - Static method in class org.apache.hadoop.security.SecurityUtil
Explicitly pull the service ticket for the specified host.
Field() - Method in class org.apache.hadoop.record.compiler.generated.Rcc
 
FIELD_SEPARATOR - Static variable in class org.apache.hadoop.contrib.failmon.LocalStore
 
FieldSelectionHelper - Class in org.apache.hadoop.mapreduce.lib.fieldsel
This class implements a mapper/reducer class that can be used to perform field selections in a manner similar to unix cut.
FieldSelectionHelper() - Constructor for class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionHelper
 
FieldSelectionHelper(Text, Text) - Constructor for class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionHelper
 
FieldSelectionMapper<K,V> - Class in org.apache.hadoop.mapreduce.lib.fieldsel
This class implements a mapper class that can be used to perform field selections in a manner similar to unix cut.
FieldSelectionMapper() - Constructor for class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionMapper
 
FieldSelectionMapReduce<K,V> - Class in org.apache.hadoop.mapred.lib
This class implements a mapper/reducer class that can be used to perform field selections in a manner similar to unix cut.
FieldSelectionMapReduce() - Constructor for class org.apache.hadoop.mapred.lib.FieldSelectionMapReduce
 
FieldSelectionReducer<K,V> - Class in org.apache.hadoop.mapreduce.lib.fieldsel
This class implements a reducer class that can be used to perform field selections in a manner similar to unix cut.
FieldSelectionReducer() - Constructor for class org.apache.hadoop.mapreduce.lib.fieldsel.FieldSelectionReducer
 
FieldTypeInfo - Class in org.apache.hadoop.record.meta
Represents a type information for a field, which is made up of its ID (name) and its type (a TypeID object).
file - Variable in class org.apache.hadoop.fs.FSInputChecker
The file name from which data is read from
FILE_NAME_PROPERTY - Static variable in class org.apache.hadoop.metrics.file.FileContext
Deprecated.  
FILE_TYPES - Static variable in class org.apache.hadoop.fs.s3.INode
 
FileAlreadyExistsException - Exception in org.apache.hadoop.fs
Used when target file already exists for any operation and is not configured to be overwritten.
FileAlreadyExistsException() - Constructor for exception org.apache.hadoop.fs.FileAlreadyExistsException
 
FileAlreadyExistsException(String) - Constructor for exception org.apache.hadoop.fs.FileAlreadyExistsException
 
FileAlreadyExistsException - Exception in org.apache.hadoop.mapred
Used when target file already exists for any operation and is not configured to be overwritten.
FileAlreadyExistsException() - Constructor for exception org.apache.hadoop.mapred.FileAlreadyExistsException
 
FileAlreadyExistsException(String) - Constructor for exception org.apache.hadoop.mapred.FileAlreadyExistsException
 
FileChecksum - Class in org.apache.hadoop.fs
An abstract class representing file checksums for files.
FileChecksum() - Constructor for class org.apache.hadoop.fs.FileChecksum
 
FileContext - Class in org.apache.hadoop.metrics.file
Deprecated. use FileSink instead.
FileContext() - Constructor for class org.apache.hadoop.metrics.file.FileContext
Deprecated. Creates a new instance of FileContext
fileExists(String) - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
fileExtension(String) - Method in class org.apache.hadoop.streaming.JarBuilder
 
FileInputFormat<K,V> - Class in org.apache.hadoop.mapred
A base class for file-based InputFormat.
FileInputFormat() - Constructor for class org.apache.hadoop.mapred.FileInputFormat
 
FileInputFormat<K,V> - Class in org.apache.hadoop.mapreduce.lib.input
A base class for file-based InputFormats.
FileInputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
 
FileInputFormat.Counter - Enum in org.apache.hadoop.mapred
 
FileInputFormat.Counter - Enum in org.apache.hadoop.mapreduce.lib.input
 
fileLength(String) - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
fileModified(String) - Method in class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
 
FileOutputCommitter - Class in org.apache.hadoop.mapred
An OutputCommitter that commits files specified in job output directory i.e.
FileOutputCommitter() - Constructor for class org.apache.hadoop.mapred.FileOutputCommitter
 
FileOutputCommitter - Class in org.apache.hadoop.mapreduce.lib.output
An OutputCommitter that commits files specified in job output directory i.e.
FileOutputCommitter(Path, TaskAttemptContext) - Constructor for class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Create a file output committer
FileOutputFormat<K,V> - Class in org.apache.hadoop.mapred
A base class for OutputFormat.
FileOutputFormat() - Constructor for class org.apache.hadoop.mapred.FileOutputFormat
 
FileOutputFormat<K,V> - Class in org.apache.hadoop.mapreduce.lib.output
A base class for OutputFormats that read from FileSystems.
FileOutputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
 
FileOutputFormat.Counter - Enum in org.apache.hadoop.mapred
 
FileOutputFormat.Counter - Enum in org.apache.hadoop.mapreduce.lib.output
 
FileSink - Class in org.apache.hadoop.metrics2.sink
 
FileSink() - Constructor for class org.apache.hadoop.metrics2.sink.FileSink
 
FileSplit - Class in org.apache.hadoop.mapred
A section of an input file.
FileSplit(Path, long, long, JobConf) - Constructor for class org.apache.hadoop.mapred.FileSplit
Deprecated.  
FileSplit(Path, long, long, String[]) - Constructor for class org.apache.hadoop.mapred.FileSplit
Constructs a split with host information
FileSplit - Class in org.apache.hadoop.mapreduce.lib.input
A section of an input file.
FileSplit(Path, long, long, String[]) - Constructor for class org.apache.hadoop.mapreduce.lib.input.FileSplit
Constructs a split with host information
FileStatus - Class in org.apache.hadoop.fs
Interface that represents the client side information for a file.
FileStatus() - Constructor for class org.apache.hadoop.fs.FileStatus
 
FileStatus(long, boolean, int, long, long, Path) - Constructor for class org.apache.hadoop.fs.FileStatus
 
FileStatus(long, boolean, int, long, long, long, FsPermission, String, String, Path) - Constructor for class org.apache.hadoop.fs.FileStatus
 
FileSystem - Class in org.apache.hadoop.fs
An abstract base class for a fairly generic filesystem.
FileSystem() - Constructor for class org.apache.hadoop.fs.FileSystem
 
FileSystem.Statistics - Class in org.apache.hadoop.fs
 
FileSystem.Statistics(String) - Constructor for class org.apache.hadoop.fs.FileSystem.Statistics
 
FILESYSTEM_COUNTER_GROUP - Static variable in class org.apache.hadoop.mapred.Task
Name of the FileSystem counters' group
FileSystemDirectory - Class in org.apache.hadoop.contrib.index.lucene
This class implements a Lucene Directory on top of a general FileSystem.
FileSystemDirectory(FileSystem, Path, boolean, Configuration) - Constructor for class org.apache.hadoop.contrib.index.lucene.FileSystemDirectory
Constructor
FileSystemStore - Interface in org.apache.hadoop.fs.s3
A facility for storing and retrieving INodes and Blocks.
fileURIs - Variable in class org.apache.hadoop.streaming.StreamJob
 
FileUtil - Class in org.apache.hadoop.fs
A collection of file-processing util methods
FileUtil() - Constructor for class org.apache.hadoop.fs.FileUtil
 
FillBuff() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
fillJoinCollector(K) - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
For all child RRs offering the key provided, obtain an iterator at that position in the JoinCollector.
fillJoinCollector(K) - Method in class org.apache.hadoop.mapred.join.OverrideRecordReader
Instead of filling the JoinCollector with iterators from all data sources, fill only the rightmost for this key.
Filter - Class in org.apache.hadoop.util.bloom
Defines the general behavior of a filter.
Filter() - Constructor for class org.apache.hadoop.util.bloom.Filter
 
Filter(int, int, int) - Constructor for class org.apache.hadoop.util.bloom.Filter
Constructor.
FILTER_CLASS - Static variable in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter
 
FILTER_FREQUENCY - Static variable in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter
 
FILTER_REGEX - Static variable in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter
 
FilterContainer - Interface in org.apache.hadoop.http
A container class for javax.servlet.Filter.
FilterFileSystem - Class in org.apache.hadoop.fs
A FilterFileSystem contains some other file system, which it uses as its basic file system, possibly transforming the data along the way or providing additional functionality.
FilterFileSystem() - Constructor for class org.apache.hadoop.fs.FilterFileSystem
 
FilterFileSystem(FileSystem) - Constructor for class org.apache.hadoop.fs.FilterFileSystem
 
FilterInitializer - Class in org.apache.hadoop.http
Initialize a javax.servlet.Filter.
FilterInitializer() - Constructor for class org.apache.hadoop.http.FilterInitializer
 
filterNames - Variable in class org.apache.hadoop.http.HttpServer
 
FilterOutputFormat<K,V> - Class in org.apache.hadoop.mapreduce.lib.output
FilterOutputFormat is a convenience class that wraps OutputFormat.
FilterOutputFormat() - Constructor for class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat
 
FilterOutputFormat(OutputFormat<K, V>) - Constructor for class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat
Create a FilterOutputFormat based on the underlying output format.
FilterOutputFormat.FilterRecordWriter<K,V> - Class in org.apache.hadoop.mapreduce.lib.output
FilterRecordWriter is a convenience wrapper class that extends the RecordWriter.
FilterOutputFormat.FilterRecordWriter() - Constructor for class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat.FilterRecordWriter
 
FilterOutputFormat.FilterRecordWriter(RecordWriter<K, V>) - Constructor for class org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat.FilterRecordWriter
 
finalize() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
Overriden to close the stream.
finalize() - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
 
finalKey(WritableComparable) - Method in class org.apache.hadoop.io.MapFile.Reader
Reads the final key from the file.
find(String) - Method in class org.apache.hadoop.io.Text
 
find(String, int) - Method in class org.apache.hadoop.io.Text
Finds any occurence of what in the backing buffer, starting as position start.
findAll(String, String, int, String) - Method in class org.apache.hadoop.contrib.failmon.ShellParser
Finds all occurences of a pattern in a piece of text and returns the matching groups.
findByte(byte[], int, int, byte) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use UTF8ByteArrayUtils.findByte(byte[], int, int, byte)
findByte(byte[], int, int, byte) - Static method in class org.apache.hadoop.util.UTF8ByteArrayUtils
Find the first occurrence of the given byte b in a UTF-8 encoded string
findBytes(byte[], int, int, byte[]) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use UTF8ByteArrayUtils.findBytes(byte[], int, int, byte[])
findBytes(byte[], int, int, byte[]) - Static method in class org.apache.hadoop.util.UTF8ByteArrayUtils
Find the first occurrence of the given bytes b in a UTF-8 encoded string
findCounter(Enum) - Method in class org.apache.hadoop.mapred.Counters
Find the counter for the given enum.
findCounter(String, String) - Method in class org.apache.hadoop.mapred.Counters
Find a counter given the group and the name.
findCounter(String, int, String) - Method in class org.apache.hadoop.mapred.Counters
Deprecated.  
findCounter(String, String) - Method in class org.apache.hadoop.mapreduce.CounterGroup
Internal to find a counter in a group.
findCounter(String) - Method in class org.apache.hadoop.mapreduce.CounterGroup
 
findCounter(String, String) - Method in class org.apache.hadoop.mapreduce.Counters
 
findCounter(Enum<?>) - Method in class org.apache.hadoop.mapreduce.Counters
Find the counter for the given enum.
findCredentials() - Method in class org.apache.hadoop.mapred.JobLocalizer
 
findFinishedMap(int) - Method in class org.apache.hadoop.mapred.JobInProgress
Find the details of someplace where a map has finished
findInClasspath(String) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
findInClasspath(String, ClassLoader) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
findNext(String, char, char, int, StringBuilder) - Static method in class org.apache.hadoop.util.StringUtils
Finds the first occurrence of the separator character ignoring the escaped separators starting from the index.
findNthByte(byte[], int, int, byte, int) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use UTF8ByteArrayUtils.findNthByte(byte[], int, int, byte, int)
findNthByte(byte[], byte, int) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use UTF8ByteArrayUtils.findNthByte(byte[], byte, int)
findNthByte(byte[], int, int, byte, int) - Static method in class org.apache.hadoop.util.UTF8ByteArrayUtils
Find the nth occurrence of the given byte b in a UTF-8 encoded string
findNthByte(byte[], byte, int) - Static method in class org.apache.hadoop.util.UTF8ByteArrayUtils
Find the nth occurrence of the given byte b in a UTF-8 encoded string
findPattern(String, String, int) - Method in class org.apache.hadoop.contrib.failmon.ShellParser
Find the first occurence ofa pattern in a piece of text and return a specific group.
findPort - Variable in class org.apache.hadoop.http.HttpServer
 
findSeparator(byte[], int, int, byte) - Static method in class org.apache.hadoop.mapred.KeyValueLineRecordReader
 
findSeparator(byte[], int, int, byte) - Static method in class org.apache.hadoop.mapreduce.lib.input.KeyValueLineRecordReader
 
findSpeculativeTask(Collection<TaskInProgress>, TaskTrackerStatus, double, long, boolean) - Method in class org.apache.hadoop.mapred.JobInProgress
Find a speculative task
findTab(byte[], int, int) - Static method in class org.apache.hadoop.streaming.StreamKeyValUtil
Find the first occured tab in a UTF-8 encoded string
findTab(byte[]) - Static method in class org.apache.hadoop.streaming.StreamKeyValUtil
Find the first occured tab in a UTF-8 encoded string
findTab(byte[], int, int) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use StreamKeyValUtil.findTab(byte[], int, int)
findTab(byte[]) - Static method in class org.apache.hadoop.streaming.UTF8ByteArrayUtils
Deprecated. use StreamKeyValUtil.findTab(byte[])
finish() - Method in class org.apache.hadoop.io.compress.BlockCompressorStream
 
finish() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
finish() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
 
finish() - Method in class org.apache.hadoop.io.compress.CompressionOutputStream
Finishes writing compressed data to the output stream without closing the underlying stream.
finish() - Method in interface org.apache.hadoop.io.compress.Compressor
When called, indicates that compression should end with the current contents of the input buffer.
finish() - Method in class org.apache.hadoop.io.compress.CompressorStream
 
finish() - Method in class org.apache.hadoop.io.compress.GzipCodec.GzipOutputStream
 
finish() - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
When called, indicates that compression should end with the current contents of the input buffer.
finish() - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
 
finished() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
finished() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyDecompressor
 
finished() - Method in interface org.apache.hadoop.io.compress.Compressor
Returns true if the end of the compressed data output stream has been reached.
finished() - Method in interface org.apache.hadoop.io.compress.Decompressor
Returns true if the end of the decompressed data output stream has been reached.
finished() - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
Returns true if the end of the compressed data output stream has been reached.
finished() - Method in class org.apache.hadoop.io.compress.snappy.SnappyDecompressor
Returns true if the end of the decompressed data output stream has been reached.
finished() - Method in class org.apache.hadoop.io.compress.zlib.BuiltInGzipDecompressor
Returns true if the end of the gzip substream (single "member") has been reached.
finished() - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
 
finished() - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
 
finishedMaps() - Method in class org.apache.hadoop.mapred.JobInProgress
 
finishedReduces() - Method in class org.apache.hadoop.mapred.JobInProgress
 
firstKey() - Method in class org.apache.hadoop.io.SortedMapWritable
fix(FileSystem, Path, Class<? extends Writable>, Class<? extends Writable>, boolean, Configuration) - Static method in class org.apache.hadoop.io.MapFile
This method attempts to fix a corrupt MapFile by re-creating its index.
FLOAT - Static variable in class org.apache.hadoop.record.meta.TypeID.RIOType
 
FLOAT_TKN - Static variable in interface org.apache.hadoop.record.compiler.generated.RccConstants
 
FloatSplitter - Class in org.apache.hadoop.mapreduce.lib.db
Implement DBSplitter over floating-point values.
FloatSplitter() - Constructor for class org.apache.hadoop.mapreduce.lib.db.FloatSplitter
 
FloatTypeID - Static variable in class org.apache.hadoop.record.meta.TypeID
 
FloatWritable - Class in org.apache.hadoop.io
A WritableComparable for floats.
FloatWritable() - Constructor for class org.apache.hadoop.io.FloatWritable
 
FloatWritable(float) - Constructor for class org.apache.hadoop.io.FloatWritable
 
FloatWritable.Comparator - Class in org.apache.hadoop.io
A Comparator optimized for FloatWritable.
FloatWritable.Comparator() - Constructor for class org.apache.hadoop.io.FloatWritable.Comparator
 
flush() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
 
flush() - Method in class org.apache.hadoop.io.compress.CompressionOutputStream
 
flush() - Method in class org.apache.hadoop.io.compress.GzipCodec.GzipOutputStream
 
flush() - Method in class org.apache.hadoop.mapred.TaskLogAppender
 
flush() - Method in class org.apache.hadoop.metrics.file.FileContext
Deprecated. Flushes the output writer, forcing updates to disk.
flush() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Called each period after all records have been emitted, this method does nothing.
flush() - Method in class org.apache.hadoop.metrics.spi.CompositeContext
Deprecated.  
flush() - Method in interface org.apache.hadoop.metrics2.MetricsSink
Flush any buffered metrics
flush() - Method in class org.apache.hadoop.metrics2.sink.FileSink
 
flush() - Method in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
flush() - Method in class org.apache.hadoop.security.SaslOutputStream
Flushes this output stream
flushBuffer() - Method in class org.apache.hadoop.fs.FSOutputSummer
 
flushBuffer(boolean) - Method in class org.apache.hadoop.fs.FSOutputSummer
 
formatBytes(long) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
formatBytes2(long) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
formatPercent(double, int) - Static method in class org.apache.hadoop.util.StringUtils
Format a percentage for presentation to the user.
formatTime(long) - Static method in class org.apache.hadoop.util.StringUtils
Given the time in long milliseconds, returns a String in the format Xhrs, Ymins, Z sec.
formatTimeDiff(long, long) - Static method in class org.apache.hadoop.util.StringUtils
Given a finish and start time in long milliseconds, returns a String in the format Xhrs, Ymins, Z sec, for the time difference between two times.
forName(String) - Static method in class org.apache.hadoop.mapred.JobID
Construct a JobId object from given string
forName(String) - Static method in class org.apache.hadoop.mapred.TaskAttemptID
Construct a TaskAttemptID object from given string
forName(String) - Static method in class org.apache.hadoop.mapred.TaskID
 
forName(String) - Static method in class org.apache.hadoop.mapreduce.JobID
Construct a JobId object from given string
forName(String) - Static method in class org.apache.hadoop.mapreduce.TaskAttemptID
Construct a TaskAttemptID object from given string
forName(String) - Static method in class org.apache.hadoop.mapreduce.TaskID
Construct a TaskID object from given string
fourRotations - Static variable in class org.apache.hadoop.examples.dancing.Pentomino
Are all 4 rotations unique?
fromEscapedCompactString(String) - Static method in class org.apache.hadoop.mapred.Counters
Convert a stringified counter representation into a counter object.
fromShort(short) - Method in class org.apache.hadoop.fs.permission.FsPermission
 
fromString(String) - Method in class org.apache.hadoop.io.DefaultStringifier
 
fromString(String) - Method in interface org.apache.hadoop.io.Stringifier
Restores the object from its string representation.
fs - Variable in class org.apache.hadoop.fs.FilterFileSystem
 
fs - Variable in class org.apache.hadoop.fs.FsShell
 
fs - Variable in class org.apache.hadoop.mapred.lib.CombineFileRecordReader
 
fs - Variable in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
FS_DEFAULT_NAME_DEFAULT - Static variable in class org.apache.hadoop.fs.CommonConfigurationKeys
 
FS_DEFAULT_NAME_KEY - Static variable in class org.apache.hadoop.fs.CommonConfigurationKeys
See src/core/core-default.xml
FS_DEFAULT_NAME_KEY - Static variable in class org.apache.hadoop.fs.FileSystem
 
FsAction - Enum in org.apache.hadoop.fs.permission
File system actions, e.g.
FSDataInputStream - Class in org.apache.hadoop.fs
Utility that wraps a FSInputStream in a DataInputStream and buffers input through a BufferedInputStream.
FSDataInputStream(InputStream) - Constructor for class org.apache.hadoop.fs.FSDataInputStream
 
FSDataOutputStream - Class in org.apache.hadoop.fs
Utility that wraps a OutputStream in a DataOutputStream, buffers output through a BufferedOutputStream and creates a checksum file.
FSDataOutputStream(OutputStream) - Constructor for class org.apache.hadoop.fs.FSDataOutputStream
Deprecated. 
FSDataOutputStream(OutputStream, FileSystem.Statistics) - Constructor for class org.apache.hadoop.fs.FSDataOutputStream
 
FSDataOutputStream(OutputStream, FileSystem.Statistics, long) - Constructor for class org.apache.hadoop.fs.FSDataOutputStream
 
FSError - Error in org.apache.hadoop.fs
Thrown for unexpected filesystem errors, presumed to reflect disk errors in the native filesystem.
fsError(TaskAttemptID, String, JvmContext) - Method in class org.apache.hadoop.mapred.TaskTracker
A child task had a local filesystem error.
fsError(TaskAttemptID, String, JvmContext) - Method in interface org.apache.hadoop.mapred.TaskUmbilicalProtocol
Report that the task encounted a local filesystem error.
FSInputChecker - Class in org.apache.hadoop.fs
This is a generic input stream for verifying checksums for data before it is read by a user.
FSInputChecker(Path, int) - Constructor for class org.apache.hadoop.fs.FSInputChecker
Constructor
FSInputChecker(Path, int, boolean, Checksum, int, int) - Constructor for class org.apache.hadoop.fs.FSInputChecker
Constructor
FSInputStream - Class in org.apache.hadoop.fs
FSInputStream is a generic old InputStream with a little bit of RAF-style seek ability.
FSInputStream() - Constructor for class org.apache.hadoop.fs.FSInputStream
 
FSOutputSummer - Class in org.apache.hadoop.fs
This is a generic output stream for generating checksums for data before it is written to the underlying stream
FSOutputSummer(Checksum, int, int) - Constructor for class org.apache.hadoop.fs.FSOutputSummer
 
FsPermission - Class in org.apache.hadoop.fs.permission
A class for file/directory permissions.
FsPermission(FsAction, FsAction, FsAction) - Constructor for class org.apache.hadoop.fs.permission.FsPermission
Construct by the given FsAction.
FsPermission(short) - Constructor for class org.apache.hadoop.fs.permission.FsPermission
Construct by the given mode.
FsPermission(FsPermission) - Constructor for class org.apache.hadoop.fs.permission.FsPermission
Copy constructor
FsPermission(String) - Constructor for class org.apache.hadoop.fs.permission.FsPermission
Construct by given mode, either in octal or symbolic format.
FsShell - Class in org.apache.hadoop.fs
Provide command line access to a FileSystem.
FsShell() - Constructor for class org.apache.hadoop.fs.FsShell
 
FsShell(Configuration) - Constructor for class org.apache.hadoop.fs.FsShell
 
fstat(FileDescriptor) - Static method in class org.apache.hadoop.io.nativeio.NativeIO
Wrapper around fstat(2)
FsUrlStreamHandlerFactory - Class in org.apache.hadoop.fs
Factory for URL stream handlers.
FsUrlStreamHandlerFactory() - Constructor for class org.apache.hadoop.fs.FsUrlStreamHandlerFactory
 
FsUrlStreamHandlerFactory(Configuration) - Constructor for class org.apache.hadoop.fs.FsUrlStreamHandlerFactory
 
FTPException - Exception in org.apache.hadoop.fs.ftp
A class to wrap a Throwable into a Runtime Exception.
FTPException(String) - Constructor for exception org.apache.hadoop.fs.ftp.FTPException
 
FTPException(Throwable) - Constructor for exception org.apache.hadoop.fs.ftp.FTPException
 
FTPException(String, Throwable) - Constructor for exception org.apache.hadoop.fs.ftp.FTPException
 
FTPFileSystem - Class in org.apache.hadoop.fs.ftp
A FileSystem backed by an FTP client provided by Apache Commons Net.
FTPFileSystem() - Constructor for class org.apache.hadoop.fs.ftp.FTPFileSystem
 
FTPInputStream - Class in org.apache.hadoop.fs.ftp
 
FTPInputStream(InputStream, FTPClient, FileSystem.Statistics) - Constructor for class org.apache.hadoop.fs.ftp.FTPInputStream
 
fullyDelete(File) - Static method in class org.apache.hadoop.fs.FileUtil
Delete a directory and all its contents.
fullyDelete(FileSystem, Path) - Static method in class org.apache.hadoop.fs.FileUtil
Deprecated. Use FileSystem.delete(Path, boolean)
fullyDeleteContents(File) - Static method in class org.apache.hadoop.fs.FileUtil
Delete the contents of a directory, not the directory itself.

G

G_SIZE - Static variable in interface org.apache.hadoop.io.compress.bzip2.BZip2Constants
 
GangliaContext - Class in org.apache.hadoop.metrics.ganglia
Deprecated. in favor of org.apache.hadoop.metrics2 usage.
GangliaContext() - Constructor for class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated. Creates a new instance of GangliaContext
GangliaContext31 - Class in org.apache.hadoop.metrics.ganglia
Context for sending metrics to Ganglia version 3.1.x.
GangliaContext31() - Constructor for class org.apache.hadoop.metrics.ganglia.GangliaContext31
 
gangliaMetricVisitor - Variable in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
Used for visiting Metrics
GangliaSink30 - Class in org.apache.hadoop.metrics2.sink.ganglia
This code supports Ganglia 3.0
GangliaSink30() - Constructor for class org.apache.hadoop.metrics2.sink.ganglia.GangliaSink30
 
GangliaSink31 - Class in org.apache.hadoop.metrics2.sink.ganglia
This code supports Ganglia 3.1
GangliaSink31() - Constructor for class org.apache.hadoop.metrics2.sink.ganglia.GangliaSink31
 
gauge(MetricGauge<Integer>, int) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for int value gauges
gauge(MetricGauge<Long>, long) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for long value gauges
gauge(MetricGauge<Float>, float) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for float value gauges
gauge(MetricGauge<Double>, double) - Method in interface org.apache.hadoop.metrics2.MetricsVisitor
Callback for double value gauges
gcd(int, int) - Static method in class org.apache.hadoop.contrib.failmon.Environment
Determines the greatest common divisor (GCD) of two integers.
gcd(int[]) - Static method in class org.apache.hadoop.contrib.failmon.Environment
Determines the greatest common divisor (GCD) of a list of integers.
genCode(String, String, ArrayList<String>) - Method in class org.apache.hadoop.record.compiler.JFile
Generate record code in given language.
generateActualKey(K, V) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
Generate the actual key from the given key/value.
generateActualValue(K, V) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
Generate the actual value from the given key and value.
generateEntry(String, String, Text) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
 
generateFileNameForKeyValue(K, V, String) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
Generate the file output file name based on the given key and the leaf file name.
generateGroupKey(TaggedMapOutput) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
Generate a map output key.
generateHash(byte[], SecretKey) - Static method in class org.apache.hadoop.mapreduce.security.SecureShuffleUtils
Base64 encoded hash of msg
generateInputTag(String) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
Determine the source tag based on the input file name.
generateKeyValPairs(Object, Object) - Method in class org.apache.hadoop.examples.AggregateWordCount.WordCountPlugInClass
 
generateKeyValPairs(Object, Object) - Method in class org.apache.hadoop.examples.AggregateWordHistogram.AggregateWordHistogramPlugin
Parse the given value, generate an aggregation-id/value pair per word.
generateKeyValPairs(Object, Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.UserDefinedValueAggregatorDescriptor
Generate a list of aggregation-id/value pairs for the given key/value pairs by delegating the invocation to the real object.
generateKeyValPairs(Object, Object) - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
Generate 1 or 2 aggregation-id/value pairs for the given key/value pair.
generateKeyValPairs(Object, Object) - Method in interface org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorDescriptor
Generate a list of aggregation-id/value pairs for the given key/value pair.
generateLeafFileName(String) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
Generate the leaf name for the output file name.
generateParseException() - Method in class org.apache.hadoop.record.compiler.generated.Rcc
 
generateSecret() - Method in class org.apache.hadoop.security.token.SecretManager
Generate a new random secret key.
generateTaggedMapOutput(Object) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
Generate a tagged map output value.
generateValueAggregator(String) - Static method in class org.apache.hadoop.mapred.lib.aggregate.ValueAggregatorBaseDescriptor
 
generationFromSegmentsFileName(String) - Static method in class org.apache.hadoop.contrib.index.lucene.LuceneUtil
Parse the generation off the segments file name and return it.
GenericOptionsParser - Class in org.apache.hadoop.util
GenericOptionsParser is a utility to parse command line arguments generic to the Hadoop framework.
GenericOptionsParser(Options, String[]) - Constructor for class org.apache.hadoop.util.GenericOptionsParser
Create an options parser with the given options to parse the args.
GenericOptionsParser(String[]) - Constructor for class org.apache.hadoop.util.GenericOptionsParser
Create an options parser to parse the args.
GenericOptionsParser(Configuration, String[]) - Constructor for class org.apache.hadoop.util.GenericOptionsParser
Create a GenericOptionsParser to parse only the generic Hadoop arguments.
GenericOptionsParser(Configuration, Options, String[]) - Constructor for class org.apache.hadoop.util.GenericOptionsParser
Create a GenericOptionsParser to parse given options as well as generic Hadoop options.
GenericsUtil - Class in org.apache.hadoop.util
Contains utility methods for dealing with Java Generics.
GenericsUtil() - Constructor for class org.apache.hadoop.util.GenericsUtil
 
GenericWritable - Class in org.apache.hadoop.io
A wrapper for Writable instances.
GenericWritable() - Constructor for class org.apache.hadoop.io.GenericWritable
 
get(String) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property, null if no such property exists.
get(String, String) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property.
get(String) - Method in class org.apache.hadoop.contrib.failmon.EventRecord
Get the value of a property of the EventRecord.
get(String) - Method in class org.apache.hadoop.contrib.failmon.SerializedRecord
Get the value of a property of the EventRecord.
get(URI, Configuration, String) - Static method in class org.apache.hadoop.fs.FileSystem
 
get(Configuration) - Static method in class org.apache.hadoop.fs.FileSystem
Returns the configured filesystem implementation.
get(URI, Configuration) - Static method in class org.apache.hadoop.fs.FileSystem
Returns the FileSystem for this URI's scheme and authority.
get(long, Writable) - Method in class org.apache.hadoop.io.ArrayFile.Reader
Return the nth value in the file.
get() - Method in class org.apache.hadoop.io.ArrayWritable
 
get(WritableComparable, Writable) - Method in class org.apache.hadoop.io.BloomMapFile.Reader
Fast version of the MapFile.Reader.get(WritableComparable, Writable) method.
get() - Method in class org.apache.hadoop.io.BooleanWritable
Returns the value of the BooleanWritable
get() - Method in class org.apache.hadoop.io.BytesWritable
Deprecated. Use BytesWritable.getBytes() instead.
get() - Method in class org.apache.hadoop.io.ByteWritable
Return the value of this ByteWritable.
get() - Method in class org.apache.hadoop.io.DoubleWritable
 
get(BytesWritable, BytesWritable) - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader.Scanner.Entry
Copy the key and value in one shot into BytesWritables.
get() - Method in class org.apache.hadoop.io.FloatWritable
Return the value of this FloatWritable.
get() - Method in class org.apache.hadoop.io.GenericWritable
Return the wrapped instance.
get() - Method in class org.apache.hadoop.io.IntWritable
Return the value of this IntWritable.
get() - Method in class org.apache.hadoop.io.LongWritable
Return the value of this LongWritable.
get(WritableComparable, Writable) - Method in class org.apache.hadoop.io.MapFile.Reader
Return the value for the named key, or null if none exists.
get(Object) - Method in class org.apache.hadoop.io.MapWritable
get() - Static method in class org.apache.hadoop.io.NullWritable
Returns the single instance of this class.
get() - Method in class org.apache.hadoop.io.ObjectWritable
Return the instance, or null if none.
get(Text) - Method in class org.apache.hadoop.io.SequenceFile.Metadata
 
get(WritableComparable) - Method in class org.apache.hadoop.io.SetFile.Reader
Read the matching key from a set into key.
get(Object) - Method in class org.apache.hadoop.io.SortedMapWritable
get() - Method in class org.apache.hadoop.io.TwoDArrayWritable
 
get() - Method in class org.apache.hadoop.io.VIntWritable
Return the value of this VIntWritable.
get() - Method in class org.apache.hadoop.io.VLongWritable
Return the value of this LongWritable.
get(Class<? extends WritableComparable>) - Static method in class org.apache.hadoop.io.WritableComparator
Get a comparator for a WritableComparable implementation.
get() - Static method in class org.apache.hadoop.ipc.Server
Returns the server instance called under or null.
get(int) - Method in class org.apache.hadoop.mapred.join.CompositeInputSplit
Get ith child InputSplit.
get(int) - Method in class org.apache.hadoop.mapred.join.TupleWritable
Get ith Writable from Tuple.
get() - Method in class org.apache.hadoop.metrics.util.MetricsIntValue
Deprecated. Get value
get() - Method in class org.apache.hadoop.metrics.util.MetricsLongValue
Deprecated. Get value
get(String) - Method in class org.apache.hadoop.metrics.util.MetricsRegistry
Deprecated.  
get(String) - Method in class org.apache.hadoop.metrics2.lib.MetricsRegistry
Get a metric by name
get(String, Collection<MetricsTag>) - Method in class org.apache.hadoop.metrics2.util.MetricsCache
Get the cached record
get(DataInput) - Static method in class org.apache.hadoop.record.BinaryRecordInput
Get a thread-local record input for the supplied DataInput.
get(DataOutput) - Static method in class org.apache.hadoop.record.BinaryRecordOutput
Get a thread-local record output for the supplied DataOutput.
get() - Method in class org.apache.hadoop.record.Buffer
Get the data from the Buffer.
get(DataInput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesInput
Get a thread-local typed bytes input for the supplied DataInput.
get(DataOutput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesOutput
Get a thread-local typed bytes output for the supplied DataOutput.
get(TypedBytesInput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesRecordInput
Get a thread-local typed bytes record input for the supplied TypedBytesInput.
get(DataInput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesRecordInput
Get a thread-local typed bytes record input for the supplied DataInput.
get(TypedBytesOutput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesRecordOutput
Get a thread-local typed bytes record input for the supplied TypedBytesOutput.
get(DataOutput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesRecordOutput
Get a thread-local typed bytes record output for the supplied DataOutput.
get(TypedBytesInput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesWritableInput
Get a thread-local typed bytes writable input for the supplied TypedBytesInput.
get(DataInput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesWritableInput
Get a thread-local typed bytes writable input for the supplied DataInput.
get(TypedBytesOutput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesWritableOutput
Get a thread-local typed bytes writable input for the supplied TypedBytesOutput.
get(DataOutput) - Static method in class org.apache.hadoop.typedbytes.TypedBytesWritableOutput
Get a thread-local typed bytes writable output for the supplied DataOutput.
get() - Method in class org.apache.hadoop.util.Progress
Returns the overall progress of the root.
getAbsolutePath(String) - Method in class org.apache.hadoop.streaming.PathFinder
Returns the full path name of this file if it is listed in the path
getAcceptAnonymous() - Method in class org.apache.hadoop.security.authentication.server.PseudoAuthenticationHandler
Returns if the handler is configured to support anonymous users.
getAccessKey() - Method in class org.apache.hadoop.fs.s3.S3Credentials
 
getAccessTime() - Method in class org.apache.hadoop.fs.FileStatus
Get the access time of the file.
getAclName() - Method in enum org.apache.hadoop.mapreduce.JobACL
Get the name of the ACL.
getACLString() - Method in class org.apache.hadoop.security.authorize.AccessControlList
Returns the String representation of this ACL.
getActiveTrackerNames() - Method in class org.apache.hadoop.mapred.ClusterStatus
Get the names of active task trackers in the cluster.
getAddress(Configuration) - Static method in class org.apache.hadoop.mapred.JobTracker
 
getAdjustedEnd() - Method in class org.apache.hadoop.io.compress.SplitCompressionInputStream
After calling createInputStream, the values of start or end might change.
getAdjustedStart() - Method in class org.apache.hadoop.io.compress.SplitCompressionInputStream
After calling createInputStream, the values of start or end might change.
getAdminAcls(Configuration, String) - Static method in class org.apache.hadoop.security.SecurityUtil
Get the ACL object representing the cluster administrators The user who starts the daemon is automatically added as an admin
getAlgorithmName() - Method in class org.apache.hadoop.fs.FileChecksum
The checksum algorithm name
getAlgorithmName() - Method in class org.apache.hadoop.fs.MD5MD5CRC32FileChecksum
The checksum algorithm name
getAliveNodesInfoJson() - Method in class org.apache.hadoop.mapred.JobTracker
 
getAliveNodesInfoJson() - Method in interface org.apache.hadoop.mapred.JobTrackerMXBean
 
getAllAttempts() - Method in class org.apache.hadoop.mapreduce.server.tasktracker.JVMInfo
 
getAllContexts() - Method in class org.apache.hadoop.metrics.ContextFactory
Deprecated. Returns all MetricsContexts built by this factory.
getAllJobs() - Method in class org.apache.hadoop.mapred.JobClient
Get the jobs that are submitted.
getAllJobs() - Method in class org.apache.hadoop.mapred.JobTracker
 
getAllKeys() - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager
 
getAllLocalPathsToRead(String, Configuration) - Method in class org.apache.hadoop.fs.LocalDirAllocator
Get all of the paths that currently exist in the working directories.
getAllRecords() - Method in interface org.apache.hadoop.metrics.MetricsContext
Deprecated. Retrieves all the records managed by this MetricsContext.
getAllRecords() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Retrieves all the records managed by this MetricsContext.
getAllStaticResolutions() - Static method in class org.apache.hadoop.net.NetUtils
This is used to get all the resolutions that were added using NetUtils.addStaticResolution(String, String).
getAllStatistics() - Static method in class org.apache.hadoop.fs.FileSystem
Return the FileSystem classes that have Statistics
getAllTasks() - Method in class org.apache.hadoop.mapred.JobHistory.JobInfo
Returns all map and reduce tasks .
getAllTokens() - Method in class org.apache.hadoop.security.Credentials
Return all the tokens in the in-memory map
getApproxChkSumLength(long) - Static method in class org.apache.hadoop.fs.ChecksumFileSystem
 
getArchiveClassPaths(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get the archive entries in classpath as an array of Path.
getArchiveTimestamps(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get the timestamps of the archives.
getArchiveVisibilities(Configuration) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
Get the booleans on whether the archives are public or not.
getAssignedJobID() - Method in class org.apache.hadoop.mapred.jobcontrol.Job
 
getAssignedTracker(TaskAttemptID) - Method in class org.apache.hadoop.mapred.JobTracker
Get tracker name for a given task id.
getAttemptsToStartSkipping(Configuration) - Static method in class org.apache.hadoop.mapred.SkipBadRecords
Get the number of Task attempts AFTER which skip mode will be kicked off.
getAttribute(String) - Method in class org.apache.hadoop.http.HttpServer
Get the value in the webapp context.
getAttribute(String) - Method in class org.apache.hadoop.metrics.ContextFactory
Deprecated. Returns the value of the named attribute, or null if there is no attribute of that name.
getAttribute(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Convenience method for subclasses to access factory attributes.
getAttribute(String) - Method in class org.apache.hadoop.metrics.util.MetricsDynamicMBeanBase
Deprecated.  
getAttributeNames() - Method in class org.apache.hadoop.metrics.ContextFactory
Deprecated. Returns the names of all the factory's attributes.
getAttributes(String[]) - Method in class org.apache.hadoop.metrics.util.MetricsDynamicMBeanBase
Deprecated.  
getAttributeTable(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Returns an attribute-value map derived from the factory attributes by finding all factory attributes that begin with contextName.tableName.
getAuthenticationHandler() - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Returns the authentication handler being used.
getAuthenticationMethod() - Method in class org.apache.hadoop.security.UserGroupInformation
Get the authentication method from the subject
getAutoIncrMapperProcCount(Configuration) - Static method in class org.apache.hadoop.mapred.SkipBadRecords
Get the flag which if set to true, SkipBadRecords.COUNTER_MAP_PROCESSED_RECORDS is incremented by MapRunner after invoking the map function.
getAutoIncrReducerProcCount(Configuration) - Static method in class org.apache.hadoop.mapred.SkipBadRecords
Get the flag which if set to true, SkipBadRecords.COUNTER_REDUCE_PROCESSED_GROUPS is incremented by framework after invoking the reduce function.
getAvailable() - Method in class org.apache.hadoop.fs.DF
 
getAvailableMapSlots() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get available map slots.
getAvailablePhysicalMemorySize() - Method in class org.apache.hadoop.util.LinuxResourceCalculatorPlugin
Obtain the total size of the available physical memory present in the system.
getAvailablePhysicalMemorySize() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin
Obtain the total size of the available physical memory present in the system.
getAvailableReduceSlots() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get available reduce slots.
getAvailableSlots(TaskType) - Method in class org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker
Get the number of currently available slots on this tasktracker for the given type of the task.
getAvailableVirtualMemorySize() - Method in class org.apache.hadoop.util.LinuxResourceCalculatorPlugin
Obtain the total size of the available virtual memory present in the system.
getAvailableVirtualMemorySize() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin
Obtain the total size of the available virtual memory present in the system.
getBaseLogDir() - Static method in class org.apache.hadoop.mapred.TaskLog
 
getBasePathInJarOut(String) - Method in class org.apache.hadoop.streaming.JarBuilder
 
getBaseRecordWriter(FileSystem, JobConf, String, Progressable) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
 
getBaseRecordWriter(FileSystem, JobConf, String, Progressable) - Method in class org.apache.hadoop.mapred.lib.MultipleSequenceFileOutputFormat
 
getBaseRecordWriter(FileSystem, JobConf, String, Progressable) - Method in class org.apache.hadoop.mapred.lib.MultipleTextOutputFormat
 
getBeginColumn() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
getBeginLine() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
getBlacklistedNodesInfoJson() - Method in class org.apache.hadoop.mapred.JobTracker
 
getBlacklistedNodesInfoJson() - Method in interface org.apache.hadoop.mapred.JobTrackerMXBean
 
getBlackListedTaskTrackerCount() - Method in class org.apache.hadoop.mapreduce.ClusterMetrics
Get the number of blacklisted trackers in the cluster.
getBlacklistedTrackerNames() - Method in class org.apache.hadoop.mapred.ClusterStatus
Get the names of blacklisted task trackers in the cluster.
getBlacklistedTrackers() - Method in class org.apache.hadoop.mapred.ClusterStatus
Get the number of blacklisted task trackers in the cluster.
getBlockIndex(BlockLocation[], long) - Method in class org.apache.hadoop.mapred.FileInputFormat
 
getBlockIndex(BlockLocation[], long) - Method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
 
getBlocks() - Method in class org.apache.hadoop.fs.s3.INode
 
getBlockSize() - Method in class org.apache.hadoop.fs.FileStatus
Get the block size of the file.
getBlockSize(Path) - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. Use getFileStatus() instead
getBlockSize() - Method in class org.apache.hadoop.io.compress.bzip2.CBZip2OutputStream
Returns the blocksize parameter specified at construction time.
getBloomFilter() - Method in class org.apache.hadoop.io.BloomMapFile.Reader
Retrieve the Bloom filter used by this instance of the Reader.
getBoolean(String, boolean) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as a boolean.
getBoundAntProperty(String, String) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
getBoundingValsQuery() - Method in class org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat
 
getBuildVersion() - Method in class org.apache.hadoop.mapred.JobTracker
 
getBuildVersion() - Static method in class org.apache.hadoop.util.VersionInfo
Returns the full version string containing version, revision, user and source checksum.
getByName(String) - Static method in class org.apache.hadoop.security.SecurityUtil
Resolves a host subject to the security requirements determined by hadoop.security.token.service.use_ip.
getByName(String) - Method in class org.apache.hadoop.security.SecurityUtil.QualifiedHostResolver
Create an InetAddress with a fully qualified hostname of the given hostname.
getBytes() - Method in class org.apache.hadoop.fs.FileChecksum
The value of the checksum in bytes
getBytes() - Method in class org.apache.hadoop.fs.MD5MD5CRC32FileChecksum
The value of the checksum in bytes
getBytes() - Method in class org.apache.hadoop.io.BinaryComparable
Return representative byte array for this instance.
getBytes() - Method in class org.apache.hadoop.io.BytesWritable
Get the data from the BytesWritable.
getBytes() - Method in class org.apache.hadoop.io.Text
Returns the raw bytes; however, only data up to Text.getLength() is valid.
getBytes() - Method in class org.apache.hadoop.io.UTF8
Deprecated. The raw bytes.
getBytes(String) - Static method in class org.apache.hadoop.io.UTF8
Deprecated. Convert a string to a UTF-8 encoded byte array.
getBytes() - Method in class org.apache.hadoop.security.token.TokenIdentifier
Get the bytes for the token identifier
getBytes() - Method in class org.apache.hadoop.util.bloom.Key
 
getBytesPerChecksum() - Method in class org.apache.hadoop.util.DataChecksum
 
getBytesPerSum() - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Return the bytes Per Checksum
getBytesRead() - Method in class org.apache.hadoop.fs.FileSystem.Statistics
Get the total number of bytes read
getBytesRead() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
getBytesRead() - Method in interface org.apache.hadoop.io.compress.Compressor
Return number of uncompressed bytes input so far.
getBytesRead() - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
Return number of bytes given to this compressor since last reset.
getBytesRead() - Method in class org.apache.hadoop.io.compress.zlib.BuiltInGzipDecompressor
Returns the total number of compressed bytes input so far, including gzip header/trailer bytes.
getBytesRead() - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
Returns the total number of uncompressed bytes input so far.
getBytesRead() - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
Returns the total number of compressed bytes input so far.
getBytesWritten() - Method in class org.apache.hadoop.fs.FileSystem.Statistics
Get the total number of bytes written
getBytesWritten() - Method in class org.apache.hadoop.io.compress.bzip2.BZip2DummyCompressor
 
getBytesWritten() - Method in interface org.apache.hadoop.io.compress.Compressor
Return number of compressed bytes output so far.
getBytesWritten() - Method in class org.apache.hadoop.io.compress.snappy.SnappyCompressor
Return number of bytes consumed by callers of compress since last reset.
getBytesWritten() - Method in class org.apache.hadoop.io.compress.zlib.ZlibCompressor
Returns the total number of compressed bytes output so far.
getBytesWritten() - Method in class org.apache.hadoop.io.compress.zlib.ZlibDecompressor
Returns the total number of uncompressed bytes output so far.
getCacheArchives(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get cache archives set in the Configuration.
getCacheFiles(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get cache files set in the Configuration.
getCallQueueLen() - Method in class org.apache.hadoop.ipc.Server
The number of rpc calls in the queue.
getCanonicalServiceName() - Method in class org.apache.hadoop.fs.FileSystem
Get a canonical service name for this file system.
getCanonicalServiceName() - Method in class org.apache.hadoop.fs.FilterFileSystem
 
getCanonicalServiceName() - Method in class org.apache.hadoop.fs.HarFileSystem
 
getCanonicalUri() - Method in class org.apache.hadoop.fs.FileSystem
Resolve the uri's hostname and add the default port if not in the uri
getCanonicalUri(URI, int) - Static method in class org.apache.hadoop.net.NetUtils
Resolve the uri's hostname and add the default port if not in the uri
getCapacity() - Method in class org.apache.hadoop.fs.DF
 
getCapacity() - Method in class org.apache.hadoop.io.BytesWritable
Get the capacity, which is the maximum size that could handled without resizing the backing storage.
getCapacity() - Method in class org.apache.hadoop.record.Buffer
Get the capacity, which is the maximum count that could handled without resizing the backing storage.
getCategory(List<List<Pentomino.ColumnName>>) - Method in class org.apache.hadoop.examples.dancing.Pentomino
Find whether the solution has the x in the upper left quadrant, the x-midline, the y-midline or in the center.
getChannel() - Method in class org.apache.hadoop.net.SocketInputStream
Returns underlying channel used by inputstream.
getChannel() - Method in class org.apache.hadoop.net.SocketOutputStream
Returns underlying channel used by this stream.
getChecksumFile(Path) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Return the name of the checksum file associated with a file.
getChecksumFileLength(Path, long) - Method in class org.apache.hadoop.fs.ChecksumFileSystem
Return the length of the checksum file given the size of the actual file.
getChecksumHeaderSize() - Static method in class org.apache.hadoop.util.DataChecksum
 
getChecksumLength(long, int) - Static method in class org.apache.hadoop.fs.ChecksumFileSystem
Calculated the length of the checksum file in bytes.
getChecksumSize() - Method in class org.apache.hadoop.util.DataChecksum
 
getChecksumType() - Method in class org.apache.hadoop.util.DataChecksum
 
getChunkPosition(long) - Method in class org.apache.hadoop.fs.FSInputChecker
Return position of beginning of chunk containing pos.
getClass(String, Class<?>) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as a Class.
getClass(String, Class<? extends U>, Class<U>) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as a Class implementing the interface specified by xface.
getClass(byte) - Method in class org.apache.hadoop.io.AbstractMapWritable
 
getClass(String, Configuration) - Static method in class org.apache.hadoop.io.WritableName
Return the class for a name.
getClass(T) - Static method in class org.apache.hadoop.util.GenericsUtil
Returns the Class object (of type Class<T>) of the argument of type T.
getClass(T) - Static method in class org.apache.hadoop.util.ReflectionUtils
Return the correctly-typed Class of the given object.
getClassByName(String) - Method in class org.apache.hadoop.conf.Configuration
Load a class by name.
getClassByName(String) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
 
getClasses(String, Class<?>...) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as an array of Class.
getClassLoader() - Method in class org.apache.hadoop.conf.Configuration
Get the ClassLoader for this job.
getClassName() - Method in exception org.apache.hadoop.ipc.RemoteException
 
getClassPaths() - Method in class org.apache.hadoop.filecache.TaskDistributedCacheManager
Retrieves class paths (as local references) to add.
getCleanupTaskReports(JobID) - Method in class org.apache.hadoop.mapred.JobClient
Get the information of the current state of the cleanup tasks of a job.
getCleanupTaskReports(JobID) - Method in class org.apache.hadoop.mapred.JobTracker
 
getClientInput() - Method in class org.apache.hadoop.streaming.PipeMapRed
Returns the DataInput from which the client output is read.
getClientOutput() - Method in class org.apache.hadoop.streaming.PipeMapRed
Returns the DataOutput to which the client input is written.
getClientVersion() - Method in exception org.apache.hadoop.ipc.RPC.VersionMismatch
Get the client's preferred version
getClock() - Method in class org.apache.hadoop.mapred.JobTracker
 
getClosest(WritableComparable, Writable) - Method in class org.apache.hadoop.io.MapFile.Reader
Finds the record that is the closest match to the specified key.
getClosest(WritableComparable, Writable, boolean) - Method in class org.apache.hadoop.io.MapFile.Reader
Finds the record that is the closest match to the specified key.
getClusterMetrics() - Method in class org.apache.hadoop.mapred.JobTracker
 
getClusterNick() - Method in class org.apache.hadoop.streaming.StreamJob
Deprecated. 
getClusterStatus() - Method in class org.apache.hadoop.mapred.JobClient
Get status information about the Map-Reduce cluster.
getClusterStatus(boolean) - Method in class org.apache.hadoop.mapred.JobClient
Get status information about the Map-Reduce cluster.
getClusterStatus() - Method in class org.apache.hadoop.mapred.JobTracker
Deprecated. use JobTracker.getClusterStatus(boolean)
getClusterStatus(boolean) - Method in class org.apache.hadoop.mapred.JobTracker
 
getCodec(Path) - Method in class org.apache.hadoop.io.compress.CompressionCodecFactory
Find the relevant compression codec for the given file based on its filename suffix.
getCodecClasses(Configuration) - Static method in class org.apache.hadoop.io.compress.CompressionCodecFactory
Get the list of codecs listed in the configuration
getCollector(String, Reporter) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Gets the output collector for a named output.
getCollector(String, String, Reporter) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Gets the output collector for a multi named output.
getColumnName(int) - Method in class org.apache.hadoop.examples.dancing.DancingLinks
Get the name of a given column as a string
getCombinerClass() - Method in class org.apache.hadoop.mapred.JobConf
Get the user-defined combiner class used to combine map-outputs before being sent to the reducers.
getCombinerClass() - Method in class org.apache.hadoop.mapreduce.JobContext
Get the combiner class for the job.
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.DoubleValueSum
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMax
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueMin
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.LongValueSum
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.StringValueMax
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.StringValueMin
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.UniqValueCount
 
getCombinerOutput() - Method in interface org.apache.hadoop.mapred.lib.aggregate.ValueAggregator
 
getCombinerOutput() - Method in class org.apache.hadoop.mapred.lib.aggregate.ValueHistogram
 
getCommandLine() - Method in class org.apache.hadoop.util.GenericOptionsParser
Returns the commons-cli CommandLine object to process the parsed arguments.
getCommandName() - Method in class org.apache.hadoop.fs.shell.Command
Return the command's name excluding the leading character -
getCommandName() - Method in class org.apache.hadoop.fs.shell.Count
 
getComparator() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get an instance of the RawComparator that is constructed based on the string comparator representation.
getComparator() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Return comparator defining the ordering for RecordReaders in this composite.
getComparatorName() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get the string representation of the comparator.
getCompressedData() - Method in class org.apache.hadoop.io.compress.BlockDecompressorStream
 
getCompressedData() - Method in class org.apache.hadoop.io.compress.DecompressorStream
 
getCompressionCodec() - Method in class org.apache.hadoop.io.SequenceFile.Reader
Returns the compression codec of data in this file.
getCompressionCodec() - Method in class org.apache.hadoop.io.SequenceFile.Writer
Returns the compression codec of data in this file.
getCompressionLevel(Configuration) - Static method in class org.apache.hadoop.io.compress.zlib.ZlibFactory
 
getCompressionStrategy(Configuration) - Static method in class org.apache.hadoop.io.compress.zlib.ZlibFactory
 
getCompressionType(Configuration) - Static method in class org.apache.hadoop.io.SequenceFile
Deprecated. Use SequenceFileOutputFormat.getOutputCompressionType(org.apache.hadoop.mapred.JobConf) to get SequenceFile.CompressionType for job-outputs.
getCompressMapOutput() - Method in class org.apache.hadoop.mapred.JobConf
Are the outputs of the maps be compressed?
getCompressor(CompressionCodec, Configuration) - Static method in class org.apache.hadoop.io.compress.CodecPool
Get a Compressor for the given CompressionCodec from the pool or a new one.
getCompressor(CompressionCodec) - Static method in class org.apache.hadoop.io.compress.CodecPool
 
getCompressorType() - Method in class org.apache.hadoop.io.compress.BZip2Codec
This functionality is currently not supported.
getCompressorType() - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Get the type of Compressor needed by this CompressionCodec.
getCompressorType() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
getCompressorType() - Method in class org.apache.hadoop.io.compress.GzipCodec
 
getCompressorType() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Get the type of Compressor needed by this CompressionCodec.
getCompressOutput(JobConf) - Static method in class org.apache.hadoop.mapred.FileOutputFormat
Is the job output compressed?
getCompressOutput(JobContext) - Static method in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
Is the job output compressed?
getConditions() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
getConf() - Method in interface org.apache.hadoop.conf.Configurable
Return the configuration used by this object.
getConf() - Method in class org.apache.hadoop.conf.Configured
 
getConf() - Method in class org.apache.hadoop.fs.FilterFileSystem
 
getConf() - Method in class org.apache.hadoop.io.AbstractMapWritable
 
getConf() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
getConf() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Return the configuration used by this object.
getConf() - Method in class org.apache.hadoop.io.GenericWritable
 
getConf() - Method in class org.apache.hadoop.io.ObjectWritable
 
getConf() - Method in class org.apache.hadoop.mapred.JobTracker
Returns a handle to the JobTracker's Configuration
getConf() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Return the configuration used by this object.
getConf() - Method in class org.apache.hadoop.mapred.lib.InputSampler
 
getConf() - Method in class org.apache.hadoop.mapred.SequenceFileInputFilter.FilterBase
 
getConf() - Method in class org.apache.hadoop.mapred.Task
 
getConf() - Method in class org.apache.hadoop.mapred.TaskController
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFilter.FilterBase
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.partition.BinaryPartitioner
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedComparator
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedPartitioner
 
getConf() - Method in class org.apache.hadoop.mapreduce.lib.partition.TotalOrderPartitioner
 
getConf() - Method in class org.apache.hadoop.net.ScriptBasedMapping
 
getConf() - Method in class org.apache.hadoop.net.SocksSocketFactory
 
getConf() - Method in class org.apache.hadoop.streaming.DumpTypedBytes
 
getConf() - Method in class org.apache.hadoop.streaming.LoadTypedBytes
 
getConf() - Method in class org.apache.hadoop.streaming.StreamJob
 
getConf() - Method in class org.apache.hadoop.typedbytes.TypedBytesWritableInput
 
getConfiguration() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the underlying configuration object.
getConfiguration() - Method in class org.apache.hadoop.mapreduce.JobContext
Return the configuration for the job.
getConfiguration(String, FilterConfig) - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Returns the filtered configuration (only properties starting with the specified prefix).
getConfiguration() - Method in class org.apache.hadoop.streaming.PipeMapRed
Returns the Configuration.
getConfiguration() - Method in class org.apache.hadoop.util.GenericOptionsParser
Get the modified configuration
getConfigVersion() - Method in class org.apache.hadoop.mapred.JobTracker
 
getConfigVersion() - Method in interface org.apache.hadoop.mapred.JobTrackerMXBean
 
getConfigVersion() - Method in class org.apache.hadoop.mapred.TaskTracker
 
getConfigVersion() - Method in interface org.apache.hadoop.mapred.TaskTrackerMXBean
 
getConfResourceAsInputStream(String) - Method in class org.apache.hadoop.conf.Configuration
Get an input stream attached to the configuration resource with the given name.
getConfResourceAsReader(String) - Method in class org.apache.hadoop.conf.Configuration
Get a Reader attached to the configuration resource with the given name.
getConnectAddress(Server) - Static method in class org.apache.hadoop.net.NetUtils
Returns InetSocketAddress that a client can use to connect to the server.
getConnection() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
Returns a connection object o the DB
getConnection() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
getConnection() - Method in class org.apache.hadoop.mapreduce.lib.db.DBOutputFormat.DBRecordWriter
 
getConnection() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
getContentSummary(Path) - Method in class org.apache.hadoop.fs.FileSystem
Return the ContentSummary of a given Path.
getContext(String, String) - Method in class org.apache.hadoop.metrics.ContextFactory
Deprecated. Returns the named MetricsContext instance, constructing it if necessary using the factory's current configuration attributes.
getContext(String) - Method in class org.apache.hadoop.metrics.ContextFactory
Deprecated.  
getContext(String) - Static method in class org.apache.hadoop.metrics.MetricsUtil
Deprecated.  
getContext(String, String) - Static method in class org.apache.hadoop.metrics.MetricsUtil
Deprecated. Utility method to return the named context.
getContext() - Method in class org.apache.hadoop.streaming.PipeMapRed
 
getContextFactory() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Returns the factory by which this context was created.
getContextName() - Method in interface org.apache.hadoop.metrics.MetricsContext
Deprecated. Returns the context name.
getContextName() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext
Deprecated. Returns the context name.
getCookieDomain() - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Returns the cookie domain to use for the HTTP cookie.
getCookiePath() - Method in class org.apache.hadoop.security.authentication.server.AuthenticationFilter
Returns the cookie path to use for the HTTP cookie.
getCount() - Method in class org.apache.hadoop.record.Buffer
Get the current count of the buffer.
getCounter() - Method in class org.apache.hadoop.mapred.Counters.Counter
What is the current value of this counter?
getCounter(Enum) - Method in class org.apache.hadoop.mapred.Counters
Returns current value of the specified counter, or 0 if the counter does not exist.
getCounter(String) - Method in class org.apache.hadoop.mapred.Counters.Group
Returns the value of the specified counter, or 0 if the counter does not exist.
getCounter(int, String) - Method in class org.apache.hadoop.mapred.Counters.Group
Deprecated. use Counters.Group.getCounter(String) instead
getCounter(Enum<?>) - Method in interface org.apache.hadoop.mapred.Reporter
Get the Counters.Counter of the given group with the given name.
getCounter(String, String) - Method in interface org.apache.hadoop.mapred.Reporter
Get the Counters.Counter of the given group with the given name.
getCounter(String, String) - Method in class org.apache.hadoop.mapred.Task.TaskReporter
 
getCounter(Enum<?>) - Method in class org.apache.hadoop.mapred.Task.TaskReporter
 
getCounter(Enum<?>) - Method in class org.apache.hadoop.mapreduce.StatusReporter
 
getCounter(String, String) - Method in class org.apache.hadoop.mapreduce.StatusReporter
 
getCounter(Enum<?>) - Method in class org.apache.hadoop.mapreduce.TaskInputOutputContext
 
getCounter(String, String) - Method in class org.apache.hadoop.mapreduce.TaskInputOutputContext
 
getCounterForName(String) - Method in class org.apache.hadoop.mapred.Counters.Group
Get the counter for the given name and create it if it doesn't exist.
getCounters(Counters) - Method in class org.apache.hadoop.mapred.JobInProgress
Returns the total job counters, by adding together the job, the map and the reduce counters.
getCounters() - Method in interface org.apache.hadoop.mapred.RunningJob
Gets the counters for this job.
getCounters() - Method in class org.apache.hadoop.mapred.TaskReport
A table of counters.
getCounters() - Method in class org.apache.hadoop.mapred.TaskStatus
Get task's counters.
getCounters() - Method in class org.apache.hadoop.mapreduce.Job
Gets the counters for this job.
getCountersEnabled(JobConf) - Static method in class org.apache.hadoop.mapred.lib.MultipleOutputs
Returns if the counters for the named outputs are enabled or not.
getCountersEnabled(JobContext) - Static method in class org.apache.hadoop.mapreduce.lib.output.MultipleOutputs
Returns if the counters for the named outputs are enabled or not.
getCountQuery() - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat
Returns the query for getting the total number of rows, subclasses can override this for custom behaviour.
getCountQuery() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
Returns the query for getting the total number of rows, subclasses can override this for custom behaviour.
getCpuFrequency() - Method in class org.apache.hadoop.util.LinuxResourceCalculatorPlugin
Obtain the CPU frequency of on the system.
getCpuFrequency() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin
Obtain the CPU frequency of on the system.
getCpuUsage() - Method in class org.apache.hadoop.util.LinuxResourceCalculatorPlugin
Obtain the CPU usage % of the machine.
getCpuUsage() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin
Obtain the CPU usage % of the machine.
getCredentials() - Method in class org.apache.hadoop.mapred.JobConf
Get credentials for the job.
getCredentials() - Method in class org.apache.hadoop.mapreduce.JobContext
Get credentials for the job.
getCumulativeCpuTime() - Method in class org.apache.hadoop.util.LinuxResourceCalculatorPlugin
Obtain the cumulative CPU time since the system is on.
getCumulativeCpuTime() - Method in class org.apache.hadoop.util.ProcfsBasedProcessTree
Get the CPU time in millisecond used by all the processes in the process-tree since the process-tree created
getCumulativeCpuTime() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin
Obtain the cumulative CPU time since the system is on.
getCumulativeCpuTime() - Method in class org.apache.hadoop.util.ResourceCalculatorPlugin.ProcResourceValues
Obtain the cumulative CPU time used by a current process tree.
getCumulativeRssmem() - Method in class org.apache.hadoop.util.ProcfsBasedProcessTree
Get the cumulative resident set size (rss) memory used by all the processes in the process-tree.
getCumulativeRssmem(int) - Method in class org.apache.hadoop.util.ProcfsBasedProcessTree
Get the cumulative resident set size (rss) memory used by all the processes in the process-tree that are older than the passed in age.
getCumulativeVmem() - Method in class org.apache.hadoop.util.ProcfsBasedProcessTree
Get the cumulative virtual memory used by all the processes in the process-tree.
getCumulativeVmem(int) - Method in class org.apache.hadoop.util.ProcfsBasedProcessTree
Get the cumulative virtual memory used by all the processes in the process-tree that are older than the passed in age.
getCurrentIntervalValue() - Method in class org.apache.hadoop.metrics.util.MetricsTimeVaryingInt
Deprecated. The Value at the current interval
getCurrentIntervalValue() - Method in class org.apache.hadoop.metrics.util.MetricsTimeVaryingLong
Deprecated. The Value at the current interval
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
Get the current key
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.DelegatingRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.KeyValueLineRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.LineRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsTextRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileRecordReader
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.MapContext
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.RecordReader
Get the current key
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.ReduceContext
 
getCurrentKey() - Method in class org.apache.hadoop.mapreduce.TaskInputOutputContext
Get the current key.
getCurrentKey() - Method in class org.apache.hadoop.streaming.io.OutputReader
Returns the current key.
getCurrentKey() - Method in class org.apache.hadoop.streaming.io.RawBytesOutputReader
 
getCurrentKey() - Method in class org.apache.hadoop.streaming.io.TextOutputReader
 
getCurrentKey() - Method in class org.apache.hadoop.streaming.io.TypedBytesOutputReader
 
getCurrentSegmentGeneration(Directory) - Static method in class org.apache.hadoop.contrib.index.lucene.LuceneUtil
Get the generation (N) of the current segments_N file in the directory.
getCurrentSegmentGeneration(String[]) - Static method in class org.apache.hadoop.contrib.index.lucene.LuceneUtil
Get the generation (N) of the current segments_N file from a list of files.
getCurrentSplit(JobConf) - Static method in class org.apache.hadoop.streaming.StreamUtil
 
getCurrentStatus() - Method in class org.apache.hadoop.mapred.TaskReport
The current status
getCurrentTrashDir() - Method in class org.apache.hadoop.fs.FsShell
Returns the Trash object associated with this shell.
getCurrentUser() - Static method in class org.apache.hadoop.security.UserGroupInformation
Return the current user, including any doAs in the current stack.
getCurrentValue(Writable) - Method in class org.apache.hadoop.io.SequenceFile.Reader
Get the 'value' corresponding to the last read 'key'.
getCurrentValue(Object) - Method in class org.apache.hadoop.io.SequenceFile.Reader
Get the 'value' corresponding to the last read 'key'.
getCurrentValue(V) - Method in class org.apache.hadoop.mapred.SequenceFileRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
Get the current value.
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.DelegatingRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.KeyValueLineRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.LineRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileAsTextRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.MapContext
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.RecordReader
Get the current value.
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.ReduceContext
 
getCurrentValue() - Method in class org.apache.hadoop.mapreduce.TaskInputOutputContext
Get the current value.
getCurrentValue() - Method in class org.apache.hadoop.streaming.io.OutputReader
Returns the current value.
getCurrentValue() - Method in class org.apache.hadoop.streaming.io.RawBytesOutputReader
 
getCurrentValue() - Method in class org.apache.hadoop.streaming.io.TextOutputReader
 
getCurrentValue() - Method in class org.apache.hadoop.streaming.io.TypedBytesOutputReader
 
getData() - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
 
getData() - Method in class org.apache.hadoop.io.DataInputBuffer
 
getData() - Method in class org.apache.hadoop.io.DataOutputBuffer
Returns the current contents of the buffer.
getData() - Method in class org.apache.hadoop.io.OutputBuffer
Returns the current contents of the buffer.
getDate() - Static method in class org.apache.hadoop.util.VersionInfo
The date that Hadoop was compiled.
getDBConf() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
getDBConf() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
getDBProductName() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat
 
getDeclaredClass() - Method in class org.apache.hadoop.io.ObjectWritable
Return the class this is meant to be.
getDecommissionedTaskTrackerCount() - Method in class org.apache.hadoop.mapreduce.ClusterMetrics
Get the number of decommissioned trackers in the cluster.
getDecompressor(CompressionCodec) - Static method in class org.apache.hadoop.io.compress.CodecPool
Get a Decompressor for the given CompressionCodec from the pool or a new one.
getDecompressorType() - Method in class org.apache.hadoop.io.compress.BZip2Codec
This functionality is currently not supported.
getDecompressorType() - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Get the type of Decompressor needed by this CompressionCodec.
getDecompressorType() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
getDecompressorType() - Method in class org.apache.hadoop.io.compress.GzipCodec
 
getDecompressorType() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Get the type of Decompressor needed by this CompressionCodec.
getDefault() - Static method in class org.apache.hadoop.fs.permission.FsPermission
Get the default permission.
getDefaultAuthenticator() - Static method in class org.apache.hadoop.security.authentication.client.AuthenticatedURL
Returns the default Authenticator class to use when an AuthenticatedURL instance is created without specifying an authenticator.
getDefaultBlockSize() - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. use FileSystem.getDefaultBlockSize(Path) instead
getDefaultBlockSize(Path) - Method in class org.apache.hadoop.fs.FileSystem
Return the number of bytes that large input files should be optimally be split into to minimize i/o time.
getDefaultBlockSize() - Method in class org.apache.hadoop.fs.FilterFileSystem
Return the number of bytes that large input files should be optimally be split into to minimize i/o time.
getDefaultBlockSize() - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
getDefaultExtension() - Method in class org.apache.hadoop.io.compress.BZip2Codec
.bz2 is recognized as the default extension for compressed BZip2 files
getDefaultExtension() - Method in interface org.apache.hadoop.io.compress.CompressionCodec
Get the default filename extension for this kind of compression.
getDefaultExtension() - Method in class org.apache.hadoop.io.compress.DefaultCodec
 
getDefaultExtension() - Method in class org.apache.hadoop.io.compress.GzipCodec
 
getDefaultExtension() - Method in class org.apache.hadoop.io.compress.SnappyCodec
Get the default filename extension for this kind of compression.
getDefaultHost(String, String) - Static method in class org.apache.hadoop.net.DNS
Returns the default (first) host name associated by the provided nameserver with the address bound to the specified network interface
getDefaultHost(String) - Static method in class org.apache.hadoop.net.DNS
Returns the default (first) host name associated by the default nameserver with the address bound to the specified network interface
getDefaultIP(String) - Static method in class org.apache.hadoop.net.DNS
Returns the first available IP address associated with the provided network interface
getDefaultMaps() - Method in class org.apache.hadoop.mapred.JobClient
Get status information about the max available Maps in the cluster.
getDefaultPort() - Method in class org.apache.hadoop.fs.FileSystem
Get the default port for this file system.
getDefaultRealm() - Static method in class org.apache.hadoop.security.authentication.util.KerberosUtil
 
getDefaultRealm() - Method in class org.apache.hadoop.security.KerberosName
Get the configured default realm.
getDefaultReduces() - Method in class org.apache.hadoop.mapred.JobClient
Get status information about the max available Reduces in the cluster.
getDefaultReplication() - Method in class org.apache.hadoop.fs.FileSystem
Deprecated. use FileSystem.getDefaultReplication(Path) instead
getDefaultReplication(Path) - Method in class org.apache.hadoop.fs.FileSystem
Get the default replication.
getDefaultReplication() - Method in class org.apache.hadoop.fs.FilterFileSystem
Get the default replication.
getDefaultReplication() - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
getDefaultRetryPolicy(Configuration, String, boolean, String, String, Class<? extends Exception>) - Static method in class org.apache.hadoop.io.retry.RetryUtils
Return the default retry policy set in conf.
getDefaultSocketFactory(Configuration) - Static method in class org.apache.hadoop.net.NetUtils
Get the default socket factory as specified by the configuration parameter hadoop.rpc.socket.factory.default
getDefaultUri(Configuration) - Static method in class org.apache.hadoop.fs.FileSystem
Get the default filesystem URI from a configuration.
getDefaultWorkFile(TaskAttemptContext, String) - Method in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
Get the default path and filename for the output format.
getDelegate() - Method in class org.apache.hadoop.mapred.join.CompositeRecordReader
Obtain an iterator over the child RRs apropos of the value type ultimately emitted from this join.
getDelegate() - Method in class org.apache.hadoop.mapred.join.JoinRecordReader
Return an iterator wrapping the JoinCollector.
getDelegate() - Method in class org.apache.hadoop.mapred.join.MultiFilterRecordReader
Return an iterator returning a single value from the tuple.
getDelegationToken(String) - Method in class org.apache.hadoop.fs.FileSystem
Get a new delegation token for this file system.
getDelegationToken(Text) - Method in class org.apache.hadoop.mapred.JobClient
 
getDelegationToken(Text) - Method in class org.apache.hadoop.mapred.JobTracker
Get a new delegation token.
getDelegationToken(Credentials, String) - Static method in class org.apache.hadoop.mapreduce.security.TokenCache
 
getDelegationTokens(Configuration, Credentials) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
For each archive or cache file - get the corresponding delegation token
getDelegationTokenSecretManager() - Method in class org.apache.hadoop.mapred.JobTracker
 
getDependentJobs() - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
 
getDependingJobs() - Method in class org.apache.hadoop.mapred.jobcontrol.Job
 
getDescription() - Method in class org.apache.hadoop.metrics.util.MetricsBase
Deprecated.  
getDeserializer(Class<Serializable>) - Method in class org.apache.hadoop.io.serializer.JavaSerialization
 
getDeserializer(Class<T>) - Method in interface org.apache.hadoop.io.serializer.Serialization
 
getDeserializer(Class<T>) - Method in class org.apache.hadoop.io.serializer.SerializationFactory
 
getDeserializer(Class<Writable>) - Method in class org.apache.hadoop.io.serializer.WritableSerialization
 
getDiagnosticInfo() - Method in class org.apache.hadoop.mapred.TaskStatus
 
getDiagnostics() - Method in class org.apache.hadoop.mapred.TaskReport
A list of error messages.
getDigest() - Method in class org.apache.hadoop.io.MD5Hash
Returns the digest bytes.
getDigester() - Static method in class org.apache.hadoop.io.MD5Hash
Create a thread local MD5 digester
getDirectory() - Method in class org.apache.hadoop.contrib.index.mapred.IntermediateForm
Get the ram directory of the intermediate form.
getDirectory() - Method in class org.apache.hadoop.contrib.index.mapred.Shard
Get the directory where this shard resides.
getDirectoryCount() - Method in class org.apache.hadoop.fs.ContentSummary
 
getDirFailures() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the number of local directories that have failed on this tracker.
getDirPath() - Method in class org.apache.hadoop.fs.DF
 
getDirPath() - Method in class org.apache.hadoop.fs.DU
 
getDisplayName() - Method in class org.apache.hadoop.mapred.Counters.Group
Returns localized name of the group.
getDisplayName() - Method in class org.apache.hadoop.mapreduce.Counter
Get the name of the counter.
getDisplayName() - Method in class org.apache.hadoop.mapreduce.CounterGroup
Get the display name of the group.
getDistance(Node, Node) - Method in class org.apache.hadoop.net.NetworkTopology
Return the distance between two nodes It is assumed that the distance from one node to its parent is 1 The distance between two nodes is calculated by summing up their distances to their closest common ancestor.
getDistributionPolicyClass() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the distribution policy class.
getDmax(String) - Method in class org.apache.hadoop.metrics.ganglia.GangliaContext
Deprecated.  
getDocument() - Method in class org.apache.hadoop.contrib.index.mapred.DocumentAndOp
Get the document.
getDocumentAnalyzerClass() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the analyzer class.
getDoubleValue(Object) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
 
getDU(File) - Static method in class org.apache.hadoop.fs.FileUtil
Takes an input dir and returns the du on that local directory.
getElementTypeID() - Method in class org.apache.hadoop.record.meta.VectorTypeID
 
getEmptier() - Method in class org.apache.hadoop.fs.Trash
Return a Runnable that periodically empties the trash of all users, intended to be run by the superuser.
getEnd() - Method in class org.apache.hadoop.mapred.lib.db.DBInputFormat.DBInputSplit
 
getEnd() - Method in class org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit
 
getEndColumn() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
getEndLine() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
getEntry(MapFile.Reader[], Partitioner<K, V>, K, V) - Static method in class org.apache.hadoop.mapred.MapFileOutputFormat
Get an entry from output generated by this class.
getEntryComparator() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get a Comparator object to compare Entries.
getEntryCount() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get the number of key-value pair entries in TFile.
getEnum(String, T) - Method in class org.apache.hadoop.conf.Configuration
Return value matching this enumerated type.
getErrno() - Method in exception org.apache.hadoop.io.nativeio.NativeIOException
 
getError() - Static method in class org.apache.hadoop.log.metrics.EventCounter
 
getEventId() - Method in class org.apache.hadoop.mapred.TaskCompletionEvent
Returns event Id.
getEventType() - Method in class org.apache.hadoop.mapreduce.server.tasktracker.userlogs.UserLogEvent
Return the UserLogEvent.EventType.
getExceptions() - Method in exception org.apache.hadoop.io.MultipleIOException
 
getExcludedHosts() - Method in class org.apache.hadoop.util.HostsFileReader
 
getExecString() - Method in class org.apache.hadoop.fs.DF
 
getExecString() - Method in class org.apache.hadoop.fs.DU
 
getExecString() - Method in class org.apache.hadoop.util.Shell
return an array containing the command name & its parameters
getExecString() - Method in class org.apache.hadoop.util.Shell.ShellCommandExecutor
 
getExecutable(JobConf) - Static method in class org.apache.hadoop.mapred.pipes.Submitter
Get the URI of the application's executable.
getExitCode() - Method in exception org.apache.hadoop.util.Shell.ExitCodeException
 
getExitCode() - Method in class org.apache.hadoop.util.Shell
get the exit code
getExpires() - Method in class org.apache.hadoop.security.authentication.server.AuthenticationToken
Returns the expiration time of the token.
getExpiryDate() - Method in class org.apache.hadoop.security.token.delegation.DelegationKey
 
getFactor() - Method in class org.apache.hadoop.io.SequenceFile.Sorter
Get the number of streams to merge at once.
getFactory(Class) - Static method in class org.apache.hadoop.io.WritableFactories
Define a factory for a class.
getFactory() - Static method in class org.apache.hadoop.metrics.ContextFactory
Deprecated. Returns the singleton ContextFactory instance, constructing it if necessary.
getFailedJobList() - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl
 
getFailedJobs() - Method in class org.apache.hadoop.mapred.jobcontrol.JobControl
 
getFailureInfo() - Method in class org.apache.hadoop.mapred.JobStatus
gets any available info on the reason of failure of the job.
getFailureInfo() - Method in interface org.apache.hadoop.mapred.RunningJob
Get failure info for the job.
getFallBackAuthenticator() - Method in class org.apache.hadoop.security.authentication.client.KerberosAuthenticator
If the specified URL does not support SPNEGO authentication, a fallback Authenticator will be used.
getFatal() - Static method in class org.apache.hadoop.log.metrics.EventCounter
 
getFetchFailedMaps() - Method in class org.apache.hadoop.mapred.TaskStatus
Get the list of maps from which output-fetches failed.
getFieldID() - Method in class org.apache.hadoop.record.meta.FieldTypeInfo
get the field's id (name)
getFieldNames() - Method in class org.apache.hadoop.mapreduce.lib.db.DBRecordReader
 
getFieldSeparator() - Method in class org.apache.hadoop.streaming.PipeMapper
 
getFieldSeparator() - Method in class org.apache.hadoop.streaming.PipeMapRed
Returns the field separator to be used.
getFieldSeparator() - Method in class org.apache.hadoop.streaming.PipeReducer
 
getFieldTypeInfos() - Method in class org.apache.hadoop.record.meta.RecordTypeInfo
Return a collection of field type infos
getFieldTypeInfos() - Method in class org.apache.hadoop.record.meta.StructTypeID
 
getFile(String, String) - Method in class org.apache.hadoop.conf.Configuration
Get a local file name under a directory named in dirsProp with the given path.
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.hadoop.fs.FileSystem
Return an array containing hostnames, offset and size of portions of the given file.
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.hadoop.fs.FilterFileSystem
 
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.hadoop.fs.HarFileSystem
Get block locations from the underlying fs and fix their offsets and lengths.
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
Return null if the file doesn't exist; otherwise, get the locations of the various chunks of the file file from KFS.
getFileBlockLocations(FileSystem, FileStatus) - Method in class org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat
 
getFileChecksum(Path) - Method in class org.apache.hadoop.fs.FileSystem
Get the checksum of a file.
getFileChecksum(Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
Get the checksum of a file.
getFileChecksum(Path) - Method in class org.apache.hadoop.fs.HarFileSystem
 
getFileClassPaths(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get the file entries in classpath as an array of Path.
getFileCount() - Method in class org.apache.hadoop.fs.ContentSummary
 
getFileName() - Method in class org.apache.hadoop.metrics.file.FileContext
Deprecated. Returns the configured file name, or null.
getFiles(PathFilter) - Method in class org.apache.hadoop.fs.InMemoryFileSystem
Deprecated.  
getFileStatus(Configuration, URI) - Static method in class org.apache.hadoop.filecache.DistributedCache
Returns FileStatus of a given cache file on hdfs.
getFileStatus(Path) - Method in class org.apache.hadoop.fs.FileSystem
Return a file status object that represents the path.
getFileStatus(Path) - Method in class org.apache.hadoop.fs.FilterFileSystem
Get file status.
getFileStatus(Path) - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
 
getFileStatus(Path) - Method in class org.apache.hadoop.fs.HarFileSystem
return the filestatus of files in har archive.
getFileStatus(Path) - Method in class org.apache.hadoop.fs.kfs.KosmosFileSystem
 
getFileStatus(Path) - Method in class org.apache.hadoop.fs.RawLocalFileSystem
 
getFileStatus(Path) - Method in class org.apache.hadoop.fs.s3.S3FileSystem
FileStatus for S3 file systems.
getFileStatus(Path) - Method in class org.apache.hadoop.fs.s3native.NativeS3FileSystem
 
getFilesystem() - Method in class org.apache.hadoop.fs.DF
 
getFileSystem(Configuration) - Method in class org.apache.hadoop.fs.Path
Return the FileSystem that owns this Path.
getFileSystemCounterNames(String) - Static method in class org.apache.hadoop.mapred.Task
Counters to measure the usage of the different file systems.
getFilesystemName() - Method in class org.apache.hadoop.mapred.JobTracker
Grab the local fs name
getFileTimestamps(Configuration) - Static method in class org.apache.hadoop.filecache.DistributedCache
Get the timestamps of the files.
getFileType() - Method in class org.apache.hadoop.fs.s3.INode
 
getFileVisibilities(Configuration) - Static method in class org.apache.hadoop.filecache.TrackerDistributedCacheManager
Get the booleans on whether the files are public or not.
getFinalSync(JobConf) - Static method in class org.apache.hadoop.examples.terasort.TeraOutputFormat
Does the user want a final sync at close?
getFinishTime() - Method in class org.apache.hadoop.mapred.JobInProgress
 
getFinishTime() - Method in class org.apache.hadoop.mapred.TaskReport
Get finish time of task.
getFinishTime() - Method in class org.apache.hadoop.mapred.TaskStatus
Get task finish time.
getFirst() - Method in class org.apache.hadoop.examples.SecondarySort.IntPair
 
getFirstKey() - Method in class org.apache.hadoop.io.file.tfile.TFile.Reader
Get the first key in the TFile.
getFlippable() - Method in class org.apache.hadoop.examples.dancing.Pentomino.Piece
 
getFloat(String, float) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as a float.
getFormatMinSplitSize() - Method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
Get the lower bound on split size imposed by the format.
getFormatMinSplitSize() - Method in class org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat
 
getFormattedTimeWithDiff(DateFormat, long, long) - Static method in class org.apache.hadoop.util.StringUtils
Formats time in ms and appends difference (finishTime - startTime) as returned by formatTimeDiff().
getFs() - Method in class org.apache.hadoop.mapred.JobClient
Get a filesystem handle.
getFSSize() - Method in class org.apache.hadoop.fs.InMemoryFileSystem
Deprecated.  
getFsStatistics(Path, Configuration) - Static method in class org.apache.hadoop.mapred.Task
Gets a handle to the Statistics instance based on the scheme associated with path.
getGangliaConfForMetric(String) - Method in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
Lookup GangliaConf from cache.
getGeneration() - Method in class org.apache.hadoop.contrib.index.mapred.Shard
Get the generation of the Lucene instance.
getGET_PERMISSION_COMMAND() - Static method in class org.apache.hadoop.util.Shell
Return a Unix command to get permission information.
getGraylistedNodesInfoJson() - Method in class org.apache.hadoop.mapred.JobTracker
 
getGraylistedNodesInfoJson() - Method in interface org.apache.hadoop.mapred.JobTrackerMXBean
 
getGrayListedTaskTrackerCount() - Method in class org.apache.hadoop.mapreduce.ClusterMetrics
Get the number of graylisted trackers in the cluster.
getGraylistedTrackerNames() - Method in class org.apache.hadoop.mapred.ClusterStatus
Get the names of graylisted task trackers in the cluster.
getGraylistedTrackers() - Method in class org.apache.hadoop.mapred.ClusterStatus
Get the number of graylisted task trackers in the cluster.
getGroup() - Method in class org.apache.hadoop.fs.FileStatus
Get the group associated with the file.
getGroup(String) - Method in class org.apache.hadoop.mapred.Counters
Returns the named counter group, or an empty group if there is none with the specified name.
getGroup(String) - Method in class org.apache.hadoop.mapreduce.Counters
Returns the named counter group, or an empty group if there is none with the specified name.
getGroupAction() - Method in class org.apache.hadoop.fs.permission.FsPermission
Return group FsAction.
getGroupingComparator() - Method in class org.apache.hadoop.mapreduce.JobContext
Get the user defined RawComparator comparator for grouping keys of inputs to the reduce.
getGroupName() - Method in class org.apache.hadoop.fs.permission.PermissionStatus
Return group name
getGroupNames() - Method in class org.apache.hadoop.mapred.Counters
Returns the names of all counter classes.
getGroupNames() - Method in class org.apache.hadoop.mapreduce.Counters
Returns the names of all counter classes.
getGroupNames() - Method in class org.apache.hadoop.security.UserGroupInformation
Get the group names for this user.
getGroups(String) - Method in class org.apache.hadoop.security.Groups
Get the group memberships of a given user.
getGroups(String) - Method in class org.apache.hadoop.security.JniBasedUnixGroupsMapping
 
getGroups(String) - Method in class org.apache.hadoop.security.JniBasedUnixGroupsNetgroupMapping
Gets unix groups and netgroups for the user.
getGroups(String) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsMapping
 
getGroups(String) - Method in class org.apache.hadoop.security.ShellBasedUnixGroupsNetgroupMapping
 
getGroupsCommand() - Static method in class org.apache.hadoop.util.Shell
a Unix command to get the current user's groups list
getGroupsForUserCommand(String) - Static method in class org.apache.hadoop.util.Shell
a Unix command to get a given user's groups list
getHadoopClientHome() - Method in class org.apache.hadoop.streaming.StreamJob
 
getHarHash(Path) - Static method in class org.apache.hadoop.fs.HarFileSystem
the hash of the path p inside iniside the filesystem
getHarVersion() - Method in class org.apache.hadoop.fs.HarFileSystem
 
getHashType(Configuration) - Static method in class org.apache.hadoop.util.hash.Hash
This utility method converts the name of the configured hash type to a symbolic constant.
getHeader(boolean) - Static method in class org.apache.hadoop.fs.ContentSummary
Return the header of the output.
getHeader() - Method in class org.apache.hadoop.util.DataChecksum
 
getHealthStatus() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Returns health status of the task tracker.
getHistoryFilePath(JobID) - Static method in class org.apache.hadoop.mapred.JobHistory
Given the job id, return the history file path from the cache
getHomeDirectory() - Method in class org.apache.hadoop.fs.FileSystem
Return the current user's home directory in this filesystem.
getHomeDirectory() - Method in class org.apache.hadoop.fs.FilterFileSystem
 
getHomeDirectory() - Method in class org.apache.hadoop.fs.ftp.FTPFileSystem
 
getHomeDirectory() - Method in class org.apache.hadoop.fs.HarFileSystem
return the top level archive path.
getHomeDirectory() - Method in class org.apache.hadoop.fs.RawLocalFileSystem
 
getHost() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
 
getHost() - Method in class org.apache.hadoop.streaming.Environment
 
getHostAddress() - Method in class org.apache.hadoop.ipc.Server.Connection
 
getHostFromPrincipal(String) - Static method in class org.apache.hadoop.security.SecurityUtil
Get the host name from the principal name of format /host@realm.
getHostInetAddress() - Method in class org.apache.hadoop.ipc.Server.Connection
 
getHostname() - Method in class org.apache.hadoop.mapred.JobTracker
 
getHostname() - Method in interface org.apache.hadoop.mapred.JobTrackerMXBean
 
getHostname() - Method in class org.apache.hadoop.mapred.TaskTracker
 
getHostname() - Method in interface org.apache.hadoop.mapred.TaskTrackerMXBean
 
getHostName() - Method in class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
 
getHostName() - Method in class org.apache.hadoop.security.KerberosName
Get the second component of the name.
getHostname() - Static method in class org.apache.hadoop.util.StringUtils
Return hostname without throwing exception.
getHosts() - Method in class org.apache.hadoop.fs.BlockLocation
Get the list of hosts (hostname) hosting this block
getHosts(String, String) - Static method in class org.apache.hadoop.net.DNS
Returns all the host names associated by the provided nameserver with the address bound to the specified network interface
getHosts(String) - Static method in class org.apache.hadoop.net.DNS
Returns all the host names associated by the default nameserver with the address bound to the specified network interface
getHosts() - Method in class org.apache.hadoop.util.HostsFileReader
 
getHttpPort() - Method in class org.apache.hadoop.mapred.TaskTracker
 
getHttpPort() - Method in interface org.apache.hadoop.mapred.TaskTrackerMXBean
 
getHttpPort() - Method in class org.apache.hadoop.mapred.TaskTrackerStatus
Get the port that this task tracker is serving http requests on.
getId() - Method in class org.apache.hadoop.fs.s3.Block
 
getId(Class) - Method in class org.apache.hadoop.io.AbstractMapWritable
 
getID() - Method in interface org.apache.hadoop.mapred.RunningJob
Get the job identifier.
getId() - Method in class org.apache.hadoop.mapreduce.ID
returns the int which represents the identifier
getIdentifier(String, SecretManager<T>) - Static method in class org.apache.hadoop.security.SaslRpcServer
 
getIdentifier() - Method in class org.apache.hadoop.security.token.Token
Get the token identifier
GetImage() - Method in class org.apache.hadoop.record.compiler.generated.SimpleCharStream
 
getIncludeCounters() - Method in class org.apache.hadoop.mapred.TaskStatus
 
getIndexInputFormatClass() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the index input format class.
getIndexInterval() - Method in class org.apache.hadoop.io.MapFile.Writer
The number of entries that are added before an index entry is added.
getIndexMaxFieldLength() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the max field length for a Lucene instance.
getIndexMaxNumSegments() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the max number of segments for a Lucene instance.
getIndexShards() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the string representation of a number of shards.
getIndexShards(IndexUpdateConfiguration) - Static method in class org.apache.hadoop.contrib.index.mapred.Shard
 
getIndexUpdaterClass() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the index updater class.
getIndexUseCompoundFile() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Check whether to use the compound file format for a Lucene instance.
getInfo() - Method in class org.apache.hadoop.contrib.failmon.CPUParser
Return a String with information about this class
getInfo() - Method in class org.apache.hadoop.contrib.failmon.HadoopLogParser
Return a String with information about this class
getInfo() - Method in interface org.apache.hadoop.contrib.failmon.Monitored
Return a String with information about the implementing class
getInfo() - Method in class org.apache.hadoop.contrib.failmon.NICParser
Return a String with information about this class
getInfo() - Method in class org.apache.hadoop.contrib.failmon.SensorsParser
Return a String with information about this class
getInfo() - Method in class org.apache.hadoop.contrib.failmon.SMARTParser
Return a String with information about this class
getInfo() - Method in class org.apache.hadoop.contrib.failmon.SystemLogParser
Return a String with information about this class
getInfo() - Static method in class org.apache.hadoop.log.metrics.EventCounter
 
getInfoPort() - Method in class org.apache.hadoop.mapred.JobTracker
 
getInputBoundingQuery() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputClass() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputConditions() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputCountQuery() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputDataLength() - Method in class org.apache.hadoop.mapreduce.split.JobSplit.SplitMetaInfo
 
getInputDataLength() - Method in class org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo
 
getInputFieldNames() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputFileBasedOutputFileName(JobConf, String) - Method in class org.apache.hadoop.mapred.lib.MultipleOutputFormat
Generate the outfile name based on a given anme and the input file name.
getInputFormat() - Method in class org.apache.hadoop.mapred.JobConf
Get the InputFormat implementation for the map-reduce job, defaults to TextInputFormat if not specified explicity.
getInputFormatClass() - Method in class org.apache.hadoop.mapreduce.JobContext
Get the InputFormat class for the job.
getInputOrderBy() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputPathFilter(JobConf) - Static method in class org.apache.hadoop.mapred.FileInputFormat
Get a PathFilter instance of the filter set for the input paths.
getInputPathFilter(JobContext) - Static method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
Get a PathFilter instance of the filter set for the input paths.
getInputPaths(JobConf) - Static method in class org.apache.hadoop.mapred.FileInputFormat
Get the list of input Paths for the map-reduce job.
getInputPaths(JobContext) - Static method in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
Get the list of input Paths for the map-reduce job.
getInputQuery() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputSeparator() - Method in class org.apache.hadoop.streaming.PipeMapper
 
getInputSeparator() - Method in class org.apache.hadoop.streaming.PipeMapRed
Returns the input separator to be used.
getInputSeparator() - Method in class org.apache.hadoop.streaming.PipeReducer
 
getInputSplit() - Method in interface org.apache.hadoop.mapred.Reporter
Get the InputSplit object for a map.
getInputSplit() - Method in class org.apache.hadoop.mapred.Task.TaskReporter
 
getInputSplit() - Method in class org.apache.hadoop.mapreduce.MapContext
Get the input split for this map.
getInputStream(Socket) - Static method in class org.apache.hadoop.net.NetUtils
Same as getInputStream(socket, socket.getSoTimeout()).

From documentation for NetUtils.getInputStream(Socket, long):
Returns InputStream for the socket.
getInputStream(Socket, long) - Static method in class org.apache.hadoop.net.NetUtils
Returns InputStream for the socket.
getInputStream(InputStream) - Method in class org.apache.hadoop.security.SaslRpcClient
Get a SASL wrapped InputStream.
getInputTableName() - Method in class org.apache.hadoop.mapreduce.lib.db.DBConfiguration
 
getInputWriterClass() - Method in class org.apache.hadoop.streaming.io.IdentifierResolver
Returns the resolved InputWriter class.
getInstance() - Static method in class org.apache.hadoop.io.ReadaheadPool
Return the singleton instance for the current process.
getInstance(int) - Static method in class org.apache.hadoop.util.hash.Hash
Get a singleton instance of hash function of a given type.
getInstance(Configuration) - Static method in class org.apache.hadoop.util.hash.Hash
Get a singleton instance of hash function of a type defined in the configuration.
getInstance() - Static method in class org.apache.hadoop.util.hash.JenkinsHash
 
getInstance() - Static method in class org.apache.hadoop.util.hash.MurmurHash
 
getInstances(String, Class<U>) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as a List of objects implementing the interface specified by xface.
getInt(String, int) - Method in class org.apache.hadoop.conf.Configuration
Get the value of the name property as an int.
getInterfaceName() - Method in exception org.apache.hadoop.ipc.RPC.VersionMismatch
Get the interface name
getInterval(ArrayList<MonitorJob>) - Static method in class org.apache.hadoop.contrib.failmon.Environment
Determines the minimum interval at which the executor thread needs to wake upto execute jobs.
getIOSortMB() - Method in class org.apache.hadoop.contrib.index.mapred.IndexUpdateConfiguration
Get the IO sort space in MB.
getIPs(String) - Static method in class org.apache.hadoop.net.DNS
Like DNS.getIPs(String, boolean), but returns all IPs associated with the given interface and its subinterfaces.
getIPs(String, boolean) - Static method in class org.apache.hadoop.net.DNS
Returns all the IPs associated with the provided interface, if any, in textual form.
getIPs(String, boolean) - Static method in class org.apache.hadoop.net.NetUtils
Return an InetAddress for each interface that matches the given subnet specified using CIDR notation.
getIsCleanup() - Method in class org.apache.hadoop.mapred.TaskLogAppender
Get whether task is cleanup attempt or not.
getIsJavaMapper(JobConf) - Static method in class org.apache.hadoop.mapred.pipes.Submitter
Check whether the job is using a Java Mapper.
getIsJavaRecordReader(JobConf) - Static method in class org.apache.hadoop.mapred.pipes.Submitter
Check whether the job is using a Java RecordReader
getIsJavaRecordWriter(JobConf) - Static method in class org.apache.hadoop.mapred.pipes.Submitter
Will the reduce use a Java RecordWriter?
getIsJavaReducer(JobConf) - Static method in class org.apache.hadoop.mapred.pipes.Submitter
Check whether the job is using a Java Reducer.
getIsMap() - Method in class org.apache.hadoop.mapred.TaskStatus
 
getIssueDate() - Method in class org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier
 
getJar() - Method in class org.apache.hadoop.mapred.JobConf
Get the user jar for the map-reduce job.
getJar() - Method in class org.apache.hadoop.mapreduce.Job
Get the pathname of the job's jar.
getJar() - Method in class org.apache.hadoop.mapreduce.JobContext
Get the pathname of the job's jar.
getJob(JobID) - Method in class org.apache.hadoop.mapred.JobClient
Get an RunningJob object to track an ongoing job.
getJob(String) - Method in class org.apache.hadoop.mapred.JobClient
Deprecated. Applications should rather use JobClient.getJob(JobID).
getJob(JobID) - Method in class org.apache.hadoop.mapred.JobTracker
 
getJob() - Method in class org.apache.hadoop.mapred.lib.CombineFileSplit
 
getJob() - Method in class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
 
getJobACLs() - Method in class org.apache.hadoop.mapred.JobHistory.JobInfo
Get the job acls.