JobTracker (Hadoop 1.2.2-SNAPSHOT API)

java.lang.Object
- org.apache.hadoop.mapred.JobTracker

所有已实现的接口:

VersionedProtocol, AdminOperationsProtocol, JobTrackerMXBean, RefreshAuthorizationPolicyProtocol, RefreshUserMappingsProtocol
```
public class JobTracker
extends Object
implements RefreshUserMappingsProtocol, RefreshAuthorizationPolicyProtocol, AdminOperationsProtocol, JobTrackerMXBean
```
JobTracker is the central location for submitting and tracking MR jobs in a network environment.

嵌套类概要

嵌套类
限定符和类型	类和说明
`static class`	`JobTracker.IllegalStateException` A client tried to submit a job before the Job Tracker was ready.
`static class`	`JobTracker.SafeModeAction` JobTracker SafeMode
`static class`	`JobTracker.State`

字段概要

字段
限定符和类型	字段和说明
`static long`	`COUNTER_UPDATE_INTERVAL`
`static long`	`DEFAULT_DISK_HEALTH_CHECK_INTERVAL` How often TaskTracker needs to check the health of its disks, if not configured using mapred.disk.healthChecker.interval
`static long`	`DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT`
`static String`	`DELEGATION_KEY_UPDATE_INTERVAL_KEY`
`static long`	`DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT`
`static String`	`DELEGATION_TOKEN_MAX_LIFETIME_KEY`
`static long`	`DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT`
`static String`	`DELEGATION_TOKEN_RENEW_INTERVAL_KEY`
`static int`	`FILE_NOT_FOUND`
`static String`	`FOR_REDUCE_TASK` The reduce task number for which this map output is being transferred
`static String`	`FROM_MAP_TASK` The map task from which the map output data is being transferred
`static int`	`HEARTBEAT_INTERVAL_MIN`
`static String`	`JT_KEYTAB_FILE`
`static String`	`JT_USER_NAME`
`static org.apache.commons.logging.Log`	`LOG`
`static String`	`MAP_OUTPUT_LENGTH` The custom http header used for the map output length.
`static String`	`MAPRED_CLUSTER_MAP_MEMORY_MB_PROPERTY`
`static String`	`MAPRED_CLUSTER_MAX_MAP_MEMORY_MB_PROPERTY`
`static String`	`MAPRED_CLUSTER_MAX_REDUCE_MEMORY_MB_PROPERTY`
`static String`	`MAPRED_CLUSTER_REDUCE_MEMORY_MB_PROPERTY`
`static String`	`MAX_USER_JOBCONF_SIZE_KEY` the config key for max user jobconf size
`static String`	`RAW_MAP_OUTPUT_LENGTH` The custom http header used for the "raw" map output length.
`static int`	`SUCCESS`
`static int`	`TRACKERS_OK`
`static int`	`UNKNOWN_TASKTRACKER`
`static long`	`versionID` version 3 introduced to replace emitHearbeat/pollForNewTask/pollForTaskWithClosedJob with `heartbeat(TaskTrackerStatus, boolean, boolean, boolean, short)` version 4 changed TaskReport for HADOOP-549.
`static long`	`versionID`
`static String`	`WORKDIR`

从接口继承的字段 org.apache.hadoop.security.RefreshUserMappingsProtocol
versionID

从接口继承的字段 org.apache.hadoop.security.authorize.RefreshAuthorizationPolicyProtocol
versionID

从接口继承的字段 org.apache.hadoop.mapred.AdminOperationsProtocol
versionID

方法概要

