org.apache.hadoop.mapred

类 TaskTrackerStatus

java.lang.Object

org.apache.hadoop.mapred.TaskTrackerStatus

所有已实现的接口:

Writable

public class TaskTrackerStatus
extends Object
implements Writable

A TaskTrackerStatus is a MapReduce primitive. Keeps info on a TaskTracker. The JobTracker maintains a set of the most recent TaskTrackerStatus objects for each unique TaskTracker it knows about. This is NOT a public interface!

字段概要

字段

限定符和类型	字段和说明
static org.apache.commons.logging.Log	LOG
static int	UNAVAILABLE

构造器概要

构造器

构造器和说明
TaskTrackerStatus()
TaskTrackerStatus(String trackerName, String host, int httpPort, List<TaskStatus> taskReports, int taskFailures, int dirFailures, int maxMapTasks, int maxReduceTasks)

方法概要

方法

限定符和类型	方法和说明
int	countMapTasks() Get the number of running map tasks.
int	countOccupiedMapSlots() Get the number of occupied map slots.
int	countOccupiedReduceSlots() Get the number of occupied reduce slots.
int	countReduceTasks() Get the number of running reduce tasks.
int	getAvailableMapSlots() Get available map slots.
int	getAvailableReduceSlots() Get available reduce slots.
int	getDirFailures() Get the number of local directories that have failed on this tracker.
org.apache.hadoop.mapred.TaskTrackerStatus.TaskTrackerHealthStatus	getHealthStatus() Returns health status of the task tracker.
String	getHost()
int	getHttpPort() Get the port that this task tracker is serving http requests on.
long	getLastSeen()
int	getMaxMapSlots() Get the maximum map slots for this node.
int	getMaxReduceSlots() Get the maximum reduce slots for this node.
int	getTaskFailures() Get the number of tasks that have failed on this tracker.
List<TaskStatus>	getTaskReports() Get the current tasks at the TaskTracker.
String	getTrackerName()
void	readFields(DataInput in) Deserialize the fields of this object from in.
void	setLastSeen(long lastSeen)
void	write(DataOutput out) Serialize the fields of this object to out.

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

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

字段详细资料

LOG

public static final org.apache.commons.logging.Log LOG

UNAVAILABLE

public static final int UNAVAILABLE

另请参阅:

常量字段值

构造器详细资料

TaskTrackerStatus

public TaskTrackerStatus()

TaskTrackerStatus

public TaskTrackerStatus(String trackerName,
                 String host,
                 int httpPort,
                 List<TaskStatus> taskReports,
                 int taskFailures,
                 int dirFailures,
                 int maxMapTasks,
                 int maxReduceTasks)

方法详细资料

getTrackerName

public String getTrackerName()

getHost

public String getHost()

getHttpPort

public int getHttpPort()

Get the port that this task tracker is serving http requests on.

返回:

the http port

getTaskFailures

public int getTaskFailures()

Get the number of tasks that have failed on this tracker.

返回:

The number of failed tasks

getDirFailures

public int getDirFailures()

Get the number of local directories that have failed on this tracker.

返回:

The number of failed local directories

getTaskReports

public List<TaskStatus> getTaskReports()

Get the current tasks at the TaskTracker. Tasks are tracked by a TaskStatus object.

返回:

a list of TaskStatus representing the current tasks at the TaskTracker.

countMapTasks

public int countMapTasks()

Get the number of running map tasks.

返回:

the number of running map tasks

countOccupiedMapSlots

public int countOccupiedMapSlots()

Get the number of occupied map slots.

返回:

the number of occupied map slots

getAvailableMapSlots

public int getAvailableMapSlots()

Get available map slots.

返回:

available map slots

countReduceTasks

public int countReduceTasks()

Get the number of running reduce tasks.

返回:

the number of running reduce tasks

countOccupiedReduceSlots

public int countOccupiedReduceSlots()

Get the number of occupied reduce slots.

返回:

the number of occupied reduce slots

getAvailableReduceSlots

public int getAvailableReduceSlots()

Get available reduce slots.

返回:

available reduce slots

getLastSeen

public long getLastSeen()

setLastSeen

public void setLastSeen(long lastSeen)

getMaxMapSlots

public int getMaxMapSlots()

Get the maximum map slots for this node.

返回:

the maximum map slots for this node

getMaxReduceSlots

public int getMaxReduceSlots()

Get the maximum reduce slots for this node.

返回:

the maximum reduce slots for this node

getHealthStatus

public org.apache.hadoop.mapred.TaskTrackerStatus.TaskTrackerHealthStatus getHealthStatus()

Returns health status of the task tracker.

返回:

health status of Task Tracker

write

public void write(DataOutput out)
           throws IOException

从接口复制的说明: Writable

Serialize the fields of this object to out.

指定者:

write 在接口中 Writable

参数:

out - DataOuput to serialize this object into.

抛出:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

从接口复制的说明: Writable

Deserialize the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

指定者:

readFields 在接口中 Writable

参数:

in - DataInput to deseriablize this object from.

抛出:

IOException