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.downgrade(TaskAttemptID old)
          Deprecated. Downgrade a new TaskAttemptID to an old one
static TaskAttemptID TaskAttemptID.forName(String str)
          Deprecated. Construct a TaskAttemptID object from given string
 TaskAttemptID TaskReport.getSuccessfulTaskAttempt()
          Get the attempt ID that took this task to completion
 TaskAttemptID TaskCompletionEvent.getTaskAttemptId()
          Returns task id.
 TaskAttemptID TaskAttemptContext.getTaskAttemptID()
          Deprecated. Get the taskAttemptID.
 TaskAttemptID Task.getTaskID()
           
 TaskAttemptID TaskStatus.getTaskID()
           
static TaskAttemptID TaskAttemptID.read(DataInput in)
          Deprecated. 
 

Methods in org.apache.hadoop.mapred that return types with arguments of type TaskAttemptID
 List<TaskAttemptID> TaskStatus.getFetchFailedMaps()
          Get the list of maps from which output-fetches failed.
 Collection<TaskAttemptID> TaskReport.getRunningTaskAttempts()
          Get the running task attempt IDs for this task
 

Methods in org.apache.hadoop.mapred with parameters of type TaskAttemptID
 void TaskInProgress.addDiagnosticInfo(TaskAttemptID taskId, String diagInfo)
          Save diagnostic information for a given task.
 Task TaskInProgress.addRunningTask(TaskAttemptID taskid, String taskTracker)
           
 Task TaskInProgress.addRunningTask(TaskAttemptID taskid, String taskTracker, boolean taskCleanup)
          Adds a previously running task to this tip.
 boolean TaskTracker.canCommit(TaskAttemptID taskid)
          Child checking whether it can commit
 boolean TaskUmbilicalProtocol.canCommit(TaskAttemptID taskid)
          Polling to know whether the task can go-ahead with commit
 void TaskTracker.commitPending(TaskAttemptID taskid, TaskStatus taskStatus)
          Task is reporting that it is in commit_pending and it is waiting for the commit Response
 void TaskUmbilicalProtocol.commitPending(TaskAttemptID taskId, TaskStatus taskStatus)
          Report that the task is complete, but its commit is pending.
 void TaskInProgress.completed(TaskAttemptID taskid)
          Indicate that one of the taskids in this TaskInProgress has successfully completed!
 void TaskInProgress.doCommit(TaskAttemptID taskid)
          Commit this task attempt for the tip.
 void TaskTracker.done(TaskAttemptID taskid)
          The task is done.
 void TaskUmbilicalProtocol.done(TaskAttemptID taskid)
          Report that the task is successfully completed.
 void JobInProgress.failedTask(TaskInProgress tip, TaskAttemptID taskid, String reason, TaskStatus.Phase phase, TaskStatus.State state, String trackerName)
          Fail a task with a given reason, but without a status object.
 void TaskTracker.fatalError(TaskAttemptID taskId, String msg)
          A child task had a fatal error.
 void TaskUmbilicalProtocol.fatalError(TaskAttemptID taskId, String message)
          Report that the task encounted a fatal error.
 void TaskTracker.fsError(TaskAttemptID taskId, String message)
          A child task had a local filesystem error.
 void TaskUmbilicalProtocol.fsError(TaskAttemptID taskId, String message)
          Report that the task encounted a local filesystem error.
 String JobTracker.getAssignedTracker(TaskAttemptID taskId)
          Get tracker name for a given task id.
 List<String> TaskInProgress.getDiagnosticInfo(TaskAttemptID taskId)
          Get the diagnostic messages for a given task within this tip.
 MapTaskCompletionEventsUpdate TaskTracker.getMapCompletionEvents(JobID jobId, int fromEventId, int maxLocs, TaskAttemptID id)
           
 MapTaskCompletionEventsUpdate TaskUmbilicalProtocol.getMapCompletionEvents(JobID jobId, int fromIndex, int maxLocs, TaskAttemptID id)
          Called by a reduce task to get the map output locations for finished maps.
 String[] RunningJob.getTaskDiagnostics(TaskAttemptID taskid)
          Gets the diagnostic messages for a given task attempt.
 String[] JobTracker.getTaskDiagnostics(TaskAttemptID taskId)
          Get the diagnostics for a given task
static File TaskLog.getTaskLogFile(TaskAttemptID taskid, boolean isCleanup, TaskLog.LogName filter)
           
 TaskStatus TaskInProgress.getTaskStatus(TaskAttemptID taskid)
          Get the status of the specified task
 void TaskInProgress.incompleteSubTask(TaskAttemptID taskid, JobStatus jobStatus)
          Indicate that one of the taskids in this TaskInProgress has failed.
 boolean TaskInProgress.isCommitPending(TaskAttemptID taskId)
           
 boolean TaskInProgress.isComplete(TaskAttemptID taskid)
          Is the given taskid the one that took this tip to completion?
 boolean TaskInProgress.isFirstAttempt(TaskAttemptID taskId)
          Is the Task associated with taskid is the first attempt of the tip?
 void RunningJob.killTask(TaskAttemptID taskId, boolean shouldFail)
          Kill indicated task attempt.
 boolean JobTracker.killTask(TaskAttemptID taskid, boolean shouldFail)
           