方法
限定符和类型	方法和说明
`Collection<TaskTrackerStatus>`	`activeTaskTrackers()` Get the active task tracker statuses in the cluster
`void`	`addJobInProgressListener(org.apache.hadoop.mapred.JobInProgressListener listener)` Registers a `JobInProgressListener` for updates from this `TaskTrackerManager`.
`Collection<TaskTrackerStatus>`	`blacklistedTaskTrackers()` Get the statuses of the blacklisted task trackers in the cluster.
`void`	`cancelDelegationToken(Token<DelegationTokenIdentifier> token)` Discard a current delegation token.
`Vector<JobInProgress>`	`completedJobs()`
`Vector<JobInProgress>`	`failedJobs()`
`void`	`failJob(JobInProgress job)` Fail a job and inform the listeners.
`static InetSocketAddress`	`getAddress(Configuration conf)`
`String`	`getAliveNodesInfoJson()`
`JobStatus[]`	`getAllJobs()` Get all the jobs submitted.
`String`	`getAssignedTracker(TaskAttemptID taskId)` Get tracker name for a given task id.
`String`	`getBlacklistedNodesInfoJson()`
`String`	`getBuildVersion()` Returns the VersionInfo build version of the JobTracker
`TaskReport[]`	`getCleanupTaskReports(JobID jobid)` Grab a bunch of info on the cleanup tasks that make up the job
`org.apache.hadoop.mapred.Clock`	`getClock()`
`ClusterMetrics`	`getClusterMetrics()`
`ClusterStatus`	`getClusterStatus()` 已过时。 use `getClusterStatus(boolean)`
`ClusterStatus`	`getClusterStatus(boolean detailed)` Get the current status of the cluster
`JobConf`	`getConf()` Returns a handle to the JobTracker's Configuration
`String`	`getConfigVersion()`
`Token<DelegationTokenIdentifier>`	`getDelegationToken(Text renewer)` Get a new delegation token.
`DelegationTokenSecretManager`	`getDelegationTokenSecretManager()`
`String`	`getFilesystemName()` Grab the local fs name
`String`	`getGraylistedNodesInfoJson()`
`String`	`getHostname()`
`int`	`getInfoPort()`
`JobInProgress`	`getJob(JobID jobid)` Obtain the job object identified by jobid
`Counters`	`getJobCounters(JobID jobid)` Grab the current job counters
`JobProfile`	`getJobProfile(JobID jobid)` Grab a handle to a job that is already known to the JobTracker.
`JobStatus[]`	`getJobsFromQueue(String queue)` Gets all the jobs submitted to the particular Queue
`JobStatus`	`getJobStatus(JobID jobid)` Grab a handle to a job that is already known to the JobTracker.
`String`	`getJobTrackerMachine()`
`static String`	`getLocalJobFilePath(JobID jobId)` Get the localized job file path on the job trackers local file system
`TaskReport[]`	`getMapTaskReports(JobID jobid)` Grab a bunch of info on the map tasks that make up the job
`JobID`	`getNewJobId()` Allocates a new JobId string.
`int`	`getNextHeartbeatInterval()` Calculates next heartbeat interval using cluster size.
`Node`	`getNode(String name)` Return the Node in the network topology that corresponds to the hostname
`Collection<Node>`	`getNodesAtMaxLevel()` Returns a collection of nodes at the max level
`int`	`getNumberOfUniqueHosts()`
`int`	`getNumResolvedTaskTrackers()`
`int`	`getNumTaskCacheLevels()`
`static Node`	`getParentNode(Node node, int level)`
`long`	`getProtocolVersion(String protocol, long clientVersion)` Return protocol version corresponding to protocol interface.
`QueueAclsInfo[]`	`getQueueAclsForCurrentUser()` Gets the Queue ACLs for current user
`AccessControlList`	`getQueueAdmins(String queueName)` Get the administrators of the given job-queue.
`JobQueueInfo`	`getQueueInfo(String queue)` Gets scheduling information associated with the particular Job queue
`String`	`getQueueInfoJson()`
`org.apache.hadoop.mapred.QueueManager`	`getQueueManager()` Return the `QueueManager` associated with the JobTracker.
`JobQueueInfo[]`	`getQueues()` Gets set of Job Queues associated with the Job Tracker
`String`	`getReasonsForBlacklisting(String host)`
`String`	`getReasonsForGraylisting(String host)`
`long`	`getRecoveryDuration()` How long the jobtracker took to recover from restart.
`TaskReport[]`	`getReduceTaskReports(JobID jobid)` Grab a bunch of info on the reduce tasks that make up the job
`List<JobInProgress>`	`getRunningJobs()` Version that is called from a timer thread, and therefore needs to be careful to synchronize.
`TaskReport[]`	`getSetupTaskReports(JobID jobid)` Grab a bunch of info on the setup tasks that make up the job
`String`	`getStagingAreaDir()` Get a hint from the JobTracker where job-specific files are to be placed.
`long`	`getStartTime()`
`String`	`getSummaryJson()`
`String`	`getSystemDir()` Grab the jobtracker system directory path where job-specific files are to be placed.
`TaskCompletionEvent[]`	`getTaskCompletionEvents(JobID jobid, int fromEventId, int maxEvents)` Get task completion events for the jobid, starting from fromEventId.
`String[]`	`getTaskDiagnostics(TaskAttemptID taskId)` Get the diagnostics for a given task
`TaskTracker`	`getTaskTracker(String trackerID)`
`TaskTrackerStatus`	`getTaskTrackerStatus(String trackerID)`
`int`	`getThreadCount()`
`org.apache.hadoop.mapred.TaskInProgress`	`getTip(TaskID tipid)` Returns specified TaskInProgress, or null.
`int`	`getTotalSubmissions()`
`String`	`getTrackerIdentifier()` Get the unique identifier (ie. timestamp) of this job tracker start.
`int`	`getTrackerPort()`
`String`	`getVersion()`
`String`	`getVIVersion()` Returns the VersionInfo version of the JobTracker
`Collection<TaskTrackerStatus>`	`graylistedTaskTrackers()` Get the statuses of the graylisted task trackers in the cluster.
`boolean`	`hasRecovered()` Whether the JT has recovered upon restart
`boolean`	`hasRestarted()` Whether the JT has restarted
`org.apache.hadoop.mapred.HeartbeatResponse`	`heartbeat(TaskTrackerStatus status, boolean restarted, boolean initialContact, boolean acceptNewTasks, short responseId)` The periodic heartbeat mechanism between the `TaskTracker` and the `JobTracker`.
`void`	`initJob(JobInProgress job)` Initialize the Job
`boolean`	`isBlacklisted(String trackerID)` Whether the tracker is blacklisted or not
`boolean`	`isGraylisted(String trackerID)` Whether the tracker is graylisted or not
`boolean`	`isInSafeMode()` Get safe mode.
`boolean`	`isNodeGroupAware()`
`JobStatus[]`	`jobsToComplete()` Get the jobs that are not completed and not failed
`void`	`killJob(JobID jobid)` Kill the indicated job
`boolean`	`killTask(TaskAttemptID taskid, boolean shouldFail)` Kill indicated task attempt.
`static void`	`main(String[] argv)` Start the JobTracker process.
`void`	`offerService()` Run forever
`void`	`refreshNodes()` Rereads the config to get hosts and exclude list file names.
`void`	`refreshQueues()` Refresh the queue acls in use currently.
`void`	`refreshServiceAcl()` Refresh the service-level authorization policy in-effect.
`void`	`refreshSuperUserGroupsConfiguration()` Refresh superuser proxy group list
`void`	`refreshUserToGroupsMappings()` Refresh user to group mappings.
`void`	`removeJobInProgressListener(org.apache.hadoop.mapred.JobInProgressListener listener)` Unregisters a `JobInProgressListener` from this `TaskTrackerManager`.
`long`	`renewDelegationToken(Token<DelegationTokenIdentifier> token)` Renew a delegation token to extend its lifetime.
`void`	`reportTaskTrackerError(String taskTracker, String errorClass, String errorMessage)` Report a problem to the job tracker.
`Node`	`resolveAndAddToTopology(String name)`
`Vector<JobInProgress>`	`runningJobs()`
`void`	`setJobPriority(JobID jobid, String priority)` Set the priority of the specified job
`boolean`	`setSafeMode(JobTracker.SafeModeAction safeModeAction)` Set safe mode for the JobTracker.
`static JobTracker`	`startTracker(JobConf conf)` Start the JobTracker with given configuration.
`static JobTracker`	`startTracker(JobConf conf, String identifier)`
`static JobTracker`	`startTracker(JobConf conf, String identifier, boolean initialize)`
`void`	`stopTracker()`
`JobStatus`	`submitJob(JobID jobId, String jobSubmitDir, Credentials ts)` JobTracker.submitJob() kicks off a new job.
`List<List<String>>`	`taskTrackerNames()` Get the active, blacklisted, and graylisted task tracker names in the cluster.
`Collection<TaskTrackerStatus>`	`taskTrackers()` Get all the task trackers in the cluster

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - MAX_USER_JOBCONF_SIZE_KEY
```
public static final String MAX_USER_JOBCONF_SIZE_KEY
```
    the config key for max user jobconf size
    
    另请参阅:
    常量字段值
  - DELEGATION_KEY_UPDATE_INTERVAL_KEY
