类 org.apache.hadoop.mapreduce.TaskAttemptContext
的使用

使用TaskAttemptContext的程序包

程序包	说明
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.db
org.apache.hadoop.mapreduce.lib.input
org.apache.hadoop.mapreduce.lib.output
org.apache.hadoop.tools.distcp2.mapred
org.apache.hadoop.tools.distcp2.mapred.lib

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

org.apache.hadoop.mapred中TaskAttemptContext的子类

限定符和类型	类和说明
class	TaskAttemptContext

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

限定符和类型	方法和说明
void	OutputCommitter.abortTask(TaskAttemptContext taskContext) This method implements the new interface by calling the old method.
void	OutputCommitter.commitTask(TaskAttemptContext taskContext) This method implements the new interface by calling the old method.
boolean	OutputCommitter.needsTaskCommit(TaskAttemptContext taskContext) This method implements the new interface by calling the old method.
void	OutputCommitter.setupTask(TaskAttemptContext taskContext) This method implements the new interface by calling the old method.

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

org.apache.hadoop.mapreduce中TaskAttemptContext的子类

限定符和类型	类和说明
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	TaskInputOutputContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> A context object that allows input and output from the task.

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce中的方法

限定符和类型	方法和说明
abstract void	OutputCommitter.abortTask(TaskAttemptContext taskContext) Discard the task output
abstract void	RecordWriter.close(TaskAttemptContext context) Close this RecordWriter to future operations.
abstract void	OutputCommitter.commitTask(TaskAttemptContext taskContext) To promote the task's temporary output to final output location The task's output is moved to the job's output directory.
abstract RecordReader<K,V>	InputFormat.createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for a given split.
abstract OutputCommitter	OutputFormat.getOutputCommitter(TaskAttemptContext context) Get the output committer for this output format.
abstract RecordWriter<K,V>	OutputFormat.getRecordWriter(TaskAttemptContext context) Get the RecordWriter for the given task.
abstract void	RecordReader.initialize(InputSplit split, TaskAttemptContext context) Called once at initialization.
abstract boolean	OutputCommitter.needsTaskCommit(TaskAttemptContext taskContext) Check whether task needs a commit
abstract void	OutputCommitter.setupTask(TaskAttemptContext taskContext) Sets up output for the task.

org.apache.hadoop.mapreduce.lib.db中TaskAttemptContext的使用

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.db中的方法

限定符和类型	方法和说明
void	DBOutputFormat.DBRecordWriter.close(TaskAttemptContext context) Close this RecordWriter to future operations.
RecordReader<LongWritable,T>	DBInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for a given split.
OutputCommitter	DBOutputFormat.getOutputCommitter(TaskAttemptContext context)
RecordWriter<K,V>	DBOutputFormat.getRecordWriter(TaskAttemptContext context) Get the RecordWriter for the given task.
void	DBRecordReader.initialize(InputSplit split, TaskAttemptContext context)

org.apache.hadoop.mapreduce.lib.input中TaskAttemptContext的使用

声明为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.input中的字段

限定符和类型	字段和说明
protected TaskAttemptContext	CombineFileRecordReader.context

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.input中的方法

限定符和类型	方法和说明
RecordReader<LongWritable,Text>	TextInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)
RecordReader<K,V>	SequenceFileInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)
RecordReader<K,V>	SequenceFileInputFilter.createRecordReader(InputSplit split, TaskAttemptContext context) Create a record reader for the given split
RecordReader<Text,Text>	SequenceFileAsTextInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)
RecordReader<BytesWritable,BytesWritable>	SequenceFileAsBinaryInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)
RecordReader<LongWritable,Text>	NLineInputFormat.createRecordReader(InputSplit genericSplit, TaskAttemptContext context)
RecordReader<Text,Text>	KeyValueTextInputFormat.createRecordReader(InputSplit genericSplit, TaskAttemptContext context)
RecordReader<K,V>	DelegatingInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)
abstract RecordReader<K,V>	CombineFileInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context) This is not implemented yet.
void	SequenceFileRecordReader.initialize(InputSplit split, TaskAttemptContext context)
void	SequenceFileAsTextRecordReader.initialize(InputSplit split, TaskAttemptContext context)
void	SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader.initialize(InputSplit split, TaskAttemptContext context)
void	LineRecordReader.initialize(InputSplit genericSplit, TaskAttemptContext context)
void	KeyValueLineRecordReader.initialize(InputSplit genericSplit, TaskAttemptContext context)
void	DelegatingRecordReader.initialize(InputSplit split, TaskAttemptContext context)
void	CombineFileRecordReader.initialize(InputSplit split, TaskAttemptContext context)

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.input中的构造器

