public class TaskTrackerStatus
extends java.lang.Object
implements org.apache.hadoop.io.Writable
Modifier and Type | Class and Description |
---|---|
static class |
TaskTrackerStatus.ResourceStatus
Class representing a collection of resources on this tasktracker.
|
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
static int |
UNAVAILABLE |
Constructor and Description |
---|
TaskTrackerStatus() |
TaskTrackerStatus(java.lang.String trackerName,
java.lang.String urlScheme,
java.lang.String host,
int httpPort,
java.util.List<TaskStatus> taskReports,
int taskFailures,
int dirFailures,
int maxMapTasks,
int maxReduceTasks) |
Modifier and Type | Method and Description |
---|---|
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.
|
int |
getFailures()
Get the number of tasks that have failed on this tracker.
|
org.apache.hadoop.mapred.TaskTrackerStatus.TaskTrackerHealthStatus |
getHealthStatus()
Returns health status of the task tracker.
|
java.lang.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.
|
TaskTrackerStatus.ResourceStatus |
getResourceStatus()
Return the
TaskTrackerStatus.ResourceStatus object configured with this
status. |
java.util.List<TaskStatus> |
getTaskReports()
Get the current tasks at the TaskTracker.
|
java.lang.String |
getTrackerName() |
java.lang.String |
getUrlScheme() |
void |
readFields(java.io.DataInput in) |
void |
setLastSeen(long lastSeen) |
void |
write(java.io.DataOutput out) |
public static final org.apache.commons.logging.Log LOG
public static final int UNAVAILABLE
public TaskTrackerStatus()
public TaskTrackerStatus(java.lang.String trackerName, java.lang.String urlScheme, java.lang.String host, int httpPort, java.util.List<TaskStatus> taskReports, int taskFailures, int dirFailures, int maxMapTasks, int maxReduceTasks)
public java.lang.String getTrackerName()
public java.lang.String getUrlScheme()
public java.lang.String getHost()
public int getHttpPort()
public int getFailures()
public int getDirFailures()
public java.util.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 TaskTrackerStatus.ResourceStatus getResourceStatus()
TaskTrackerStatus.ResourceStatus
object configured with this
status.public org.apache.hadoop.mapred.TaskTrackerStatus.TaskTrackerHealthStatus getHealthStatus()
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface org.apache.hadoop.io.Writable
java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
java.io.IOException
Copyright © 2009 The Apache Software Foundation