```
public static final String DELEGATION_KEY_UPDATE_INTERVAL_KEY
```
    另请参阅:
    常量字段值
  - DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT
```
public static final long DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT
```
    另请参阅:
    常量字段值
  - DELEGATION_TOKEN_RENEW_INTERVAL_KEY
```
public static final String DELEGATION_TOKEN_RENEW_INTERVAL_KEY
```
    另请参阅:
    常量字段值
  - DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT
```
public static final long DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT
```
    另请参阅:
    常量字段值
  - DELEGATION_TOKEN_MAX_LIFETIME_KEY
```
public static final String DELEGATION_TOKEN_MAX_LIFETIME_KEY
```
    另请参阅:
    常量字段值
  - DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT
```
public static final long DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT
```
    另请参阅:
    常量字段值
  - LOG
```
public static final org.apache.commons.logging.Log LOG
```
  - JT_USER_NAME
```
public static final String JT_USER_NAME
```
    另请参阅:
    常量字段值
  - JT_KEYTAB_FILE
```
public static final String JT_KEYTAB_FILE
```
    另请参阅:
    常量字段值
  - MAPRED_CLUSTER_MAP_MEMORY_MB_PROPERTY
```
public static final String MAPRED_CLUSTER_MAP_MEMORY_MB_PROPERTY
```
    另请参阅:
    常量字段值
  - MAPRED_CLUSTER_REDUCE_MEMORY_MB_PROPERTY
```
public static final String MAPRED_CLUSTER_REDUCE_MEMORY_MB_PROPERTY
```
    另请参阅:
    常量字段值
  - MAPRED_CLUSTER_MAX_MAP_MEMORY_MB_PROPERTY
```
public static final String MAPRED_CLUSTER_MAX_MAP_MEMORY_MB_PROPERTY
```
    另请参阅:
    常量字段值
  - MAPRED_CLUSTER_MAX_REDUCE_MEMORY_MB_PROPERTY
```
public static final String MAPRED_CLUSTER_MAX_REDUCE_MEMORY_MB_PROPERTY
```
    另请参阅:
    常量字段值
  - HEARTBEAT_INTERVAL_MIN
```
public static final int HEARTBEAT_INTERVAL_MIN
```
    另请参阅:
    常量字段值
  - COUNTER_UPDATE_INTERVAL
```
public static final long COUNTER_UPDATE_INTERVAL
```
    另请参阅:
    常量字段值
  - DEFAULT_DISK_HEALTH_CHECK_INTERVAL
```
public static final long DEFAULT_DISK_HEALTH_CHECK_INTERVAL
```
    How often TaskTracker needs to check the health of its disks, if not configured using mapred.disk.healthChecker.interval
    
    另请参阅:
    常量字段值
  - SUCCESS
```
public static final int SUCCESS
```
    另请参阅:
    常量字段值
  - FILE_NOT_FOUND
```
public static final int FILE_NOT_FOUND
```
    另请参阅:
    常量字段值
  - MAP_OUTPUT_LENGTH
```
public static final String MAP_OUTPUT_LENGTH
```
    The custom http header used for the map output length.
    
    另请参阅:
    常量字段值
  - RAW_MAP_OUTPUT_LENGTH
```
public static final String RAW_MAP_OUTPUT_LENGTH
```
    The custom http header used for the "raw" map output length.
    
    另请参阅:
    常量字段值
  - FROM_MAP_TASK
```
public static final String FROM_MAP_TASK
```
    The map task from which the map output data is being transferred
    
    另请参阅:
    常量字段值
  - FOR_REDUCE_TASK
```
public static final String FOR_REDUCE_TASK
```
    The reduce task number for which this map output is being transferred
    
    另请参阅:
    常量字段值
  - WORKDIR
```
public static final String WORKDIR
```
    另请参阅:
    常量字段值
  - versionID
