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

Packages that use TaskInProgress
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 TaskInProgress in org.apache.hadoop.mapred
 

Methods in org.apache.hadoop.mapred that return TaskInProgress
protected  TaskInProgress JobInProgress.findSpeculativeTask(Collection<TaskInProgress> list, TaskTrackerStatus ttStatus, double avgProgress, long currentTime, boolean shouldRemove)
          Find a speculative task
 TaskInProgress JobInProgress.getTaskInProgress(TaskID tipid)
          Return the TaskInProgress that matches the tipid.
 TaskInProgress JobTracker.getTip(TaskID tipid)
          Returns specified TaskInProgress, or null.
 

Methods in org.apache.hadoop.mapred that return types with arguments of type TaskInProgress
 Vector<TaskInProgress> JobInProgress.reportCleanupTIPs(boolean shouldBeComplete)
          Return a vector of cleanup TaskInProgress objects
 Vector<TaskInProgress> JobInProgress.reportSetupTIPs(boolean shouldBeComplete)
          Return a vector of setup TaskInProgress objects
 Vector<TaskInProgress> JobInProgress.reportTasksInProgress(boolean shouldBeMap, boolean shouldBeComplete)
          Return a vector of completed TaskInProgress objects
 

Methods in org.apache.hadoop.mapred with parameters of type TaskInProgress
 boolean JobInProgress.completedTask(TaskInProgress tip, TaskStatus status)
          A taskid assigned to this JobInProgress has reported in successfully.
 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.
protected  void JobInProgress.scheduleMap(TaskInProgress tip)
          Adds a map tip to the list of running maps.
protected  void JobInProgress.scheduleReduce(TaskInProgress tip)
          Adds a reduce tip to the list of running reduces
 void JobInProgress.updateTaskStatus(TaskInProgress tip, TaskStatus status)
          Assuming JobTracker is locked on entry.
 

Method parameters in org.apache.hadoop.mapred with type arguments of type TaskInProgress
protected  TaskInProgress JobInProgress.findSpeculativeTask(Collection<TaskInProgress> list, TaskTrackerStatus ttStatus, double avgProgress, long currentTime, boolean shouldRemove)
          Find a speculative task
 



Copyright © 2009 The Apache Software Foundation