cgl.imr.monitor
Class JobStatus

java.lang.Object
  extended by cgl.imr.monitor.JobStatus

public class JobStatus
extends Object

Presents the state of the job to the user. Keeps track of successful/failed tasks.


Constructor Summary
JobStatus(JobConf jobConf)
           
 
Method Summary
 void addMapTaskStatus(TaskStatus mapStatus)
           
 void addReduceTaskStatus(TaskStatus reduceStatus)
           
 float getCurrentMapPercentage()
           
 float getCurrentReducePercentage()
           
 Map<Integer,TaskStatus> getMapTaskStatuses()
           
 TaskStatus getMapTaskStatuses(int mapTaskNumber)
           
 int getNumCombineInputsReceived()
           
 int getNumFailedMapTasks()
           
 int getNumFailedReduceTasks()
           
 int getNumSuccessfulMapTasks()
           
 int getNumSuccessfulReduceTasks()
           
 Map<Integer,TaskStatus> getReduceTaskStatuses()
           
 TaskStatus getReduceTaskStatuses(int reduceTaskNumber)
           
 void incrementCombineInputs()
           
 void incrementFailedMapTasks()
           
 void incrementFailedReduceTasks()
           
 void incrementSuccessfulMapTasks()
           
 void incrementSuccessfulReduceTasks()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JobStatus

public JobStatus(JobConf jobConf)
Method Detail

addMapTaskStatus

public void addMapTaskStatus(TaskStatus mapStatus)

addReduceTaskStatus

public void addReduceTaskStatus(TaskStatus reduceStatus)

getCurrentMapPercentage

public float getCurrentMapPercentage()

getCurrentReducePercentage

public float getCurrentReducePercentage()

getMapTaskStatuses

public Map<Integer,TaskStatus> getMapTaskStatuses()

getMapTaskStatuses

public TaskStatus getMapTaskStatuses(int mapTaskNumber)

getNumCombineInputsReceived

public int getNumCombineInputsReceived()

getNumFailedMapTasks

public int getNumFailedMapTasks()

getNumFailedReduceTasks

public int getNumFailedReduceTasks()

getNumSuccessfulMapTasks

public int getNumSuccessfulMapTasks()

getNumSuccessfulReduceTasks

public int getNumSuccessfulReduceTasks()

getReduceTaskStatuses

public Map<Integer,TaskStatus> getReduceTaskStatuses()

getReduceTaskStatuses

public TaskStatus getReduceTaskStatuses(int reduceTaskNumber)

incrementCombineInputs

public void incrementCombineInputs()

incrementFailedMapTasks

public void incrementFailedMapTasks()

incrementFailedReduceTasks

public void incrementFailedReduceTasks()

incrementSuccessfulMapTasks

public void incrementSuccessfulMapTasks()

incrementSuccessfulReduceTasks

public void incrementSuccessfulReduceTasks()


For comments and suggestions please send e-mail to