|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobContext | |
---|---|
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.mapreduce | |
org.apache.hadoop.mapreduce.lib.input | |
org.apache.hadoop.mapreduce.lib.map | |
org.apache.hadoop.mapreduce.lib.output |
Uses of JobContext in org.apache.hadoop.mapred |
---|
Subclasses of JobContext in org.apache.hadoop.mapred | |
---|---|
class |
JobContext
Deprecated. Use JobContext instead. |
Methods in org.apache.hadoop.mapred with parameters of type JobContext | |
---|---|
void |
OutputCommitter.cleanupJob(JobContext context)
Deprecated. This method implements the new interface by calling the old method. |
void |
OutputCommitter.setupJob(JobContext jobContext)
Deprecated. This method implements the new interface by calling the old method. |
Uses of JobContext in org.apache.hadoop.mapreduce |
---|
Subclasses of JobContext in org.apache.hadoop.mapreduce | |
---|---|
class |
Job
The job submitter's view of the Job. |
class |
MapContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
The context that is given to the Mapper . |
class |
Mapper.Context
|
class |
ReduceContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
The context passed to the Reducer . |
class |
Reducer.Context
|
class |
TaskAttemptContext
The context for task attempts. |
class |
TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
A context object that allows input and output from the task. |
Methods in org.apache.hadoop.mapreduce with parameters of type JobContext | |
---|---|
abstract void |
OutputFormat.checkOutputSpecs(JobContext context)
Check for validity of the output-specification for the job. |
abstract void |
OutputCommitter.cleanupJob(JobContext jobContext)
For cleaning up the job's output after job completion |
abstract List<InputSplit> |
InputFormat.getSplits(JobContext context)
Logically split the set of input files for the job. |
abstract void |
OutputCommitter.setupJob(JobContext jobContext)
For the framework to setup the job output during initialization |
Uses of JobContext in org.apache.hadoop.mapreduce.lib.input |
---|
Methods in org.apache.hadoop.mapreduce.lib.input with parameters of type JobContext | |
---|---|
static PathFilter |
FileInputFormat.getInputPathFilter(JobContext context)
Get a PathFilter instance of the filter set for the input paths. |
static Path[] |
FileInputFormat.getInputPaths(JobContext context)
Get the list of input Path s for the map-reduce job. |
static long |
FileInputFormat.getMaxSplitSize(JobContext context)
Get the maximum split size. |
static long |
FileInputFormat.getMinSplitSize(JobContext job)
Get the minimum split size |
List<InputSplit> |
FileInputFormat.getSplits(JobContext job)
Generate the list of files and make them into FileSplits. |
protected boolean |
TextInputFormat.isSplitable(JobContext context,
Path file)
|
protected boolean |
FileInputFormat.isSplitable(JobContext context,
Path filename)
Is the given filename splitable? Usually, true, but if the file is stream compressed, it will not be. |
protected List<FileStatus> |
SequenceFileInputFormat.listStatus(JobContext job)
|
protected List<FileStatus> |
FileInputFormat.listStatus(JobContext job)
List input directories. |
Uses of JobContext in org.apache.hadoop.mapreduce.lib.map |
---|
Methods in org.apache.hadoop.mapreduce.lib.map with parameters of type JobContext | ||
---|---|---|
static
|
MultithreadedMapper.getMapperClass(JobContext job)
Get the application's mapper class. |
|
static int |
MultithreadedMapper.getNumberOfThreads(JobContext job)
The number of threads in the thread pool that will run the map function. |
Uses of JobContext in org.apache.hadoop.mapreduce.lib.output |
---|
Methods in org.apache.hadoop.mapreduce.lib.output with parameters of type JobContext | |
---|---|
void |
NullOutputFormat.checkOutputSpecs(JobContext context)
|
void |
FileOutputFormat.checkOutputSpecs(JobContext job)
|
void |
FileOutputCommitter.cleanupJob(JobContext context)
Delete the temporary directory, including all of the work directories. |
static boolean |
FileOutputFormat.getCompressOutput(JobContext job)
Is the job output compressed? |
static SequenceFile.CompressionType |
SequenceFileOutputFormat.getOutputCompressionType(JobContext job)
Get the SequenceFile.CompressionType for the output SequenceFile . |
static Class<? extends CompressionCodec> |
FileOutputFormat.getOutputCompressorClass(JobContext job,
Class<? extends CompressionCodec> defaultValue)
Get the CompressionCodec for compressing the job outputs. |
static Path |
FileOutputFormat.getOutputPath(JobContext job)
Get the Path to the output directory for the map-reduce job. |
void |
FileOutputCommitter.setupJob(JobContext context)
Create the temporary directory that is the root of all of the task work directories. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |