|
Generated by JDiff |
|||||||
PREV CLASS NEXT CLASS FRAMES NO FRAMES | DETAIL: CONSTRUCTORS | METHODS | FIELDS |
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, |
|
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, extends, JobTrackerInstrumentation> ) 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, |
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, |
Change in signature from (Configuration, Class, extends, JobTrackerInstrumentation> ) to (Configuration, Class ). |
|
JobStatus submitJob(JobID, |
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 |
|
||||||||
PREV CLASS NEXT CLASS FRAMES NO FRAMES |