类 org.apache.hadoop.mapred.JobConf
的使用

使用JobConf的程序包

程序包	说明
org.apache.hadoop.contrib.index.example
org.apache.hadoop.contrib.index.mapred
org.apache.hadoop.contrib.utils.join
org.apache.hadoop.examples	Hadoop example code.
org.apache.hadoop.examples.dancing	This package is a distributed implementation of Knuth's dancing links algorithm that can run under Hadoop.
org.apache.hadoop.examples.terasort	This package consists of 3 map/reduce applications for Hadoop to compete in the annual terabyte sort competition.
org.apache.hadoop.mapred	A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner.
org.apache.hadoop.mapred.jobcontrol	Utilities for managing dependent jobs.
org.apache.hadoop.mapred.join	Given a set of sorted datasets keyed with the same class and yielding equal partitions, it is possible to effect a join of those datasets prior to the map.
org.apache.hadoop.mapred.lib	Library of generally useful mappers, reducers, and partitioners.
org.apache.hadoop.mapred.lib.aggregate	Classes for performing various counting and aggregations.
org.apache.hadoop.mapred.lib.db	org.apache.hadoop.mapred.lib.db Package This package contains a library to read records from a database as an input to a mapreduce job, and write the output records to the database.
org.apache.hadoop.mapred.pipes	Hadoop Pipes allows C++ code to use Hadoop DFS and map/reduce.
org.apache.hadoop.mapreduce
org.apache.hadoop.streaming	Hadoop Streaming is a utility which allows users to create and run Map-Reduce jobs with any executables (e.g.
org.apache.hadoop.tools
org.apache.hadoop.tools.rumen	Rumen is a data extraction and analysis tool built for Apache Hadoop.

org.apache.hadoop.contrib.index.example中JobConf的使用

参数类型为JobConf的org.apache.hadoop.contrib.index.example中的方法

限定符和类型	方法和说明
void	LineDocLocalAnalysis.configure(JobConf job)
void	IdentityLocalAnalysis.configure(JobConf job)
RecordReader<DocumentID,LineDocTextAndOp>	LineDocInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

org.apache.hadoop.contrib.index.mapred中JobConf的使用

参数类型为JobConf的org.apache.hadoop.contrib.index.mapred中的方法

限定符和类型	方法和说明
void	IndexUpdateReducer.configure(JobConf job)
void	IndexUpdatePartitioner.configure(JobConf job)
void	IndexUpdateMapper.configure(JobConf job)
void	IndexUpdateCombiner.configure(JobConf job)
RecordWriter<Shard,Text>	IndexUpdateOutputFormat.getRecordWriter(FileSystem fs, JobConf job, String name, Progressable progress)

org.apache.hadoop.contrib.utils.join中JobConf的使用

声明为JobConf的org.apache.hadoop.contrib.utils.join中的字段

限定符和类型	字段和说明
protected JobConf	DataJoinReducerBase.job
protected JobConf	DataJoinMapperBase.job

返回JobConf的org.apache.hadoop.contrib.utils.join中的方法

限定符和类型	方法和说明
static JobConf	DataJoinJob.createDataJoinJob(String[] args)

参数类型为JobConf的org.apache.hadoop.contrib.utils.join中的方法

限定符和类型	方法和说明
TaggedMapOutput	TaggedMapOutput.clone(JobConf job)
void	JobBase.configure(JobConf job) Initializes a new instance from a JobConf.
void	DataJoinReducerBase.configure(JobConf job)
void	DataJoinMapperBase.configure(JobConf job)
static boolean	DataJoinJob.runJob(JobConf job) Submit/run a map/reduce job.

org.apache.hadoop.examples中JobConf的使用

返回JobConf的org.apache.hadoop.examples中的方法

限定符和类型	方法和说明
JobConf	SleepJob.setupJobConf(int numMapper, int numReducer, long mapSleepTime, int mapSleepCount, long reduceSleepTime, int reduceSleepCount)

参数类型为JobConf的org.apache.hadoop.examples中的方法

限定符和类型	方法和说明
void	SleepJob.configure(JobConf job)
void	PiEstimator.PiReducer.configure(JobConf job) Store job configuration.
static BigDecimal	PiEstimator.estimate(int numMaps, long numPoints, JobConf jobConf) Run a map/reduce job for estimating Pi.
RecordReader<IntWritable,IntWritable>	SleepJob.SleepInputFormat.getRecordReader(InputSplit ignored, JobConf conf, Reporter reporter)
RecordReader<MultiFileWordCount.WordOffset,Text>	MultiFileWordCount.MyInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
InputSplit[]	SleepJob.SleepInputFormat.getSplits(JobConf conf, int numSplits)

org.apache.hadoop.examples.dancing中JobConf的使用

参数类型为JobConf的org.apache.hadoop.examples.dancing中的方法

限定符和类型	方法和说明
void	DistributedPentomino.PentMap.configure(JobConf conf)

org.apache.hadoop.examples.terasort中JobConf的使用

参数类型为JobConf的org.apache.hadoop.examples.terasort中的方法

限定符和类型	方法和说明
static boolean	TeraOutputFormat.getFinalSync(JobConf conf) Does the user want a final sync at close?
RecordReader<Text,Text>	TeraInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
RecordWriter<Text,Text>	TeraOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
InputSplit[]	TeraInputFormat.getSplits(JobConf conf, int splits)
static void	TeraOutputFormat.setFinalSync(JobConf conf, boolean newValue) Set the requirement for a final sync before the stream is closed.
static void	TeraInputFormat.writePartitionFile(JobConf conf, Path partFile) Use the input splits to take samples of the input and generate sample keys.

org.apache.hadoop.mapred中JobConf的使用

声明为JobConf的org.apache.hadoop.mapred中的字段

限定符和类型	字段和说明
protected JobConf	Task.conf
protected JobConf	Task.CombinerRunner.job
protected JobConf	JobLocalizer.ttConf

返回JobConf的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
JobConf	JobTracker.getConf() Returns a handle to the JobTracker's Configuration
JobConf	TaskAttemptContext.getJobConf()
JobConf	JobContext.getJobConf() Get the job Configuration

参数类型为JobConf的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
static void	FileInputFormat.addInputPath(JobConf conf, Path path) Add a Path to the list of inputs for the map-reduce job.
static void	FileInputFormat.addInputPaths(JobConf conf, String commaSeparatedPaths) Add the given comma separated paths to the list of inputs for the map-reduce job.
void	SequenceFileAsBinaryOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job)
void	OutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job) Check for validity of the output-specification for the job.
void	FileOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job)
void	TextInputFormat.configure(JobConf conf)
void	MapRunner.configure(JobConf job)
void	MapReduceBase.configure(JobConf job) Default implementation that does nothing.
void	KeyValueTextInputFormat.configure(JobConf conf)
void	JobConfigurable.configure(JobConf job) Initializes a new instance from a JobConf.
void	JobLocalizer.createWorkDir(JobConf jConf)
static boolean	FileOutputFormat.getCompressOutput(JobConf conf) Is the job output compressed?
static PathFilter	FileInputFormat.getInputPathFilter(JobConf conf) Get a PathFilter instance of the filter set for the input paths.
static Path[]	FileInputFormat.getInputPaths(JobConf conf) Get the list of input Paths for the map-reduce job.
static String	JobHistory.JobInfo.getJobHistoryFileName(JobConf jobConf, JobID id) Recover the job history filename from the history folder.
static Path	JobHistory.JobInfo.getJobHistoryLogLocationForUser(String logFileName, JobConf jobConf) Get the user job history file path
static SequenceFile.CompressionType	SequenceFileOutputFormat.getOutputCompressionType(JobConf conf) Get the SequenceFile.CompressionType for the output SequenceFile.
static Class<? extends CompressionCodec>	FileOutputFormat.getOutputCompressorClass(JobConf conf, Class<? extends CompressionCodec> defaultValue) Get the CompressionCodec for compressing the job outputs.
static Path	FileOutputFormat.getOutputPath(JobConf conf) Get the Path to the output directory for the map-reduce job.
static Path	FileOutputFormat.getPathForCustomFile(JobConf conf, String name) Helper function to generate a Path for a file that is unique for the task within the job output directory.
RecordReader<LongWritable,Text>	TextInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
RecordReader<K,V>	SequenceFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
RecordReader<K,V>	SequenceFileInputFilter.getRecordReader(InputSplit split, JobConf job, Reporter reporter) Create a record reader for the given split
RecordReader<Text,Text>	SequenceFileAsTextInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
RecordReader<BytesWritable,BytesWritable>	SequenceFileAsBinaryInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
abstract RecordReader<K,V>	MultiFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) 已过时。
RecordReader<Text,Text>	KeyValueTextInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
RecordReader<K,V>	InputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) Get the RecordReader for the given InputSplit.
abstract RecordReader<K,V>	FileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
RecordWriter<K,V>	TextOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
RecordWriter<K,V>	SequenceFileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
RecordWriter<BytesWritable,BytesWritable>	SequenceFileAsBinaryOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
RecordWriter<K,V>	OutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress) Get the RecordWriter for the given job.
RecordWriter<WritableComparable,Writable>	MapFileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
abstract RecordWriter<K,V>	FileOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
String	TaskController.getRunAsUser(JobConf conf) Returns the local unix user that a given job will run as.
static Class<? extends WritableComparable>	SequenceFileAsBinaryOutputFormat.getSequenceFileOutputKeyClass(JobConf conf) Get the key class for the SequenceFile
static Class<? extends Writable>	SequenceFileAsBinaryOutputFormat.getSequenceFileOutputValueClass(JobConf conf) Get the value class for the SequenceFile
InputSplit[]	MultiFileInputFormat.getSplits(JobConf job, int numSplits) 已过时。
InputSplit[]	InputFormat.getSplits(JobConf job, int numSplits) Logically split the set of input files for the job.
InputSplit[]	FileInputFormat.getSplits(JobConf job, int numSplits) Splits files returned by FileInputFormat.listStatus(JobConf) when they're too big.
static long	TaskLog.getTaskLogLength(JobConf conf) Get the desired maximum length of task's logs.
static JobClient.TaskStatusFilter	JobClient.getTaskOutputFilter(JobConf job) Get the task output filter out of the JobConf.
static Path	FileOutputFormat.getTaskOutputPath(JobConf conf, String name) Helper function to create the task's temporary output directory and return the path to the task's output file.
static String	FileOutputFormat.getUniqueName(JobConf conf, String name) Helper function to generate a name that is unique for the task.
static String	JobHistory.JobInfo.getUserName(JobConf jobConf) Get the user name from the job conf
static Path	FileOutputFormat.getWorkOutputPath(JobConf conf) Get the Path to the task's temporary output directory for the map-reduce job Tasks' Side-Effect Files Note: The following is valid only if the OutputCommitter is FileOutputCommitter.
void	JobClient.init(JobConf conf) Connect to the default JobTracker.
static void	JobHistory.init(JobTracker jobTracker, JobConf conf, String hostname, long jobTrackerStartTime) Initialize JobHistory files.
void	Task.initialize(JobConf job, JobID id, Reporter reporter, boolean useNewApi)
protected void	TaskTracker.launchTaskForJob(org.apache.hadoop.mapred.TaskTracker.TaskInProgress tip, JobConf jobConf, org.apache.hadoop.mapred.TaskTracker.RunningJob rjob)
protected FileStatus[]	SequenceFileInputFormat.listStatus(JobConf job)
protected FileStatus[]	FileInputFormat.listStatus(JobConf job) List input directories.
void	Task.localizeConfiguration(JobConf conf) Localize the given JobConf to be specific for this task.
void	JobLocalizer.localizeJobFiles(JobID jobid, JobConf jConf, Path localJobFile, Path localJobTokenFile, TaskUmbilicalProtocol taskTracker)
void	JobLocalizer.localizeJobFiles(JobID jobid, JobConf jConf, Path localJobTokenFile, TaskUmbilicalProtocol taskTracker)
static void	JobEndNotifier.localRunnerNotification(JobConf conf, JobStatus status)
static void	JobHistory.JobInfo.logSubmitted(JobID jobId, JobConf jobConf, String jobConfPath, long submitTime) 已过时。 Use JobHistory.JobInfo.logSubmitted(JobID, JobConf, String, long, boolean) instead.
static void	JobHistory.JobInfo.logSubmitted(JobID jobId, JobConf jobConf, String jobConfPath, long submitTime, boolean restarted)
boolean	JobClient.monitorAndPrintJob(JobConf conf, RunningJob job) Monitor a job and print status in real-time as progress is made and tasks fail.
static Path	JobHistory.JobInfo.recoverJobHistoryFile(JobConf conf, Path logFilePath) Selects one of the two files generated as a part of recovery.
static void	JobEndNotifier.registerNotification(JobConf jobConf, JobStatus status)
abstract void	Task.run(JobConf job, TaskUmbilicalProtocol umbilical) Run this task as a part of the named job.
static RunningJob	JobClient.runJob(JobConf job) Utility that submits a job, then polls for progress until the job is complete.
static void	FileOutputFormat.setCompressOutput(JobConf conf, boolean compress) Set whether the output of the job is compressed.
static void	FileInputFormat.setInputPathFilter(JobConf conf, Class<? extends PathFilter> filter) Set a PathFilter to be applied to the input paths for the map-reduce job.
static void	FileInputFormat.setInputPaths(JobConf conf, Path... inputPaths) Set the array of Paths as the list of inputs for the map-reduce job.
static void	FileInputFormat.setInputPaths(JobConf conf, String commaSeparatedPaths) Sets the given comma separated paths as the list of inputs for the map-reduce job.
static void	SequenceFileOutputFormat.setOutputCompressionType(JobConf conf, SequenceFile.CompressionType style) Set the SequenceFile.CompressionType for the output SequenceFile.
static void	FileOutputFormat.setOutputCompressorClass(JobConf conf, Class<? extends CompressionCodec> codecClass) Set the CompressionCodec to be used to compress job outputs.
static void	FileOutputFormat.setOutputPath(JobConf conf, Path outputDir) Set the Path of the output directory for the map-reduce job.
static void	SequenceFileAsBinaryOutputFormat.setSequenceFileOutputKeyClass(JobConf conf, Class<?> theClass) Set the key class for the SequenceFile This allows the user to specify the key class to be different from the actual class (BytesWritable) used for writing
static void	SequenceFileAsBinaryOutputFormat.setSequenceFileOutputValueClass(JobConf conf, Class<?> theClass) Set the value class for the SequenceFile This allows the user to specify the value class to be different from the actual class (BytesWritable) used for writing
static void	SkipBadRecords.setSkipOutputPath(JobConf conf, Path path) Set the directory to which skipped records are written.
static void	JobClient.setTaskOutputFilter(JobConf job, JobClient.TaskStatusFilter newValue) Modify the JobConf to set the task output filter.
static JobTracker	JobTracker.startTracker(JobConf conf) Start the JobTracker with given configuration.
static JobTracker	JobTracker.startTracker(JobConf conf, String identifier)
static JobTracker	JobTracker.startTracker(JobConf conf, String identifier, boolean initialize)
RunningJob	JobClient.submitJob(JobConf job) Submit a job to the MR system.
RunningJob	JobClient.submitJobInternal(JobConf job) Internal method for submitting jobs to the system.
protected boolean	Task.supportIsolationRunner(JobConf conf)
static void	JobLocalizer.writeLocalJobFile(Path jobFile, JobConf conf) Write the task specific job-configuration file.

