|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.TaskStatus
public abstract class TaskStatus
Describes the current status of a task. This is not intended to be a comprehensive piece of data.
Nested Class Summary | |
---|---|
static class |
TaskStatus.Phase
|
static class |
TaskStatus.State
|
Constructor Summary | |
---|---|
TaskStatus()
|
|
TaskStatus(TaskAttemptID taskid,
float progress,
int numSlots,
TaskStatus.State runState,
String diagnosticInfo,
String stateString,
String taskTracker,
TaskStatus.Phase phase,
Counters counters)
|
Method Summary | |
---|---|
Object |
clone()
|
Counters |
getCounters()
Get task's counters. |
String |
getDiagnosticInfo()
|
List<TaskAttemptID> |
getFetchFailedMaps()
Get the list of maps from which output-fetches failed. |
long |
getFinishTime()
Get task finish time. |
boolean |
getIncludeCounters()
|
abstract boolean |
getIsMap()
|
org.apache.hadoop.mapred.SortedRanges.Range |
getNextRecordRange()
Get the next record range which is going to be processed by Task. |
int |
getNumSlots()
|
long |
getOutputSize()
Returns the number of bytes of output from this map. |
TaskStatus.Phase |
getPhase()
Get current phase of this task. |
float |
getProgress()
|
TaskStatus.State |
getRunState()
|
long |
getShuffleFinishTime()
Get shuffle finish time for the task. |
long |
getSortFinishTime()
Get sort finish time for the task,. |
long |
getStartTime()
Get start time of the task. |
String |
getStateString()
|
TaskAttemptID |
getTaskID()
|
String |
getTaskTracker()
|
void |
readFields(DataInput in)
Deserialize the fields of this object from in . |
void |
setCounters(Counters counters)
Set the task's counters. |
void |
setDiagnosticInfo(String info)
|
void |
setIncludeCounters(boolean send)
|
void |
setNextRecordRange(org.apache.hadoop.mapred.SortedRanges.Range nextRecordRange)
Set the next record range which is going to be processed by Task. |
void |
setProgress(float progress)
|
void |
setRunState(TaskStatus.State runState)
|
void |
setStateString(String stateString)
|
void |
setTaskTracker(String tracker)
|
void |
write(DataOutput out)
Serialize the fields of this object to out . |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TaskStatus()
public TaskStatus(TaskAttemptID taskid, float progress, int numSlots, TaskStatus.State runState, String diagnosticInfo, String stateString, String taskTracker, TaskStatus.Phase phase, Counters counters)
Method Detail |
---|
public TaskAttemptID getTaskID()
public abstract boolean getIsMap()
public int getNumSlots()
public float getProgress()
public void setProgress(float progress)
public TaskStatus.State getRunState()
public String getTaskTracker()
public void setTaskTracker(String tracker)
public void setRunState(TaskStatus.State runState)
public String getDiagnosticInfo()
public void setDiagnosticInfo(String info)
public String getStateString()
public void setStateString(String stateString)
public org.apache.hadoop.mapred.SortedRanges.Range getNextRecordRange()
public void setNextRecordRange(org.apache.hadoop.mapred.SortedRanges.Range nextRecordRange)
nextRecordRange
- public long getFinishTime()
public long getShuffleFinishTime()
public long getSortFinishTime()
public long getStartTime()
public TaskStatus.Phase getPhase()
public boolean getIncludeCounters()
public void setIncludeCounters(boolean send)
public Counters getCounters()
public void setCounters(Counters counters)
counters
- public long getOutputSize()
public List<TaskAttemptID> getFetchFailedMaps()
public Object clone()
clone
in class Object
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 |