Uses of Class
org.apache.hadoop.mapred.TaskAttemptID

Packages that use 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.

Uses of TaskAttemptID in org.apache.hadoop.mapred

Methods in org.apache.hadoop.mapred that return TaskAttemptID

static TaskAttemptID	TaskAttemptID.forName(String str) Construct a TaskAttemptID object from given string
TaskAttemptID	TaskCompletionEvent.getTaskAttemptId() Returns task id.
static TaskAttemptID	TaskAttemptID.read(DataInput in)

Methods in org.apache.hadoop.mapred with parameters of type TaskAttemptID

void	TaskTracker.done(TaskAttemptID taskid, boolean shouldPromote) The task is done.
void	TaskTracker.fsError(TaskAttemptID taskId, String message) A child task had a local filesystem error.
String	JobTracker.getAssignedTracker(TaskAttemptID taskId) Get tracker name for a given task id.
org.apache.hadoop.mapred.Task	TaskTracker.getTask(TaskAttemptID taskid) Called upon startup by the child process, to fetch Task data.
String[]	JobTracker.getTaskDiagnostics(TaskAttemptID taskId) Get the diagnostics for a given task
static File	TaskLog.getTaskLogFile(TaskAttemptID taskid, TaskLog.LogName filter)
void	RunningJob.killTask(TaskAttemptID taskId, boolean shouldFail) Kill indicated task attempt.
boolean	JobTracker.killTask(TaskAttemptID taskid, boolean shouldFail) Mark a Task to be killed
static void	JobHistory.MapAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) Log task attempt failed event.
static void	JobHistory.ReduceAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) Log failed reduce task attempt.
static void	JobHistory.ReduceAttempt.logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName) Log finished event of this task.
static void	JobHistory.MapAttempt.logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName) Log finish time of map task attempt.
static void	JobHistory.MapAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) Log task attempt killed event.
static void	JobHistory.ReduceAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) Log killed reduce task attempt.
static void	JobHistory.MapAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName) Log start time of this map task attempt.
static void	JobHistory.ReduceAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName) Log start time of Reduce task attempt.
void	TaskTracker.mapOutputLost(TaskAttemptID taskid, String errorMsg) A completed map task's output has been lost.
boolean	TaskTracker.ping(TaskAttemptID taskid) Child checking to see if we're alive.
void	TaskTracker.reportDiagnosticInfo(TaskAttemptID taskid, String info) Called when the task dies before completion, and we want to report back diagnostic info
void	TaskCompletionEvent.setTaskID(TaskAttemptID taskId) Sets task id.
void	TaskTracker.shuffleError(TaskAttemptID taskId, String message) A reduce-task failed to shuffle the map-outputs.
boolean	TaskTracker.statusUpdate(TaskAttemptID taskid, org.apache.hadoop.mapred.TaskStatus taskStatus) Called periodically to report Task progress, from 0.0 to 1.0.

Constructors in org.apache.hadoop.mapred with parameters of type TaskAttemptID

TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, String taskTrackerHttp)
Constructor.