参数类型为JobConf的org.apache.hadoop.mapred中的构造器

构造器和说明
FileSplit(Path file, long start, long length, JobConf conf) 已过时。
JobClient(JobConf conf) Build a job client with the given JobConf, and connect to the default JobTracker.
JobHistoryServer(JobConf conf) Starts job history server as a independent process * Initializes ACL Manager * Starts a webapp to service history requests
JobHistoryServer(JobConf conf, org.apache.hadoop.mapred.ACLsManager aclsManager, HttpServer httpServer) Starts job history server as a embedded server within job tracker * Starts a webapp to service history requests
JobInProgress(JobID jobid, JobConf conf, JobTracker tracker) Create an almost empty JobInProgress, which can be used only for tests
JobLocalizer(JobConf ttConf, String user, String jobid)
JobLocalizer(JobConf ttConf, String user, String jobid, String... localDirs)
LocalJobRunner(JobConf conf)
MultiFileSplit(JobConf job, Path[] files, long[] lengths) 已过时。
Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls, JobConf conf, Counters.Counter inputCounter, Task.TaskReporter reporter)
TaskTracker(JobConf conf) Start with the local machine name, and the default JobTracker

org.apache.hadoop.mapred.jobcontrol中JobConf的使用

返回JobConf的org.apache.hadoop.mapred.jobcontrol中的方法

