@InterfaceAudience.Public @InterfaceStability.Stable public class ClusterStatus extends Object implements Writable
ClusterStatus
provides clients with information such as:
JobTracker
.
Clients can query for the latest ClusterStatus
, via
JobClient.getClusterStatus()
.
JobClient
Modifier and Type | Class and Description |
---|---|
static class |
ClusterStatus.BlackListInfo
Class which encapsulates information about a blacklisted tasktracker.
|
Modifier and Type | Field and Description |
---|---|
static long |
UNINITIALIZED_MEMORY_VALUE |
Modifier and Type | Method and Description |
---|---|
Collection<String> |
getActiveTrackerNames()
Get the names of task trackers in the cluster.
|
Collection<String> |
getBlacklistedTrackerNames()
Get the names of task trackers in the cluster.
|
int |
getBlacklistedTrackers()
Get the number of blacklisted task trackers in the cluster.
|
Collection<ClusterStatus.BlackListInfo> |
getBlackListedTrackersInfo()
Gets the list of blacklisted trackers along with reasons for blacklisting.
|
Collection<String> |
getGraylistedTrackerNames()
Deprecated.
|
int |
getGraylistedTrackers()
Deprecated.
|
JobTracker.State |
getJobTrackerState()
Deprecated.
|
Cluster.JobTrackerStatus |
getJobTrackerStatus()
Get the JobTracker's status.
|
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()
Deprecated.
|
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 task trackers in the cluster.
|
long |
getTTExpiryInterval()
Get the tasktracker expiry interval for the cluster
|
long |
getUsedMemory()
Deprecated.
|
void |
readFields(DataInput in)
Deserialize the fields of this object from
in . |
void |
write(DataOutput out)
Serialize the fields of this object to
out . |
public static final long UNINITIALIZED_MEMORY_VALUE
public int getTaskTrackers()
public Collection<String> getActiveTrackerNames()
public Collection<String> getBlacklistedTrackerNames()
@Deprecated public Collection<String> getGraylistedTrackerNames()
@Deprecated public int getGraylistedTrackers()
public int getBlacklistedTrackers()
public int getNumExcludedNodes()
public long getTTExpiryInterval()
public int getMapTasks()
public int getReduceTasks()
public int getMaxMapTasks()
public int getMaxReduceTasks()
public Cluster.JobTrackerStatus getJobTrackerStatus()
Cluster.JobTrackerStatus
of the JobTracker@Deprecated public long getMaxMemory()
@Deprecated public long getUsedMemory()
public Collection<ClusterStatus.BlackListInfo> getBlackListedTrackersInfo()
ClusterStatus.BlackListInfo
objects.@Deprecated public JobTracker.State getJobTrackerState()
JobTracker
,
as JobTracker.State
JobTracker.State
should no longer be used on M/R 2.x. The function
is kept to be compatible with M/R 1.x applications.JobTracker
.public void write(DataOutput out) throws IOException
Writable
out
.write
in interface Writable
out
- DataOuput
to serialize this object into.IOException
public void readFields(DataInput in) throws IOException
Writable
in
.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
readFields
in interface Writable
in
- DataInput
to deseriablize this object from.IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.