org.apache.hadoop.mapred

类 ClusterStatus

java.lang.Object

org.apache.hadoop.mapred.ClusterStatus

所有已实现的接口:

Writable

public class ClusterStatus
extends Object
implements Writable

Status information on the current state of the Map-Reduce cluster.

ClusterStatus provides clients with information such as:

1. Size of the cluster.
2. Name of the trackers.
3. Task capacity of the cluster.
4. The number of currently running map & reduce tasks.
5. State of the JobTracker.

Clients can query for the latest ClusterStatus, via JobClient.getClusterStatus().

另请参阅:

JobClient

字段概要

字段

限定符和类型	字段和说明
static long	UNINITIALIZED_MEMORY_VALUE

方法概要

方法

限定符和类型	方法和说明
Collection<String>	getActiveTrackerNames() Get the names of active task trackers in the cluster.
Collection<String>	getBlacklistedTrackerNames() Get the names of blacklisted task trackers in the cluster.
int	getBlacklistedTrackers() Get the number of blacklisted task trackers in the cluster.
Collection<String>	getGraylistedTrackerNames() Get the names of graylisted task trackers in the cluster.
int	getGraylistedTrackers() Get the number of graylisted task trackers in the cluster.
JobTracker.State	getJobTrackerState() Get the current state of the JobTracker, as JobTracker.State
int	getMapTasks() Get the number of currently running map tasks in the cluster.
int	getMaxMapTasks() Get the maximum capacity for running map tasks in the cluster.
long	getMaxMemory() 已过时。
int	getMaxReduceTasks() Get the maximum capacity for running reduce tasks in the cluster.
int	getNumExcludedNodes() Get the number of excluded hosts in the cluster.
int	getReduceTasks() Get the number of currently running reduce tasks in the cluster.
int	getTaskTrackers() Get the number of active task trackers in the cluster.
long	getTTExpiryInterval() Get the tasktracker expiry interval for the cluster
long	getUsedMemory() 已过时。
void	readFields(DataInput in) Deserialize the fields of this object from in.
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

字段详细资料

UNINITIALIZED_MEMORY_VALUE

public static final long UNINITIALIZED_MEMORY_VALUE

另请参阅:

常量字段值

方法详细资料

getTaskTrackers

public int getTaskTrackers()

Get the number of active task trackers in the cluster. Includes graylisted but not blacklisted trackers.

返回:

the number of active task trackers in the cluster.

getActiveTrackerNames

public Collection<String> getActiveTrackerNames()

Get the names of active task trackers in the cluster. Includes graylisted but not blacklisted trackers.

返回:

the active task trackers in the cluster.

getBlacklistedTrackerNames

public Collection<String> getBlacklistedTrackerNames()

Get the names of blacklisted task trackers in the cluster.

返回:

the blacklisted task trackers in the cluster.

getBlacklistedTrackers

public int getBlacklistedTrackers()

Get the number of blacklisted task trackers in the cluster.

返回:

the number of blacklisted task trackers in the cluster.

getGraylistedTrackerNames

public Collection<String> getGraylistedTrackerNames()

Get the names of graylisted task trackers in the cluster.

返回:

the graylisted task trackers in the cluster.

getGraylistedTrackers

public int getGraylistedTrackers()

Get the number of graylisted task trackers in the cluster.

返回:

the number of graylisted task trackers in the cluster.

getNumExcludedNodes

public int getNumExcludedNodes()

Get the number of excluded hosts in the cluster.

返回:

the number of excluded hosts in the cluster.

getTTExpiryInterval

public long getTTExpiryInterval()

Get the tasktracker expiry interval for the cluster

返回:

the expiry interval in msec

getMapTasks

public int getMapTasks()

Get the number of currently running map tasks in the cluster.

返回:

the number of currently running map tasks in the cluster.

getReduceTasks

public int getReduceTasks()

Get the number of currently running reduce tasks in the cluster.

返回:

the number of currently running reduce tasks in the cluster.

getMaxMapTasks

public int getMaxMapTasks()

Get the maximum capacity for running map tasks in the cluster.

返回:

the maximum capacity for running map tasks in the cluster.

getMaxReduceTasks

public int getMaxReduceTasks()

Get the maximum capacity for running reduce tasks in the cluster.

返回:

the maximum capacity for running reduce tasks in the cluster.

getJobTrackerState

public JobTracker.State getJobTrackerState()

Get the current state of the JobTracker, as JobTracker.State

返回:

the current state of the JobTracker.

getUsedMemory

@Deprecated
public long getUsedMemory()

已过时。

Get the total heap memory used by the JobTracker

返回:

the size of heap memory used by the JobTracker

getMaxMemory

@Deprecated
public long getMaxMemory()

已过时。

Get the maximum configured heap memory that can be used by the JobTracker

返回:

the configured size of max heap memory that can be used by the JobTracker

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