Generated by
JDiff

Class org.apache.hadoop.mapred.JobTracker

Added interfaces org.apache.hadoop.mapred.AdminOperationsProtocol, org.apache.hadoop.security.RefreshUserMappingsProtocol, org.apache.hadoop.security.authorize.RefreshAuthorizationPolicyProtocol.

Added Methods
Collection activeTaskTrackers() Get the active task tracker statuses in the cluster
Collection blacklistedTaskTrackers() Get the blacklisted task tracker statuses in the cluster
void cancelDelegationToken(Token) Discard a current delegation token.
void failJob(JobInProgress) Fail a job and inform the listeners.
Clock getClock()  
ClusterMetrics getClusterMetrics()  
ClusterStatus getClusterStatus(boolean)  
List getCompletedJobs()  
JobConf getConf() Returns a handle to the JobTracker's Configuration
Token getDelegationToken(Text) Get a new delegation token.
DelegationTokenSecretManager getDelegationTokenSecretManager()  
List getFailedJobs()  
QueueAclsInfo[] getQueueAclsForCurrentUser()  
AccessControlList getQueueAdmins(String) @see org.apache.hadoop.mapred.JobSubmissionProtocol#getQueueAdmins(String)
String getStagingAreaDir() @see org.apache.hadoop.mapred.JobSubmissionProtocol#getStagingAreaDir()
TaskTrackerStatus getTaskTrackerStatus(String)  
void initJob(JobInProgress)  
boolean isBlacklisted(String) Whether the tracker is blacklisted or not
void refreshNodes() Rereads the config to get hosts and exclude list file names.
void refreshQueueAcls()  
void refreshServiceAcl()  
void refreshSuperUserGroupsConfiguration()  
void refreshUserToGroupsMappings()  
long renewDelegationToken(Token) Renew a delegation token to extend its lifetime.
JobTracker startTracker(JobConf, String)  
List taskTrackerNames() Get the active and blacklisted task tracker names in the cluster.
 

Changed Methods
Vector completedJobs() Change in return type from JobInProgress> to Vector.
 
Vector failedJobs() Change in return type from JobInProgress> to Vector.
 
TaskReport[] getCleanupTaskReports(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.
 
Class getInstrumentationClass(Configuration) Change in return type from (Class) to Class.
 
Counters getJobCounters(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.
 
TaskReport[] getMapTaskReports(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.
 
Collection getNodesAtMaxLevel() Change in return type from Node> to Collection.
Returns a collection of nodes at the max level
TaskReport[] getReduceTaskReports(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.
 
List getRunningJobs() Change in return type from JobInProgress> to List.
Version that is called from a timer thread and therefore needs to be careful to synchronize.
TaskReport[] getSetupTaskReports(JobID) Change in exceptions thrown from no exceptions to java.io.IOException.
 
TaskTracker getTaskTracker(String) Change in return type from TaskTrackerStatus to TaskTracker.
 
HeartbeatResponse heartbeat(TaskTrackerStatus, boolean, boolean, boolean, short) Change in signature from (TaskTrackerStatus, boolean, boolean, short) to (TaskTrackerStatus, boolean, boolean, boolean, short).
The periodic heartbeat mechanism between the TaskTracker and the JobTracker The JobTracker processes the status information sent by the TaskTracker and responds with instructions to start/stop tasks or jobs and also 'reset' instructions during contingencies.
Vector runningJobs() Change in return type from JobInProgress> to Vector.
 
void setInstrumentationClass(Configuration, Class) Change in signature from (Configuration, Class) to (Configuration, Class).
 
JobStatus submitJob(JobID, String, Credentials) Change in signature from JobID to (JobID, String, Credentials).
JobTracker.submitJob() kicks off a new job.
Collection taskTrackers() Change in return type from TaskTrackerStatus> to Collection.
Get all the task trackers in the cluster
ClusterStatus getClusterStatus() Now deprecated.
use {@link #getClusterStatus(boolean)}
 

Added Fields
long DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT  
String DELEGATION_KEY_UPDATE_INTERVAL_KEY  
long DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT  
String DELEGATION_TOKEN_MAX_LIFETIME_KEY  
long DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT  
String DELEGATION_TOKEN_RENEW_INTERVAL_KEY  
String JT_KEYTAB_FILE  
String JT_USER_NAME