static void JobHistory.MapAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
          Deprecated. Use JobHistory.MapAttempt.logFailed(TaskAttemptID, long, String, String, String)
static void JobHistory.ReduceAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
          Deprecated. Use JobHistory.ReduceAttempt.logFailed(TaskAttemptID, long, String, String, String)
static void JobHistory.MapAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
          Log task attempt failed event.
static void JobHistory.ReduceAttempt.logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
          Log failed reduce task attempt.
static void JobHistory.Task.logFailed(TaskID taskId, String taskType, long time, String error, TaskAttemptID failedDueToAttempt)
           
static void JobHistory.ReduceAttempt.logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName)
          Deprecated. Use JobHistory.ReduceAttempt.logFinished(TaskAttemptID, long, long, long, String, String, String, Counters)
static void JobHistory.ReduceAttempt.logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName, String taskType, String stateString, Counters counter)
          Log finished event of this task.
static void JobHistory.MapAttempt.logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName)
          Deprecated. Use JobHistory.MapAttempt.logFinished(TaskAttemptID, long, String, String, String, Counters)
static void JobHistory.MapAttempt.logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName, String taskType, String stateString, Counters counter)
          Log finish time of map task attempt.
static void JobHistory.MapAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
          Deprecated. Use JobHistory.MapAttempt.logKilled(TaskAttemptID, long, String, String, String)
static void JobHistory.ReduceAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
          Deprecated. Use JobHistory.ReduceAttempt.logKilled(TaskAttemptID, long, String, String, String)
static void JobHistory.MapAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
          Log task attempt killed event.
static void JobHistory.ReduceAttempt.logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
          Log killed reduce task attempt.
static void JobHistory.MapAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName)
          Deprecated. Use JobHistory.MapAttempt.logStarted(TaskAttemptID, long, String, int, String)
static void JobHistory.ReduceAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName)
          Deprecated. Use JobHistory.ReduceAttempt.logStarted(TaskAttemptID, long, String, int, String)
static void JobHistory.MapAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType)
          Log start time of this map task attempt.
static void JobHistory.ReduceAttempt.logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType)
          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.
 boolean TaskUmbilicalProtocol.ping(TaskAttemptID taskid)
          Periodically called by child to check if parent is still alive.
 void TaskTracker.reportDiagnosticInfo(TaskAttemptID taskid, String info)
          Called when the task dies before completion, and we want to report back diagnostic info
 void TaskUmbilicalProtocol.reportDiagnosticInfo(TaskAttemptID taskid, String trace)
          Report error messages back to parent.
protected  void Task.reportFatalError(TaskAttemptID id, Throwable throwable, String logMsg)
          Report a fatal error to the parent (task) tracker.
 void TaskTracker.reportNextRecordRange(TaskAttemptID taskid, org.apache.hadoop.mapred.SortedRanges.Range range)
           
 void TaskUmbilicalProtocol.reportNextRecordRange(TaskAttemptID taskid, org.apache.hadoop.mapred.SortedRanges.Range range)
          Report the record range which is going to process next by the Task.
 void TaskReport.setSuccessfulAttempt(TaskAttemptID t)
          set successful attempt ID of the task.
 void TaskCompletionEvent.setTaskID(TaskAttemptID taskId)
          Sets task id.
 boolean TaskInProgress.shouldClose(TaskAttemptID taskid)
          Returns whether a component task-thread should be closed because the containing JobInProgress has completed or the task is killed by the user
 boolean TaskInProgress.shouldCommit(TaskAttemptID taskid)
          Returns whether the task attempt should be committed or not
 void TaskTracker.shuffleError(TaskAttemptID taskId, String message)
          A reduce-task failed to shuffle the map-outputs.
 void TaskUmbilicalProtocol.shuffleError(TaskAttemptID taskId, String message)
          Report that a reduce-task couldn't shuffle map-outputs.
 boolean TaskTracker.statusUpdate(TaskAttemptID taskid, TaskStatus taskStatus)
          Called periodically to report Task progress, from 0.0 to 1.0.
 boolean TaskUmbilicalProtocol.statusUpdate(TaskAttemptID taskId, TaskStatus taskStatus)
          Report child's progress to parent.
static void TaskLog.syncLogs(String logLocation, TaskAttemptID taskid, boolean isCleanup)
           
 

Method parameters in org.apache.hadoop.mapred with type arguments of type TaskAttemptID
 void TaskReport.setRunningTaskAttempts(Collection<TaskAttemptID> runningAttempts)
          set running attempt(s) of the task.
 

Constructors in org.apache.hadoop.mapred with parameters of type TaskAttemptID
Task(String jobFile, TaskAttemptID taskId, int partition, int numSlotsRequired)
           
TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, String taskTrackerHttp)
          Constructor.
TaskStatus(TaskAttemptID taskid, float progress, int numSlots, TaskStatus.State runState, String diagnosticInfo, String stateString, String taskTracker, TaskStatus.Phase phase, Counters counters)
           
 



Copyright © 2009 The Apache Software Foundation