限定符和类型	方法和说明
JobConf	Job.getJobConf()

参数类型为JobConf的org.apache.hadoop.mapred.jobcontrol中的方法

限定符和类型	方法和说明
void	Job.setJobConf(JobConf jobConf) Set the mapred job conf for this job.

参数类型为JobConf的org.apache.hadoop.mapred.jobcontrol中的构造器

构造器和说明
Job(JobConf jobConf) Construct a job.
Job(JobConf jobConf, ArrayList<Job> dependingJobs) Construct a job.

org.apache.hadoop.mapred.join中JobConf的使用

参数类型为JobConf的org.apache.hadoop.mapred.join中的方法

限定符和类型	方法和说明
ComposableRecordReader<K,TupleWritable>	CompositeInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) Construct a CompositeRecordReader for the children of this InputFormat as defined in the init expression.
ComposableRecordReader<K,V>	ComposableInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
InputSplit[]	CompositeInputFormat.getSplits(JobConf job, int numSplits) Build a CompositeInputSplit from the child InputFormats by assigning the ith split from each child to the ith composite split.
void	CompositeInputFormat.setFormat(JobConf job) Interpret a given string as a composite expression.

参数类型为JobConf的org.apache.hadoop.mapred.join中的构造器

构造器和说明
JoinRecordReader(int id, JobConf conf, int capacity, Class<? extends WritableComparator> cmpcl)
MultiFilterRecordReader(int id, JobConf conf, int capacity, Class<? extends WritableComparator> cmpcl)

