Generated by
JDiff

Class org.apache.hadoop.mapred.JobTracker

Added interface org.apache.hadoop.mapred.TaskTrackerManager.

Removed Methods
String getAssignedTracker(String)  
JobInProgress getJob(String)  
Counters getJobCounters(String)  
JobProfile getJobProfile(String)  
JobStatus getJobStatus(String)  
String getLocalJobFilePath(String)  
TaskReport[] getMapTaskReports(String)  
TaskReport[] getReduceTaskReports(String)  
TaskCompletionEvent[] getTaskCompletionEvents(String, int, int)  
String[] getTaskDiagnostics(String, String, String)  
void killJob(String)  
boolean killTask(String, boolean)  
JobStatus submitJob(String)  
 

Added Methods
void addJobInProgressListener(JobInProgressListener)  
TaskReport[] getCleanupTaskReports(JobID)  
Class<JobTrackerInstrumentation> getInstrumentationClass(Configuration)  
JobStatus[] getJobsFromQueue(String)  
int getNextHeartbeatInterval() Calculates next heartbeat interval using cluster size.
int getNumberOfUniqueHosts()  
JobQueueInfo getQueueInfo(String)  
QueueManager getQueueManager() Return the QueueManager associated with the JobTracker.
JobQueueInfo[] getQueues()  
long getRecoveryDuration() How long the jobtracker took to recover from restart.
TaskReport[] getSetupTaskReports(JobID)  
boolean hasRecovered() Whether the JT has recovered upon restart
boolean hasRestarted() Whether the JT has restarted
void removeJobInProgressListener(JobInProgressListener)  
void setInstrumentationClass(Configuration, Class<JobTrackerInstrumentation>)  
void setJobPriority(JobID, String) Set the priority of a job
 

Changed Methods
void offerService() Change in exceptions thrown from java.lang.InterruptedException to (java.lang.InterruptedException, java.io.IOException).
Run forever
Collection<TaskTrackerStatus> taskTrackers() Change in return type from Collection to Collection<TaskTrackerStatus>.
 
void killJob(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.