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

使用TaskAttemptID的程序包

程序包	说明
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.tools.rumen	Rumen is a data extraction and analysis tool built for Apache Hadoop.

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

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

限定符和类型	类和说明
class	TaskAttemptID TaskAttemptID represents the immutable and unique identifier for a task attempt.

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

限定符和类型	方法和说明
protected static <INKEY,INVALUE,OUTKEY,OUTVALUE> Reducer.Context	Task.createReduceContext(Reducer<INKEY,INVALUE,OUTKEY,OUTVALUE> reducer, Configuration job, TaskAttemptID taskId, RawKeyValueIterator rIter, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<OUTKEY,OUTVALUE> output, OutputCommitter committer, StatusReporter reporter, RawComparator<INKEY> comparator, Class<INKEY> keyClass, Class<INVALUE> valueClass)
static TaskAttemptID	TaskAttemptID.downgrade(TaskAttemptID old) Downgrade a new TaskAttemptID to an old one

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

返回TaskAttemptID的org.apache.hadoop.mapreduce中的方法

限定符和类型	方法和说明
static TaskAttemptID	TaskAttemptID.forName(String str) Construct a TaskAttemptID object from given string
TaskAttemptID	TaskAttemptContext.getTaskAttemptID() Get the unique name for this task attempt.

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

限定符和类型	方法和说明
void	Job.failTask(TaskAttemptID taskId) Fail indicated task attempt.
void	Job.killTask(TaskAttemptID taskId) Kill indicated task attempt.

参数类型为TaskAttemptID的org.apache.hadoop.mapreduce中的构造器

构造器和说明
MapContext(Configuration conf, TaskAttemptID taskid, RecordReader<KEYIN,VALUEIN> reader, RecordWriter<KEYOUT,VALUEOUT> writer, OutputCommitter committer, StatusReporter reporter, InputSplit split)
Mapper.Context(Configuration conf, TaskAttemptID taskid, RecordReader<KEYIN,VALUEIN> reader, RecordWriter<KEYOUT,VALUEOUT> writer, OutputCommitter committer, StatusReporter reporter, InputSplit split)
ReduceContext(Configuration conf, TaskAttemptID taskid, RawKeyValueIterator input, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter, RawComparator<KEYIN> comparator, Class<KEYIN> keyClass, Class<VALUEIN> valueClass)
Reducer.Context(Configuration conf, TaskAttemptID taskid, RawKeyValueIterator input, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter, RawComparator<KEYIN> comparator, Class<KEYIN> keyClass, Class<VALUEIN> valueClass)
TaskAttemptContext(Configuration conf, TaskAttemptID taskId)
TaskInputOutputContext(Configuration conf, TaskAttemptID taskid, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter)

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

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

限定符和类型	方法和说明
TaskAttemptID	TaskAttemptFinishedEvent.getAttemptId() Get the task attempt id
TaskAttemptID	ReduceAttemptFinishedEvent.getAttemptId() Get the attempt id
TaskAttemptID	MapAttemptFinishedEvent.getAttemptId() Get the attempt id
TaskAttemptID	TaskFailedEvent.getFailedAttemptID() Get the attempt id due to which the task failed
TaskAttemptID	TaskAttemptUnsuccessfulCompletionEvent.getTaskAttemptId() Get the attempt id
TaskAttemptID	TaskAttemptStartedEvent.getTaskAttemptId() Get the attempt id

参数类型为TaskAttemptID的org.apache.hadoop.tools.rumen中的构造器

构造器和说明
MapAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long mapFinishTime, long finishTime, String hostname, String state, Counters counters) Create an event for successful completion of map attempts
ReduceAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long shuffleFinishTime, long sortFinishTime, long finishTime, String hostname, String state, Counters counters) Create an event to record completion of a reduce attempt
TaskAttemptFinishedEvent(TaskAttemptID id, TaskType taskType, String taskStatus, long finishTime, String hostname, String state, Counters counters) Create an event to record successful finishes for setup and cleanup attempts
TaskAttemptStartedEvent(TaskAttemptID attemptId, TaskType taskType, long startTime, String trackerName, int httpPort, String locality, String avataar) Create an event to record the start of an attempt
TaskAttemptUnsuccessfulCompletionEvent(TaskAttemptID id, TaskType taskType, String status, long finishTime, String hostname, String error) Create an event to record the unsuccessful completion of attempts
TaskFailedEvent(TaskID id, long finishTime, TaskType taskType, String error, String status, TaskAttemptID failedDueToAttempt) Create an event to record task failure