org.apache.hadoop.mapred.lib中JobConf的使用

声明为JobConf的org.apache.hadoop.mapred.lib中的字段

限定符和类型	字段和说明
protected JobConf	CombineFileRecordReader.jc

返回JobConf的org.apache.hadoop.mapred.lib中的方法

限定符和类型	方法和说明
JobConf	CombineFileSplit.getJob()

参数类型为JobConf的org.apache.hadoop.mapred.lib中的方法

限定符和类型	方法和说明
static void	MultipleInputs.addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass) Add a Path with a custom InputFormat to the list of inputs for the map-reduce job.
static void	MultipleInputs.addInputPath(JobConf conf, Path path, Class<? extends InputFormat> inputFormatClass, Class<? extends Mapper> mapperClass) Add a Path with a custom InputFormat and Mapper to the list of inputs for the map-reduce job.
static <K1,V1,K2,V2> void	ChainReducer.addMapper(JobConf job, Class<? extends Mapper<K1,V1,K2,V2>> klass, Class<? extends K1> inputKeyClass, Class<? extends V1> inputValueClass, Class<? extends K2> outputKeyClass, Class<? extends V2> outputValueClass, boolean byValue, JobConf mapperConf) Adds a Mapper class to the chain job's JobConf.
static <K1,V1,K2,V2> void	ChainMapper.addMapper(JobConf job, Class<? extends Mapper<K1,V1,K2,V2>> klass, Class<? extends K1> inputKeyClass, Class<? extends V1> inputValueClass, Class<? extends K2> outputKeyClass, Class<? extends V2> outputValueClass, boolean byValue, JobConf mapperConf) Adds a Mapper class to the chain job's JobConf.
static void	MultipleOutputs.addMultiNamedOutput(JobConf conf, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Class<?> keyClass, Class<?> valueClass) Adds a multi named output for the job.
static void	MultipleOutputs.addNamedOutput(JobConf conf, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Class<?> keyClass, Class<?> valueClass) Adds a named output for the job.
void	NullOutputFormat.checkOutputSpecs(FileSystem ignored, JobConf job)
void	TotalOrderPartitioner.configure(JobConf job) Read in the partition file and build indexing data structures.
void	RegexMapper.configure(JobConf job)
void	NLineInputFormat.configure(JobConf conf)
void	MultithreadedMapRunner.configure(JobConf jobConf)
void	KeyFieldBasedPartitioner.configure(JobConf job)
void	KeyFieldBasedComparator.configure(JobConf job)
void	HashPartitioner.configure(JobConf job)
void	FieldSelectionMapReduce.configure(JobConf job)
void	DelegatingMapper.configure(JobConf conf)
void	ChainReducer.configure(JobConf job) Configures the ChainReducer, the Reducer and all the Mappers in the chain.
void	ChainMapper.configure(JobConf job) Configures the ChainMapper and all the Mappers in the chain.
void	BinaryPartitioner.configure(JobConf job)
protected void	CombineFileInputFormat.createPool(JobConf conf, List<PathFilter> filters) Create a new pool and add the filters to it.
protected void	CombineFileInputFormat.createPool(JobConf conf, PathFilter... filters) Create a new pool and add the filters to it.
protected RecordWriter<K,V>	MultipleTextOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3)
protected RecordWriter<K,V>	MultipleSequenceFileOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3)
protected abstract RecordWriter<K,V>	MultipleOutputFormat.getBaseRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3)
static boolean	MultipleOutputs.getCountersEnabled(JobConf conf) Returns if the counters for the named outputs are enabled or not.
protected String	MultipleOutputFormat.getInputFileBasedOutputFileName(JobConf job, String name) Generate the outfile name based on a given anme and the input file name.
static Class<? extends OutputFormat>	MultipleOutputs.getNamedOutputFormatClass(JobConf conf, String namedOutput) Returns the named output OutputFormat.
static Class<? extends WritableComparable>	MultipleOutputs.getNamedOutputKeyClass(JobConf conf, String namedOutput) Returns the key class for a named output.
static List<String>	MultipleOutputs.getNamedOutputsList(JobConf conf) Returns list of channel names.
static Class<? extends Writable>	MultipleOutputs.getNamedOutputValueClass(JobConf conf, String namedOutput) Returns the value class for a named output.
static String	TotalOrderPartitioner.getPartitionFile(JobConf job) Get the path to the SequenceFile storing the sorted partition keyset.
RecordReader<LongWritable,Text>	NLineInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
RecordReader<K,V>	DelegatingInputFormat.getRecordReader(InputSplit split, JobConf conf, Reporter reporter)
abstract RecordReader<K,V>	CombineFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) This is not implemented yet.
RecordWriter<K,V>	NullOutputFormat.getRecordWriter(FileSystem ignored, JobConf job, String name, Progressable progress)
RecordWriter<K,V>	MultipleOutputFormat.getRecordWriter(FileSystem fs, JobConf job, String name, Progressable arg3) Create a composite record writer that can write key/value data to different output files
K[]	InputSampler.Sampler.getSample(InputFormat<K,V> inf, JobConf job) For a given job, collect and return a subset of the keys from the input data.
K[]	InputSampler.SplitSampler.getSample(InputFormat<K,V> inf, JobConf job) From each split sampled, take the first numSamples / numSplits records.
K[]	InputSampler.RandomSampler.getSample(InputFormat<K,V> inf, JobConf job) Randomize the split order, then take the specified number of keys from each split sampled, where each key is selected with the specified probability and possibly replaced by a subsequently selected key when the quota of keys from that split is satisfied.
K[]	InputSampler.IntervalSampler.getSample(InputFormat<K,V> inf, JobConf job) For each split sampled, emit when the ratio of the number of records retained to the total record count is less than the specified frequency.
InputSplit[]	NLineInputFormat.getSplits(JobConf job, int numSplits) Logically splits the set of input files for the job, splits N lines of the input as one split.
InputSplit[]	DelegatingInputFormat.getSplits(JobConf conf, int numSplits)
InputSplit[]	CombineFileInputFormat.getSplits(JobConf job, int numSplits)
static boolean	MultipleOutputs.isMultiNamedOutput(JobConf conf, String namedOutput) Returns if a named output is multiple.
static void	MultipleOutputs.setCountersEnabled(JobConf conf, boolean enabled) Enables or disables counters for the named outputs.
static void	TotalOrderPartitioner.setPartitionFile(JobConf job, Path p) Set the path to the SequenceFile storing the sorted partition keyset.
static <K1,V1,K2,V2> void	ChainReducer.setReducer(JobConf job, Class<? extends Reducer<K1,V1,K2,V2>> klass, Class<? extends K1> inputKeyClass, Class<? extends V1> inputValueClass, Class<? extends K2> outputKeyClass, Class<? extends V2> outputValueClass, boolean byValue, JobConf reducerConf) Sets the Reducer class to the chain job's JobConf.
static <K,V> void	InputSampler.writePartitionFile(JobConf job, InputSampler.Sampler<K,V> sampler) Write a partition file for the given job, using the Sampler provided.

