public class ClusterMetrics
extends java.lang.Object
implements org.apache.hadoop.io.Writable
ClusterMetrics
provides clients with information such as:
Constructor and Description |
---|
ClusterMetrics() |
ClusterMetrics(int runningMaps,
int runningReduces,
int occupiedMapSlots,
int occupiedReduceSlots,
int reservedMapSlots,
int reservedReduceSlots,
int mapSlots,
int reduceSlots,
int totalJobSubmissions,
int numTrackers,
int numBlacklistedTrackers,
int numDecommissionedNodes) |
Modifier and Type | Method and Description |
---|---|
int |
getBlackListedTaskTrackerCount()
Get the number of blacklisted trackers in the cluster.
|
int |
getDecommissionedTaskTrackerCount()
Get the number of decommissioned trackers in the cluster.
|
int |
getMapSlotCapacity()
Get the total number of map slots in the cluster.
|
int |
getOccupiedMapSlots()
Get number of occupied map slots in the cluster.
|
int |
getOccupiedReduceSlots()
Get the number of occupied reduce slots in the cluster.
|
int |
getReduceSlotCapacity()
Get the total number of reduce slots in the cluster.
|
int |
getReservedMapSlots()
Get number of reserved map slots in the cluster.
|
int |
getReservedReduceSlots()
Get the number of reserved reduce slots in the cluster.
|
int |
getRunningMaps()
Get the number of running map tasks in the cluster.
|
int |
getRunningReduces()
Get the number of running reduce tasks in the cluster.
|
int |
getTaskTrackerCount()
Get the number of active trackers in the cluster.
|
int |
getTotalJobSubmissions()
Get the total number of job submissions in the cluster.
|
void |
readFields(java.io.DataInput in) |
void |
write(java.io.DataOutput out) |
public ClusterMetrics()
public ClusterMetrics(int runningMaps, int runningReduces, int occupiedMapSlots, int occupiedReduceSlots, int reservedMapSlots, int reservedReduceSlots, int mapSlots, int reduceSlots, int totalJobSubmissions, int numTrackers, int numBlacklistedTrackers, int numDecommissionedNodes)
public int getRunningMaps()
public int getRunningReduces()
public int getOccupiedMapSlots()
public int getOccupiedReduceSlots()
public int getReservedMapSlots()
public int getReservedReduceSlots()
public int getMapSlotCapacity()
public int getReduceSlotCapacity()
public int getTotalJobSubmissions()
public int getTaskTrackerCount()
public int getBlackListedTaskTrackerCount()
public int getDecommissionedTaskTrackerCount()
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface org.apache.hadoop.io.Writable
java.io.IOException
Copyright © 2009 The Apache Software Foundation