|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.TaskTrackerStatus
public class TaskTrackerStatus
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!
Field Summary | |
---|---|
static org.apache.commons.logging.Log |
LOG
|
static int |
UNAVAILABLE
|
Constructor Summary | |
---|---|
TaskTrackerStatus()
|
|
TaskTrackerStatus(String trackerName,
String host,
int httpPort,
List<TaskStatus> taskReports,
int taskFailures,
int dirFailures,
int maxMapTasks,
int maxReduceTasks)
|
Method Summary | |
---|---|
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 . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
public static final int UNAVAILABLE
Constructor Detail |
---|
public TaskTrackerStatus()
public TaskTrackerStatus(String trackerName, String host, int httpPort, List<TaskStatus> taskReports, int taskFailures, int dirFailures, int maxMapTasks, int maxReduceTasks)
Method Detail |
---|
public String getTrackerName()
public String getHost()
public int getHttpPort()
public int getTaskFailures()
public int getDirFailures()
public List<TaskStatus> getTaskReports()
TaskStatus
object.
TaskStatus
representing
the current tasks at the TaskTracker.public int countMapTasks()
public int countOccupiedMapSlots()
public int getAvailableMapSlots()
public int countReduceTasks()
public int countOccupiedReduceSlots()
public int getAvailableReduceSlots()
public long getLastSeen()
public void setLastSeen(long lastSeen)
public int getMaxMapSlots()
public int getMaxReduceSlots()
public org.apache.hadoop.mapred.TaskTrackerStatus.TaskTrackerHealthStatus getHealthStatus()
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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |