|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.mapred.ClusterStatus
public class ClusterStatus
Status information on the current state of the Map-Reduce cluster.
ClusterStatus provides clients with information such as:
JobTracker.
Clients can query for the latest ClusterStatus, via
JobClient.getClusterStatus().
JobClient| Field Summary | |
|---|---|
static long |
UNINITIALIZED_MEMORY_VALUE
|
| Method Summary | |
|---|---|
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()
Get the maximum configured heap memory that can be used by the JobTracker |
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()
Get the total heap memory used by the JobTracker |
void |
readFields(DataInput in)
Deserialize the fields of this object from in. |
void |
write(DataOutput out)
Serialize the fields of this object to out. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final long UNINITIALIZED_MEMORY_VALUE
| Method Detail |
|---|
public int getTaskTrackers()
public Collection<String> getActiveTrackerNames()
public Collection<String> getBlacklistedTrackerNames()
public int getBlacklistedTrackers()
public Collection<String> getGraylistedTrackerNames()
public int getGraylistedTrackers()
public int getNumExcludedNodes()
public long getTTExpiryInterval()
public int getMapTasks()
public int getReduceTasks()
public int getMaxMapTasks()
public int getMaxReduceTasks()
public JobTracker.State getJobTrackerState()
JobTracker,
as JobTracker.State
JobTracker.public long getUsedMemory()
JobTracker
JobTrackerpublic long getMaxMemory()
JobTracker
JobTracker
public void write(DataOutput out)
throws IOException
Writableout.
write in interface Writableout - DataOuput to serialize this object into.
IOException
public void readFields(DataInput in)
throws IOException
Writablein.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
readFields in interface Writablein - DataInput to deseriablize this object from.
IOException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||