类 org.apache.hadoop.mapred.TaskTrackerStatus
的使用

使用TaskTrackerStatus的程序包

程序包	说明
org.apache.hadoop.mapred	A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner.
org.apache.hadoop.mapreduce.server.jobtracker

org.apache.hadoop.mapred中TaskTrackerStatus的使用

返回TaskTrackerStatus的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
TaskTrackerStatus	JobTracker.getTaskTrackerStatus(String trackerID)

返回变量类型为TaskTrackerStatus的类型的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
Collection<TaskTrackerStatus>	JobTracker.activeTaskTrackers() Get the active task tracker statuses in the cluster
Collection<TaskTrackerStatus>	JobTracker.blacklistedTaskTrackers() Get the statuses of the blacklisted task trackers in the cluster.
Collection<TaskTrackerStatus>	JobTracker.graylistedTaskTrackers() Get the statuses of the graylisted task trackers in the cluster.
Collection<TaskTrackerStatus>	JobTracker.taskTrackers() Get all the task trackers in the cluster

参数类型为TaskTrackerStatus的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
protected org.apache.hadoop.mapred.TaskInProgress	JobInProgress.findSpeculativeTask(Collection<org.apache.hadoop.mapred.TaskInProgress> list, TaskTrackerStatus ttStatus, double avgProgress, long currentTime, boolean shouldRemove) Find a speculative task
org.apache.hadoop.mapred.HeartbeatResponse	JobTracker.heartbeat(TaskTrackerStatus status, boolean restarted, boolean initialContact, boolean acceptNewTasks, short responseId) The periodic heartbeat mechanism between the TaskTracker and the JobTracker.
Task	JobInProgress.obtainJobCleanupTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts, boolean isMapSlot) Return a CleanupTask, if appropriate, to run on the given tasktracker
Task	JobInProgress.obtainJobSetupTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts, boolean isMapSlot) Return a SetupTask, if appropriate, to run on the given tasktracker
Task	JobInProgress.obtainNewMapTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts) Return a MapTask, if appropriate, to run on the given tasktracker
Task	JobInProgress.obtainNewMapTaskCommon(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts, int maxCacheLevel) Return a MapTask with locality level that smaller or equal than a given locality level to tasktracker.
Task	JobInProgress.obtainNewNodeLocalMapTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts)
Task	JobInProgress.obtainNewNodeOrRackLocalMapTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts)
Task	JobInProgress.obtainNewNonLocalMapTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts)
Task	JobInProgress.obtainNewReduceTask(TaskTrackerStatus tts, int clusterSize, int numUniqueHosts) Return a ReduceTask, if appropriate, to run on the given tasktracker.
Task	JobInProgress.obtainTaskCleanupTask(TaskTrackerStatus tts, boolean isMapSlot)

org.apache.hadoop.mapreduce.server.jobtracker中TaskTrackerStatus的使用

返回TaskTrackerStatus的org.apache.hadoop.mapreduce.server.jobtracker中的方法

限定符和类型	方法和说明
TaskTrackerStatus	TaskTracker.getStatus() Get the current TaskTrackerStatus of the TaskTracker.

参数类型为TaskTrackerStatus的org.apache.hadoop.mapreduce.server.jobtracker中的方法

限定符和类型	方法和说明
void	TaskTracker.setStatus(TaskTrackerStatus status) Set the current TaskTrackerStatus of the TaskTracker.