org.apache.hadoop.mapreduce.server.jobtracker

类 TaskTracker

java.lang.Object

org.apache.hadoop.mapreduce.server.jobtracker.TaskTracker

public class TaskTracker
extends Object

The representation of a single TaskTracker as seen by the JobTracker.

构造器概要

构造器

构造器和说明
TaskTracker(String trackerName) Create a new TaskTracker.

方法概要

方法

限定符和类型	方法和说明
void	cancelAllReservations() Cleanup when the TaskTracker is declared as 'lost/blacklisted' by the JobTracker.
int	getAvailableSlots(TaskType taskType) Get the number of currently available slots on this tasktracker for the given type of the task.
JobInProgress	getJobForFallowSlot(TaskType taskType) Get the JobInProgress for which the fallow slot(s) are held.
TaskTrackerStatus	getStatus() Get the current TaskTrackerStatus of the TaskTracker.
String	getTrackerName() Get the unique identifier for the TaskTracker
void	reserveSlots(TaskType taskType, JobInProgress job, int numSlots) Reserve specified number of slots for a given job.
void	setStatus(TaskTrackerStatus status) Set the current TaskTrackerStatus of the TaskTracker.
void	unreserveSlots(TaskType taskType, JobInProgress job) Free map slots on this TaskTracker which were reserved for taskType.

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TaskTracker

public TaskTracker(String trackerName)

Create a new TaskTracker.

参数:

trackerName - Unique identifier for the TaskTracker

方法详细资料

getTrackerName

public String getTrackerName()

Get the unique identifier for the TaskTracker

返回:

the unique identifier for the TaskTracker

getStatus

public TaskTrackerStatus getStatus()

Get the current TaskTrackerStatus of the TaskTracker.

返回:

the current TaskTrackerStatus of the TaskTracker

setStatus

public void setStatus(TaskTrackerStatus status)

Set the current TaskTrackerStatus of the TaskTracker.

参数:

status - the current TaskTrackerStatus of the TaskTracker

getAvailableSlots

public int getAvailableSlots(TaskType taskType)

Get the number of currently available slots on this tasktracker for the given type of the task.

参数:

taskType - the TaskType to check for number of available slots

返回:

the number of currently available slots for the given taskType

getJobForFallowSlot

public JobInProgress getJobForFallowSlot(TaskType taskType)

Get the JobInProgress for which the fallow slot(s) are held.

参数:

taskType - TaskType of the task

返回:

the task for which the fallow slot(s) are held, null if there are no fallow slots

reserveSlots

public void reserveSlots(TaskType taskType,
                JobInProgress job,
                int numSlots)

Reserve specified number of slots for a given job.

参数:

taskType - TaskType of the task

job - the job for which slots on this TaskTracker are to be reserved

numSlots - number of slots to be reserved

unreserveSlots

public void unreserveSlots(TaskType taskType,
                  JobInProgress job)

Free map slots on this TaskTracker which were reserved for taskType.

参数:

taskType - TaskType of the task

job - job whose slots are being un-reserved

cancelAllReservations

public void cancelAllReservations()

Cleanup when the TaskTracker is declared as 'lost/blacklisted' by the JobTracker. The method assumes that the lock on the JobTracker is obtained by the caller.