```
public static final long versionID
```
    version 3 introduced to replace emitHearbeat/pollForNewTask/pollForTaskWithClosedJob with heartbeat(TaskTrackerStatus, boolean, boolean, boolean, short) version 4 changed TaskReport for HADOOP-549. version 5 introduced that removes locateMapOutputs and instead uses getTaskCompletionEvents to figure finished maps and fetch the outputs version 6 adds maxTasks to TaskTrackerStatus for HADOOP-1245 version 7 replaces maxTasks by maxMapTasks and maxReduceTasks in TaskTrackerStatus for HADOOP-1274 Version 8: HeartbeatResponse is added with the next heartbeat interval. version 9 changes the counter representation for HADOOP-2248 version 10 changes the TaskStatus representation for HADOOP-2208 version 11 changes string to JobID in getTaskCompletionEvents(). version 12 changes the counters representation for HADOOP-1915 version 13 added call getBuildVersion() for HADOOP-236 Version 14: replaced getFilesystemName with getSystemDir for HADOOP-3135 Version 15: Changed format of Task and TaskStatus for HADOOP-153 Version 16: adds ResourceStatus to TaskTrackerStatus for HADOOP-3759 Version 17: Changed format of Task and TaskStatus for HADOOP-3150 Version 18: Changed status message due to changes in TaskStatus Version 19: Changed heartbeat to piggyback JobTracker restart information so that the TaskTracker can synchronize itself. Version 20: Changed status message due to changes in TaskStatus (HADOOP-4232) Version 21: Changed information reported in TaskTrackerStatus' ResourceStatus and the corresponding accessor methods (HADOOP-4035) Version 22: Replaced parameter 'initialContact' with 'restarted' in heartbeat method (HADOOP-4305) Version 23: Added parameter 'initialContact' again in heartbeat method (HADOOP-4869) Version 24: Changed format of Task and TaskStatus for HADOOP-4759 Version 25: JobIDs are passed in response to JobTracker restart Version 26: Added numRequiredSlots to TaskStatus for MAPREDUCE-516 Version 27: Adding node health status to TaskStatus for MAPREDUCE-211 Version 28: Adding user name to the serialized Task for use by TT. Version 29: Adding available memory and CPU usage information on TT to TaskTrackerStatus for MAPREDUCE-1218 Version 30: Adding disk failure to TaskTrackerStatus for MAPREDUCE-3015 Version 31: Adding version methods for HADOOP-8209
    
    另请参阅:
    常量字段值
  - TRACKERS_OK
```
public static final int TRACKERS_OK
```
    另请参阅:
    常量字段值
  - UNKNOWN_TASKTRACKER
```
public static final int UNKNOWN_TASKTRACKER
```
    另请参阅:
    常量字段值
  - versionID
```
public static final long versionID
```
    另请参阅:
    常量字段值
- 方法详细资料
  - getClock
```
public org.apache.hadoop.mapred.Clock getClock()
```
  - startTracker
```
public static JobTracker startTracker(JobConf conf)
                               throws IOException,
                                      InterruptedException
```
    Start the JobTracker with given configuration. The conf will be modified to reflect the actual ports on which the JobTracker is up and running if the user passes the port as zero.
    
    参数:
    conf - configuration for the JobTracker.
    
    抛出:
    
    IOException
    
    InterruptedException
  - startTracker
```
public static JobTracker startTracker(JobConf conf,
                      String identifier)
                               throws IOException,
                                      InterruptedException
```
    抛出:
    
    IOException
    
    InterruptedException
  - startTracker
```
public static JobTracker startTracker(JobConf conf,
                      String identifier,
                      boolean initialize)
                               throws IOException,
                                      InterruptedException
```
    抛出:
    
    IOException
    
    InterruptedException
  - stopTracker
```
public void stopTracker()
                 throws IOException
```
    抛出:
    
    IOException
  - getProtocolVersion
```
public long getProtocolVersion(String protocol,
                      long clientVersion)
                        throws IOException
```
    从接口复制的说明: VersionedProtocol
    
    Return protocol version corresponding to protocol interface.
    
    指定者:
    
    getProtocolVersion 在接口中 VersionedProtocol
    
    参数:
    protocol - The classname of the protocol interface
    clientVersion - The version of the protocol that the client speaks
    
    返回:
    the version that the server will speak
    
    抛出:
    
    IOException
  - getDelegationTokenSecretManager
```
public DelegationTokenSecretManager getDelegationTokenSecretManager()
```
  - hasRestarted
```
public boolean hasRestarted()
```
    Whether the JT has restarted
  - hasRecovered
```
public boolean hasRecovered()
```
    Whether the JT has recovered upon restart
  - getRecoveryDuration
```
public long getRecoveryDuration()
```
    How long the jobtracker took to recover from restart.
  - getAddress
```
public static InetSocketAddress getAddress(Configuration conf)
```
  - offerService
```
public void offerService()
                  throws InterruptedException,
                         IOException
```
    Run forever
    
    抛出:
    
    InterruptedException
    
    IOException
  - getTotalSubmissions
```
public int getTotalSubmissions()
```
  - getJobTrackerMachine
```
public String getJobTrackerMachine()
```
  - getTrackerIdentifier
```
public String getTrackerIdentifier()
```
    Get the unique identifier (ie. timestamp) of this job tracker start.
    
    返回:
    a string with a unique identifier
  - getTrackerPort
```
public int getTrackerPort()
```
  - getInfoPort
```
public int getInfoPort()
```
  - getStartTime
```
public long getStartTime()
```
  - runningJobs
```
public Vector<JobInProgress> runningJobs()
```
  - getRunningJobs
