org.apache.hadoop.mapred

类 TaskStatus

java.lang.Object

org.apache.hadoop.mapred.TaskStatus

所有已实现的接口:

Cloneable, Writable

public abstract class TaskStatus
extends Object
implements Writable, Cloneable

Describes the current status of a task. This is not intended to be a comprehensive piece of data.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	TaskStatus.Phase
static class	TaskStatus.State

构造器概要

构造器

构造器和说明
TaskStatus()
TaskStatus(TaskAttemptID taskid, float progress, int numSlots, TaskStatus.State runState, String diagnosticInfo, String stateString, String taskTracker, TaskStatus.Phase phase, Counters counters)

方法概要

方法

限定符和类型	方法和说明
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. if shuffleFinishTime and sortFinishTime are not set before, these are set to finishTime.
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.

从类继承的方法 java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TaskStatus

public TaskStatus()

TaskStatus

public TaskStatus(TaskAttemptID taskid,
          float progress,
          int numSlots,
          TaskStatus.State runState,
          String diagnosticInfo,
          String stateString,
          String taskTracker,
          TaskStatus.Phase phase,
          Counters counters)

方法详细资料

getTaskID

public TaskAttemptID getTaskID()

getIsMap

public abstract boolean getIsMap()

getNumSlots

public int getNumSlots()

getProgress

public float getProgress()

setProgress

public void setProgress(float progress)

getRunState

public TaskStatus.State getRunState()

getTaskTracker

public String getTaskTracker()

setTaskTracker

public void setTaskTracker(String tracker)

setRunState

public void setRunState(TaskStatus.State runState)

getDiagnosticInfo

public String getDiagnosticInfo()

setDiagnosticInfo

public void setDiagnosticInfo(String info)

getStateString

public String getStateString()

setStateString

public void setStateString(String stateString)

getNextRecordRange

public org.apache.hadoop.mapred.SortedRanges.Range getNextRecordRange()

Get the next record range which is going to be processed by Task.

返回:

nextRecordRange

setNextRecordRange

public void setNextRecordRange(org.apache.hadoop.mapred.SortedRanges.Range nextRecordRange)

Set the next record range which is going to be processed by Task.

参数:

nextRecordRange -

getFinishTime

public long getFinishTime()

Get task finish time. if shuffleFinishTime and sortFinishTime are not set before, these are set to finishTime. It takes care of the case when shuffle, sort and finish are completed with in the heartbeat interval and are not reported separately. if task state is TaskStatus.FAILED then finish time represents when the task failed.

返回:

finish time of the task.

getShuffleFinishTime

public long getShuffleFinishTime()

Get shuffle finish time for the task. If shuffle finish time was not set due to shuffle/sort/finish phases ending within same heartbeat interval, it is set to finish time of next phase i.e. sort or task finish when these are set.

返回:

0 if shuffleFinishTime, sortFinishTime and finish time are not set. else it returns approximate shuffle finish time.

getSortFinishTime

public long getSortFinishTime()

Get sort finish time for the task,. If sort finish time was not set due to sort and reduce phase finishing in same heartebat interval, it is set to finish time, when finish time is set.

返回:

0 if sort finish time and finish time are not set, else returns sort finish time if that is set, else it returns finish time.

getStartTime

public long getStartTime()

Get start time of the task.

返回:

0 is start time is not set, else returns start time.

getPhase

public TaskStatus.Phase getPhase()

Get current phase of this task. Phase.Map in case of map tasks, for reduce one of Phase.SHUFFLE, Phase.SORT or Phase.REDUCE.

返回:

.

getIncludeCounters

public boolean getIncludeCounters()

setIncludeCounters

public void setIncludeCounters(boolean send)

getCounters

public Counters getCounters()

Get task's counters.

setCounters

public void setCounters(Counters counters)

Set the task's counters.

参数:

counters -

getOutputSize

public long getOutputSize()

Returns the number of bytes of output from this map.

getFetchFailedMaps

public List<TaskAttemptID> getFetchFailedMaps()

Get the list of maps from which output-fetches failed.

返回:

the list of maps from which output-fetches failed.

clone

public Object clone()

覆盖:

clone 在类中 Object

write

public void write(DataOutput out)
           throws IOException

从接口复制的说明: Writable

Serialize the fields of this object to out.

指定者:

write 在接口中 Writable

参数:

out - DataOuput to serialize this object into.

抛出:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

从接口复制的说明: Writable

Deserialize the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

指定者:

readFields 在接口中 Writable

参数:

in - DataInput to deseriablize this object from.

抛出:

IOException