参数类型为JobConf的org.apache.hadoop.mapred.lib中的构造器

构造器和说明
CombineFileRecordReader(JobConf job, CombineFileSplit split, Reporter reporter, Class<RecordReader<K,V>> rrClass) A generic RecordReader that can hand out different recordReaders for each chunk in the CombineFileSplit.
CombineFileSplit(JobConf job, Path[] files, long[] lengths)
CombineFileSplit(JobConf job, Path[] files, long[] start, long[] lengths, String[] locations)
InputSampler(JobConf conf)
MultipleOutputs(JobConf job) Creates and initializes multiple named outputs support, it should be instantiated in the Mapper/Reducer configure method.

org.apache.hadoop.mapred.lib.aggregate中JobConf的使用

返回JobConf的org.apache.hadoop.mapred.lib.aggregate中的方法

限定符和类型	方法和说明
static JobConf	ValueAggregatorJob.createValueAggregatorJob(String[] args) Create an Aggregate based map/reduce job.
static JobConf	ValueAggregatorJob.createValueAggregatorJob(String[] args, Class<?> caller) Create an Aggregate based map/reduce job.
static JobConf	ValueAggregatorJob.createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors)
static JobConf	ValueAggregatorJob.createValueAggregatorJob(String[] args, Class<? extends ValueAggregatorDescriptor>[] descriptors, Class<?> caller)