```
public List<JobInProgress> getRunningJobs()
```
    Version that is called from a timer thread, and therefore needs to be careful to synchronize.
  - failedJobs
```
public Vector<JobInProgress> failedJobs()
```
  - completedJobs
```
public Vector<JobInProgress> completedJobs()
```
  - taskTrackers
```
public Collection<TaskTrackerStatus> taskTrackers()
```
    Get all the task trackers in the cluster
    
    返回:
    Collection of TaskTrackerStatus
  - activeTaskTrackers
```
public Collection<TaskTrackerStatus> activeTaskTrackers()
```
    Get the active task tracker statuses in the cluster
    
    返回:
    Collection of active TaskTrackerStatus
  - taskTrackerNames
```
public List<List<String>> taskTrackerNames()
```
    Get the active, blacklisted, and graylisted task tracker names in the cluster. The first element in the returned list contains the list of active tracker names; the second element in the returned list contains the list of blacklisted tracker names; and the third contains the list of graylisted tracker names. Note that the blacklist is disjoint from the active list, but the graylist is not: initially, graylisted trackers are still active and therefore will appear in both lists. (Graylisted trackers can later be blacklisted, in which case they'll be removed from the active list and added to the blacklist, but they remain on the graylist in this case. Blacklisting comes about via the health-check script, while graylisting is heuristically based on the number of per-job blacklistings in a specified time interval.)
  - blacklistedTaskTrackers
```
public Collection<TaskTrackerStatus> blacklistedTaskTrackers()
```
    Get the statuses of the blacklisted task trackers in the cluster.
    
    返回:
    Collection of blacklisted TaskTrackerStatus
  - graylistedTaskTrackers
```
public Collection<TaskTrackerStatus> graylistedTaskTrackers()
```
    Get the statuses of the graylisted task trackers in the cluster.
    
    返回:
    Collection of graylisted TaskTrackerStatus
  - isBlacklisted
```
public boolean isBlacklisted(String trackerID)
```
    Whether the tracker is blacklisted or not
    
    参数:
    trackerID -
    
    返回:
    true if blacklisted, false otherwise
  - isGraylisted
```
public boolean isGraylisted(String trackerID)
```
    Whether the tracker is graylisted or not
    
    参数:
    trackerID -
    
    返回:
    true if graylisted, false otherwise
  - getTaskTrackerStatus
```
public TaskTrackerStatus getTaskTrackerStatus(String trackerID)
```
  - getTaskTracker
```
public TaskTracker getTaskTracker(String trackerID)
```
  - resolveAndAddToTopology
```
public Node resolveAndAddToTopology(String name)
                             throws UnknownHostException
```
    抛出:
    
    UnknownHostException
  - getNodesAtMaxLevel
```
public Collection<Node> getNodesAtMaxLevel()
```
    Returns a collection of nodes at the max level
  - getParentNode
```
public static Node getParentNode(Node node,
                 int level)
```
  - getNode
```
public Node getNode(String name)
```
    Return the Node in the network topology that corresponds to the hostname
  - getNumTaskCacheLevels
```
public int getNumTaskCacheLevels()
```
  - getNumResolvedTaskTrackers
```
public int getNumResolvedTaskTrackers()
```
  - getNumberOfUniqueHosts
```
public int getNumberOfUniqueHosts()
```
    返回:
    The number of unique hosts running tasktrackers.
  - isNodeGroupAware
```
public boolean isNodeGroupAware()
```
  - addJobInProgressListener
```
public void addJobInProgressListener(org.apache.hadoop.mapred.JobInProgressListener listener)
```
    Registers a JobInProgressListener for updates from this TaskTrackerManager.
  - removeJobInProgressListener
```
public void removeJobInProgressListener(org.apache.hadoop.mapred.JobInProgressListener listener)
```
    Unregisters a JobInProgressListener from this TaskTrackerManager.
  - getQueueManager
```
public org.apache.hadoop.mapred.QueueManager getQueueManager()
```
    Return the QueueManager associated with the JobTracker.
    
    返回:
    the QueueManager
  - getVIVersion
```
public String getVIVersion()
                    throws IOException
```
    Returns the VersionInfo version of the JobTracker
    
    抛出:
    
    IOException
  - getBuildVersion
```
public String getBuildVersion()
                       throws IOException
```
    Returns the VersionInfo build version of the JobTracker
    
    抛出:
    
    IOException
  - heartbeat
```
public org.apache.hadoop.mapred.HeartbeatResponse heartbeat(TaskTrackerStatus status,
                                                   boolean restarted,
                                                   boolean initialContact,
                                                   boolean acceptNewTasks,
                                                   short responseId)
                                                     throws IOException
```
    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.
    
    参数:
    status - the status update
    restarted - true if the process has just started or restarted, false otherwise
    initialContact - true if this is first interaction since 'refresh', false otherwise.
    acceptNewTasks - true if the TaskTracker is ready to accept new tasks to run.
    responseId - the last responseId successfully acted upon by the TaskTracker.
    
    返回:
    a HeartbeatResponse with fresh instructions.
    
    抛出:
    
    IOException
  - getNextHeartbeatInterval
```
public int getNextHeartbeatInterval()
```
    Calculates next heartbeat interval using cluster size. Heartbeat interval is incremented by 1 second for every 100 nodes by default.
    
    返回:
    next heartbeat interval.
  - getFilesystemName
```
public String getFilesystemName()
                         throws IOException
```
    Grab the local fs name
    
    抛出:
    
    IOException
  - getConf
```
public JobConf getConf()
```
    Returns a handle to the JobTracker's Configuration
  - reportTaskTrackerError
```
public void reportTaskTrackerError(String taskTracker,
                          String errorClass,
                          String errorMessage)
                            throws IOException
```
    Report a problem to the job tracker.
    
    参数:
    taskTracker - the name of the task tracker
    errorClass - the kind of error (eg. the class that was thrown)
    errorMessage - the human readable error message
    
    抛出:
    
    IOException - if there was a problem in communication or on the remote side
  - getNewJobId
```
public JobID getNewJobId()
                  throws IOException
```
    Allocates a new JobId string.
    
    返回:
    a unique job name for submitting jobs.
    
    抛出:
    
    IOException
  - submitJob
```
public JobStatus submitJob(JobID jobId,
                  String jobSubmitDir,
                  Credentials ts)
                    throws IOException
```
    JobTracker.submitJob() kicks off a new job. Create a 'JobInProgress' object, which contains both JobProfile and JobStatus. Those two sub-objects are sometimes shipped outside of the JobTracker. But JobInProgress adds info that's useful for the JobTracker alone.
    
    抛出:
    
    IOException
  - getStagingAreaDir
```
public String getStagingAreaDir()
                         throws IOException
```
    Get a hint from the JobTracker where job-specific files are to be placed.
    
    返回:
    the directory where job-specific files are to be placed.
    
    抛出:
    
    IOException
    另请参阅:
    JobSubmissionProtocol.getStagingAreaDir()
  - getClusterStatus
```
@Deprecated
public ClusterStatus getClusterStatus()
```
    已过时。 use getClusterStatus(boolean)
    
    返回:
    a summary of the cluster's status.
  - getClusterStatus
```
public ClusterStatus getClusterStatus(boolean detailed)
```
    Get the current status of the cluster
    
    参数:
    detailed - if true then report tracker names and memory usage
    
    返回:
    summary of the state of the cluster
  - getClusterMetrics
```
public ClusterMetrics getClusterMetrics()
```
  - killJob
```
public void killJob(JobID jobid)
             throws IOException
```
    Kill the indicated job
    
    抛出:
    
    IOException
    另请参阅:
    JobSubmissionProtocol.killJob(org.apache.hadoop.mapred.JobID)
  - cancelDelegationToken
```
public void cancelDelegationToken(Token<DelegationTokenIdentifier> token)
                           throws IOException,
                                  InterruptedException
```
    Discard a current delegation token.
    
    参数:
    token - the token to cancel
    
    抛出:
    
    IOException
    
    InterruptedException
  - getDelegationToken
```
public Token<DelegationTokenIdentifier> getDelegationToken(Text renewer)
                                                    throws IOException,
                                                           InterruptedException
```
    Get a new delegation token.
    
    参数:
    renewer - the user other than the creator (if any) that can renew the token
    
    返回:
    the new delegation token
    
    抛出:
    
    IOException
    
    InterruptedException
  - renewDelegationToken
```
public long renewDelegationToken(Token<DelegationTokenIdentifier> token)
                          throws IOException,
                                 InterruptedException
```
    Renew a delegation token to extend its lifetime.
    
    参数:
    token - the token to renew
    
    返回:
    the new expiration time
    
    抛出:
    
    IOException
    
    InterruptedException
  - initJob
```
public void initJob(JobInProgress job)
```
    Initialize the Job
    
    参数:
    job - JobInProgress object
  - failJob
```
public void failJob(JobInProgress job)
```
    Fail a job and inform the listeners. Other components in the framework should use this to fail a job.
    
    参数:
    job - JobInProgress object
  - setJobPriority
```
public void setJobPriority(JobID jobid,
                  String priority)
                    throws IOException
```
    Set the priority of the specified job
    
    参数:
    jobid - ID of the job
    priority - Priority to be set for the job
    
    抛出:
    
    IOException
  - getJobProfile
```
public JobProfile getJobProfile(JobID jobid)
                         throws IOException
```
    Grab a handle to a job that is already known to the JobTracker.
    
    返回:
    Profile of the job, or null if not found.
    
    抛出:
    
    IOException
  - getJobStatus
```
public JobStatus getJobStatus(JobID jobid)
                       throws IOException
```
    Grab a handle to a job that is already known to the JobTracker.
    
    返回:
    Status of the job, or null if not found.
    
    抛出:
    
    IOException
  - getJobCounters
```
public Counters getJobCounters(JobID jobid)
                        throws IOException
```
    Grab the current job counters
    
    抛出:
    
    IOException
  - getMapTaskReports
```
public TaskReport[] getMapTaskReports(JobID jobid)
                               throws IOException
```
    Grab a bunch of info on the map tasks that make up the job
    
    抛出:
    
    IOException
  - getReduceTaskReports
```
public TaskReport[] getReduceTaskReports(JobID jobid)
                                  throws IOException
```
    Grab a bunch of info on the reduce tasks that make up the job
    
    抛出:
    
    IOException
  - getCleanupTaskReports
```
public TaskReport[] getCleanupTaskReports(JobID jobid)
                                   throws IOException
```
    Grab a bunch of info on the cleanup tasks that make up the job
    
    抛出:
    
    IOException
  - getSetupTaskReports
```
public TaskReport[] getSetupTaskReports(JobID jobid)
                                 throws IOException
```
    Grab a bunch of info on the setup tasks that make up the job
    
    抛出:
    
    IOException
  - getTaskCompletionEvents
```
public TaskCompletionEvent[] getTaskCompletionEvents(JobID jobid,
                                            int fromEventId,
                                            int maxEvents)
                                              throws IOException
```
    Get task completion events for the jobid, starting from fromEventId. Returns empty aray if no events are available.
    
    参数:
    jobid - job id
    fromEventId - event id to start from.
    maxEvents - the max number of events we want to look at
    
    返回:
    array of task completion events.
    
    抛出:
    
    IOException
  - getTaskDiagnostics
```
public String[] getTaskDiagnostics(TaskAttemptID taskId)
                            throws IOException
```
    Get the diagnostics for a given task
    
    参数:
    taskId - the id of the task
    
    返回:
    an array of the diagnostic messages
    
    抛出:
    
    IOException
  - getTip
```
public org.apache.hadoop.mapred.TaskInProgress getTip(TaskID tipid)
```
    Returns specified TaskInProgress, or null.
  - killTask
```
public boolean killTask(TaskAttemptID taskid,
               boolean shouldFail)
                 throws IOException
```
    Kill indicated task attempt.
    
    参数:
    taskid - the id of the task to kill.
    shouldFail - if true the task is failed and added to failed tasks list, otherwise it is just killed, w/o affecting job failure status.
    
    返回:
    true if the task was found and successfully marked to kill
    
    抛出:
    
    IOException
    另请参阅:
    JobSubmissionProtocol.killTask(TaskAttemptID, boolean)
  - getAssignedTracker
```
public String getAssignedTracker(TaskAttemptID taskId)
```
    Get tracker name for a given task id.
    
    参数:
    taskId - the name of the task
    
    返回:
    The name of the task tracker
  - jobsToComplete
```
public JobStatus[] jobsToComplete()
```
    Get the jobs that are not completed and not failed
    
    返回:
    array of JobStatus for the running/to-be-run jobs.
  - getAllJobs
```
public JobStatus[] getAllJobs()
```
    Get all the jobs submitted.
    
    返回:
    array of JobStatus for the submitted jobs
    另请参阅:
    JobSubmissionProtocol.getAllJobs()
  - getSystemDir
```
public String getSystemDir()
```
    Grab the jobtracker system directory path where job-specific files are to be placed.
    
    返回:
    the system directory where job-specific files are to be placed.
    另请参阅:
    JobSubmissionProtocol.getSystemDir()
  - getQueueAdmins
```
public AccessControlList getQueueAdmins(String queueName)
                                 throws IOException
```
    Get the administrators of the given job-queue. This method is for hadoop internal use only.
    
    返回:
    Queue administrators ACL for the queue to which job is submitted to
    
    抛出:
    
    IOException
    另请参阅:
    JobSubmissionProtocol.getQueueAdmins(String)
  - getJob
```
public JobInProgress getJob(JobID jobid)
```
    Obtain the job object identified by jobid
    
    返回:
    jobInProgress object
  - refreshNodes
```
public void refreshNodes()
                  throws IOException
```
    Rereads the config to get hosts and exclude list file names. Rereads the files to update the hosts and exclude lists.
    
    指定者:
    
    refreshNodes 在接口中 AdminOperationsProtocol
    
    抛出:
    
    IOException
  - getLocalJobFilePath
```
public static String getLocalJobFilePath(JobID jobId)
```
    Get the localized job file path on the job trackers local file system
    
    参数:
    jobId - id of the job
    
    返回:
    the path of the job conf file on the local file system
  - main
```
public static void main(String[] argv)
                 throws IOException,
                        InterruptedException
```
    Start the JobTracker process. This is used only for debugging. As a rule, JobTracker should be run as part of the DFS Namenode process.
    
    抛出:
    
    IOException
    
    InterruptedException
  - getQueues
```
public JobQueueInfo[] getQueues()
                         throws IOException
```
    Gets set of Job Queues associated with the Job Tracker
    
    返回:
    Array of the Job Queue Information Object
    
    抛出:
    
    IOException
  - getQueueInfo
```
public JobQueueInfo getQueueInfo(String queue)
                          throws IOException
```
    Gets scheduling information associated with the particular Job queue
    
    参数:
    queue - Queue Name
    
    返回:
    Scheduling Information of the Queue
    
    抛出:
    
    IOException
  - getJobsFromQueue
```
public JobStatus[] getJobsFromQueue(String queue)
                             throws IOException
```
    Gets all the jobs submitted to the particular Queue
    
    参数:
    queue - Queue name
    
    返回:
    array of JobStatus for the submitted jobs
    
    抛出:
    
    IOException
  - getQueueAclsForCurrentUser
```
public QueueAclsInfo[] getQueueAclsForCurrentUser()
                                           throws IOException
```
    Gets the Queue ACLs for current user
    
    返回:
    array of QueueAclsInfo object for current user.
    
    抛出:
    
    IOException
  - refreshServiceAcl
```
public void refreshServiceAcl()
                       throws IOException
```
    从接口复制的说明: RefreshAuthorizationPolicyProtocol
    
    Refresh the service-level authorization policy in-effect.
    
    指定者:
    
    refreshServiceAcl 在接口中 RefreshAuthorizationPolicyProtocol
    
    抛出:
    
    IOException
  - refreshSuperUserGroupsConfiguration
```
public void refreshSuperUserGroupsConfiguration()
```
    从接口复制的说明: RefreshUserMappingsProtocol
    
    Refresh superuser proxy group list
    
    指定者:
    
    refreshSuperUserGroupsConfiguration 在接口中 RefreshUserMappingsProtocol
  - refreshUserToGroupsMappings
```
public void refreshUserToGroupsMappings()
                                 throws IOException
```
    从接口复制的说明: RefreshUserMappingsProtocol
    
    Refresh user to group mappings.
    
    指定者:
    
    refreshUserToGroupsMappings 在接口中 RefreshUserMappingsProtocol
    
    抛出:
    
    IOException
  - refreshQueues
```
public void refreshQueues()
                   throws IOException
```
    从接口复制的说明: AdminOperationsProtocol
    
    Refresh the queue acls in use currently. Refresh the queues used by the jobtracker and scheduler. Access control lists and queue states are refreshed.
    
    指定者:
    
    refreshQueues 在接口中 AdminOperationsProtocol
    
    抛出:
    
    IOException
  - getReasonsForBlacklisting
```
public String getReasonsForBlacklisting(String host)
```
  - getReasonsForGraylisting
```
public String getReasonsForGraylisting(String host)
```
  - getHostname
```
public String getHostname()
```
    指定者:
    
    getHostname 在接口中 JobTrackerMXBean
    
    返回:
    hostname of the jobtracker
  - getVersion
```
public String getVersion()
```
    指定者:
    
    getVersion 在接口中 JobTrackerMXBean
    
    返回:
    version of the code base
  - getConfigVersion
```
public String getConfigVersion()
```
    指定者:
    
    getConfigVersion 在接口中 JobTrackerMXBean
    
    返回:
    the config version (from a config property)
  - getThreadCount
```
public int getThreadCount()
```
    指定者:
    
    getThreadCount 在接口中 JobTrackerMXBean
    
    返回:
    number of threads of the jobtracker jvm
  - getSummaryJson
```
public String getSummaryJson()
```
    指定者:
    
    getSummaryJson 在接口中 JobTrackerMXBean
    
    返回:
    the summary info in json
  - getAliveNodesInfoJson
```
public String getAliveNodesInfoJson()
```
    指定者:
    
    getAliveNodesInfoJson 在接口中 JobTrackerMXBean
    
    返回:
    the alive nodes info in json
  - getBlacklistedNodesInfoJson
```
public String getBlacklistedNodesInfoJson()
```
    指定者:
    
    getBlacklistedNodesInfoJson 在接口中 JobTrackerMXBean
    
    返回:
    the blacklisted nodes info in json
  - getGraylistedNodesInfoJson
```
public String getGraylistedNodesInfoJson()
```
    指定者:
    
    getGraylistedNodesInfoJson 在接口中 JobTrackerMXBean
    
    返回:
    the graylisted nodes info in json
  - getQueueInfoJson
```
public String getQueueInfoJson()
```
    指定者:
    
    getQueueInfoJson 在接口中 JobTrackerMXBean
    
    返回:
    the queue info json
  - setSafeMode
```
public boolean setSafeMode(JobTracker.SafeModeAction safeModeAction)
                    throws IOException
```
    从接口复制的说明: AdminOperationsProtocol
    
    Set safe mode for the JobTracker.
    
    指定者:
    
    setSafeMode 在接口中 AdminOperationsProtocol
    
    参数:
    safeModeAction - safe mode action
    
    返回:
    current safemode
    
    抛出:
    
    IOException
  - isInSafeMode
```
public boolean isInSafeMode()
```
    Get safe mode.
    
    返回:

类 JobTracker

嵌套类概要

字段概要

从接口继承的字段 org.apache.hadoop.security.RefreshUserMappingsProtocol

从接口继承的字段 org.apache.hadoop.security.authorize.RefreshAuthorizationPolicyProtocol

从接口继承的字段 org.apache.hadoop.mapred.AdminOperationsProtocol

方法概要

从类继承的方法 java.lang.Object

字段详细资料

MAX_USER_JOBCONF_SIZE_KEY

DELEGATION_KEY_UPDATE_INTERVAL_KEY

DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT

DELEGATION_TOKEN_RENEW_INTERVAL_KEY

DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT

DELEGATION_TOKEN_MAX_LIFETIME_KEY

DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT

LOG

JT_USER_NAME

JT_KEYTAB_FILE

MAPRED_CLUSTER_MAP_MEMORY_MB_PROPERTY

MAPRED_CLUSTER_REDUCE_MEMORY_MB_PROPERTY

MAPRED_CLUSTER_MAX_MAP_MEMORY_MB_PROPERTY

MAPRED_CLUSTER_MAX_REDUCE_MEMORY_MB_PROPERTY

HEARTBEAT_INTERVAL_MIN

COUNTER_UPDATE_INTERVAL

DEFAULT_DISK_HEALTH_CHECK_INTERVAL

SUCCESS

FILE_NOT_FOUND

MAP_OUTPUT_LENGTH

RAW_MAP_OUTPUT_LENGTH

FROM_MAP_TASK

FOR_REDUCE_TASK

WORKDIR

versionID

TRACKERS_OK

UNKNOWN_TASKTRACKER

versionID

方法详细资料

getClock

startTracker

startTracker

startTracker

stopTracker

getProtocolVersion

getDelegationTokenSecretManager

hasRestarted

hasRecovered

getRecoveryDuration

getAddress

offerService

getTotalSubmissions

getJobTrackerMachine

getTrackerIdentifier

getTrackerPort

getInfoPort

getStartTime

runningJobs

getRunningJobs

failedJobs

completedJobs

taskTrackers

activeTaskTrackers

taskTrackerNames

blacklistedTaskTrackers

graylistedTaskTrackers

isBlacklisted

isGraylisted

getTaskTrackerStatus

getTaskTracker

resolveAndAddToTopology

getNodesAtMaxLevel

getParentNode

getNode

getNumTaskCacheLevels

getNumResolvedTaskTrackers

getNumberOfUniqueHosts

isNodeGroupAware

addJobInProgressListener

removeJobInProgressListener

getQueueManager