构造器和说明
CombineFileRecordReader(CombineFileSplit split, TaskAttemptContext context, Class<? extends RecordReader<K,V>> rrClass) A generic RecordReader that can hand out different recordReaders for each chunk in the CombineFileSplit.
DelegatingRecordReader(InputSplit split, TaskAttemptContext context) Constructs the DelegatingRecordReader.

org.apache.hadoop.mapreduce.lib.output中TaskAttemptContext的使用

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.output中的方法

限定符和类型	方法和说明
void	FileOutputCommitter.abortTask(TaskAttemptContext context) Delete the work directory
void	TextOutputFormat.LineRecordWriter.close(TaskAttemptContext context)
void	FilterOutputFormat.FilterRecordWriter.close(TaskAttemptContext context)
void	FileOutputCommitter.commitTask(TaskAttemptContext context) Move the files from the work directory to the job output directory
Path	FileOutputFormat.getDefaultWorkFile(TaskAttemptContext context, String extension) Get the default path and filename for the output format.
OutputCommitter	NullOutputFormat.getOutputCommitter(TaskAttemptContext context)
OutputCommitter	LazyOutputFormat.getOutputCommitter(TaskAttemptContext context)
OutputCommitter	FilterOutputFormat.getOutputCommitter(TaskAttemptContext context)
OutputCommitter	FileOutputFormat.getOutputCommitter(TaskAttemptContext context)
RecordWriter<K,V>	TextOutputFormat.getRecordWriter(TaskAttemptContext job)
RecordWriter<K,V>	SequenceFileOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<BytesWritable,BytesWritable>	SequenceFileAsBinaryOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	NullOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	LazyOutputFormat.getRecordWriter(TaskAttemptContext context)
RecordWriter<K,V>	FilterOutputFormat.getRecordWriter(TaskAttemptContext context)
abstract RecordWriter<K,V>	FileOutputFormat.getRecordWriter(TaskAttemptContext job)
protected SequenceFile.Writer	SequenceFileAsBinaryOutputFormat.getSequenceWriter(TaskAttemptContext context, Class<?> keyClass, Class<?> valueClass)
static String	FileOutputFormat.getUniqueFile(TaskAttemptContext context, String name, String extension) Generate a unique filename, based on the task id, name, and extension
boolean	FileOutputCommitter.needsTaskCommit(TaskAttemptContext context) Did this task write any files in the work directory?
void	FileOutputCommitter.setupTask(TaskAttemptContext context) No task setup required.

参数类型为TaskAttemptContext的org.apache.hadoop.mapreduce.lib.output中的构造器

构造器和说明
FileOutputCommitter(Path outputPath, TaskAttemptContext context) Create a file output committer

org.apache.hadoop.tools.distcp2.mapred中TaskAttemptContext的使用

参数类型为TaskAttemptContext的org.apache.hadoop.tools.distcp2.mapred中的方法

限定符和类型	方法和说明
RecordReader<Text,FileStatus>	UniformSizeInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context) Implementation of InputFormat::createRecordReader().
OutputCommitter	CopyOutputFormat.getOutputCommitter(TaskAttemptContext context)

参数类型为TaskAttemptContext的org.apache.hadoop.tools.distcp2.mapred中的构造器

构造器和说明
CopyCommitter(Path outputPath, TaskAttemptContext context) Create a output committer

org.apache.hadoop.tools.distcp2.mapred.lib中TaskAttemptContext的使用

参数类型为TaskAttemptContext的org.apache.hadoop.tools.distcp2.mapred.lib中的方法

限定符和类型	方法和说明
RecordReader<K,V>	DynamicInputFormat.createRecordReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) Implementation of Inputformat::createRecordReader().
void	DynamicRecordReader.initialize(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) Implementation for RecordReader::initialize().