参数类型为JobConf的org.apache.hadoop.mapred.lib.aggregate中的方法

限定符和类型	方法和说明
void	ValueAggregatorJobBase.configure(JobConf job)
void	ValueAggregatorDescriptor.configure(JobConf job) Configure the object
void	ValueAggregatorCombiner.configure(JobConf job) Combiner does not need to configure.
void	ValueAggregatorBaseDescriptor.configure(JobConf job) get the input file name.
void	UserDefinedValueAggregatorDescriptor.configure(JobConf job) Do nothing.
static void	ValueAggregatorJob.setAggregatorDescriptors(JobConf job, Class<? extends ValueAggregatorDescriptor>[] descriptors)

参数类型为JobConf的org.apache.hadoop.mapred.lib.aggregate中的构造器

构造器和说明
UserDefinedValueAggregatorDescriptor(String className, JobConf job)

org.apache.hadoop.mapred.lib.db中JobConf的使用

参数类型为JobConf的org.apache.hadoop.mapred.lib.db中的方法

限定符和类型	方法和说明
void	DBOutputFormat.checkOutputSpecs(FileSystem filesystem, JobConf job) Check for validity of the output-specification for the job.
void	DBInputFormat.configure(JobConf job) Initializes a new instance from a JobConf.
static void	DBConfiguration.configureDB(JobConf job, String driverClass, String dbUrl) Sets the DB access related fields in the JobConf.
static void	DBConfiguration.configureDB(JobConf job, String driverClass, String dbUrl, String userName, String passwd) Sets the DB access related fields in the JobConf.
RecordReader<LongWritable,T>	DBInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) Get the RecordReader for the given InputSplit.
RecordWriter<K,V>	DBOutputFormat.getRecordWriter(FileSystem filesystem, JobConf job, String name, Progressable progress) Get the RecordWriter for the given job.
InputSplit[]	DBInputFormat.getSplits(JobConf job, int chunks) Logically split the set of input files for the job.
static void	DBInputFormat.setInput(JobConf job, Class<? extends DBWritable> inputClass, String inputQuery, String inputCountQuery) Initializes the map-part of the job with the appropriate input settings.
static void	DBInputFormat.setInput(JobConf job, Class<? extends DBWritable> inputClass, String tableName, String conditions, String orderBy, String... fieldNames) Initializes the map-part of the job with the appropriate input settings.
static void	DBOutputFormat.setOutput(JobConf job, String tableName, String... fieldNames) Initializes the reduce-part of the job with the appropriate output settings

参数类型为JobConf的org.apache.hadoop.mapred.lib.db中的构造器

构造器和说明
DBInputFormat.DBRecordReader(DBInputFormat.DBInputSplit split, Class<T> inputClass, JobConf job)

org.apache.hadoop.mapred.pipes中JobConf的使用

参数类型为JobConf的org.apache.hadoop.mapred.pipes中的方法

限定符和类型	方法和说明
static String	Submitter.getExecutable(JobConf conf) Get the URI of the application's executable.
static boolean	Submitter.getIsJavaMapper(JobConf conf) Check whether the job is using a Java Mapper.
static boolean	Submitter.getIsJavaRecordReader(JobConf conf) Check whether the job is using a Java RecordReader
static boolean	Submitter.getIsJavaRecordWriter(JobConf conf) Will the reduce use a Java RecordWriter?
static boolean	Submitter.getIsJavaReducer(JobConf conf) Check whether the job is using a Java Reducer.
static boolean	Submitter.getKeepCommandFile(JobConf conf) Does the user want to keep the command file for debugging?
static RunningJob	Submitter.jobSubmit(JobConf conf) Submit a job to the Map-Reduce framework.
static RunningJob	Submitter.runJob(JobConf conf) Submit a job to the map/reduce cluster.
static void	Submitter.setExecutable(JobConf conf, String executable) Set the URI for the application's executable.
static void	Submitter.setIsJavaMapper(JobConf conf, boolean value) Set whether the Mapper is written in Java.
static void	Submitter.setIsJavaRecordReader(JobConf conf, boolean value) Set whether the job is using a Java RecordReader.
static void	Submitter.setIsJavaRecordWriter(JobConf conf, boolean value) Set whether the job will use a Java RecordWriter.
static void	Submitter.setIsJavaReducer(JobConf conf, boolean value) Set whether the Reducer is written in Java.
static void	Submitter.setKeepCommandFile(JobConf conf, boolean keep) Set whether to keep the command file for debugging
static RunningJob	Submitter.submitJob(JobConf conf) 已过时。 Use Submitter.runJob(JobConf)

org.apache.hadoop.mapreduce中JobConf的使用

声明为JobConf的org.apache.hadoop.mapreduce中的字段

限定符和类型	字段和说明
protected JobConf	JobContext.conf

org.apache.hadoop.streaming中JobConf的使用

声明为JobConf的org.apache.hadoop.streaming中的字段

限定符和类型	字段和说明
protected JobConf	StreamJob.jobConf_

返回JobConf的org.apache.hadoop.streaming中的方法

限定符和类型	方法和说明
static JobConf	StreamJob.createJob(String[] argv) This method creates a streaming job from the given argument list.

参数类型为JobConf的org.apache.hadoop.streaming中的方法

限定符和类型	方法和说明
void	PipeReducer.configure(JobConf job)
void	PipeMapRed.configure(JobConf job)
void	PipeMapper.configure(JobConf job)
void	AutoInputFormat.configure(JobConf job)
static FileSplit	StreamUtil.getCurrentSplit(JobConf job)
RecordReader<Text,Text>	StreamInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
RecordReader	AutoInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
static org.apache.hadoop.streaming.StreamUtil.TaskId	StreamUtil.getTaskInfo(JobConf job)
static boolean	StreamUtil.isLocalJobTracker(JobConf job)

参数类型为JobConf的org.apache.hadoop.streaming中的构造器

构造器和说明
StreamBaseRecordReader(FSDataInputStream in, FileSplit split, Reporter reporter, JobConf job, FileSystem fs)
StreamXmlRecordReader(FSDataInputStream in, FileSplit split, Reporter reporter, JobConf job, FileSystem fs)

org.apache.hadoop.tools中JobConf的使用

参数类型为JobConf的org.apache.hadoop.tools中的方法

限定符和类型	方法和说明
void	Logalyzer.LogRegexMapper.configure(JobConf job)

org.apache.hadoop.tools.rumen中JobConf的使用

返回JobConf的org.apache.hadoop.tools.rumen中的方法

限定符和类型	方法和说明
JobConf	ZombieJob.getJobConf()
JobConf	JobStory.getJobConf() Get the JobConf for the job.