org.apache.hadoop.mapred

类 TaskCompletionEvent

java.lang.Object

org.apache.hadoop.mapred.TaskCompletionEvent

所有已实现的接口:

Writable

public class TaskCompletionEvent
extends Object
implements Writable

This is used to track task completion events on job tracker.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	TaskCompletionEvent.Status

字段概要

字段

限定符和类型	字段和说明
static TaskCompletionEvent[]	EMPTY_ARRAY

构造器概要

构造器

构造器和说明
TaskCompletionEvent() Default constructor for Writable.
TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, String taskTrackerHttp) Constructor. eventId should be created externally and incremented per event for each job.

方法概要

方法

限定符和类型	方法和说明
boolean	equals(Object o)
int	getEventId() Returns event Id.
TaskAttemptID	getTaskAttemptId() Returns task id.
String	getTaskId() 已过时。 use getTaskAttemptId() instead.
int	getTaskRunTime() Returns time (in millisec) the task took to complete.
TaskCompletionEvent.Status	getTaskStatus() Returns enum Status.SUCESS or Status.FAILURE.
String	getTaskTrackerHttp() http location of the tasktracker where this task ran.
int	hashCode()
int	idWithinJob()
boolean	isMapTask()
void	readFields(DataInput in) Deserialize the fields of this object from in.
void	setEventId(int eventId) set event Id. should be assigned incrementally starting from 0.
void	setTaskId(String taskId) 已过时。 use setTaskID(TaskAttemptID) instead.
void	setTaskID(TaskAttemptID taskId) Sets task id.
void	setTaskRunTime(int taskCompletionTime) Set the task completion time
void	setTaskStatus(TaskCompletionEvent.Status status) Set task status.
void	setTaskTrackerHttp(String taskTrackerHttp) Set task tracker http location.
String	toString()
void	write(DataOutput out) Serialize the fields of this object to out.

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

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

字段详细资料

EMPTY_ARRAY

public static final TaskCompletionEvent[] EMPTY_ARRAY

构造器详细资料

TaskCompletionEvent

public TaskCompletionEvent()

Default constructor for Writable.

TaskCompletionEvent

public TaskCompletionEvent(int eventId,
                   TaskAttemptID taskId,
                   int idWithinJob,
                   boolean isMap,
                   TaskCompletionEvent.Status status,
                   String taskTrackerHttp)

Constructor. eventId should be created externally and incremented per event for each job.

参数:

eventId - event id, event id should be unique and assigned in incrementally, starting from 0.

taskId - task id

status - task's status

taskTrackerHttp - task tracker's host:port for http.

方法详细资料

getEventId

public int getEventId()

Returns event Id.

返回:

event id

getTaskId

@Deprecated
public String getTaskId()

已过时。 use getTaskAttemptId() instead.

Returns task id.

返回:

task id

getTaskAttemptId

public TaskAttemptID getTaskAttemptId()

Returns task id.

返回:

task id

getTaskStatus

public TaskCompletionEvent.Status getTaskStatus()

Returns enum Status.SUCESS or Status.FAILURE.

返回:

task tracker status

getTaskTrackerHttp

public String getTaskTrackerHttp()

http location of the tasktracker where this task ran.

返回:

http location of tasktracker user logs

getTaskRunTime

public int getTaskRunTime()

Returns time (in millisec) the task took to complete.

setTaskRunTime

public void setTaskRunTime(int taskCompletionTime)

Set the task completion time

参数:

taskCompletionTime - time (in millisec) the task took to complete

setEventId

public void setEventId(int eventId)

set event Id. should be assigned incrementally starting from 0.

参数:

eventId -

setTaskId

@Deprecated
public void setTaskId(String taskId)

已过时。 use setTaskID(TaskAttemptID) instead.

Sets task id.

参数:

taskId -

setTaskID

public void setTaskID(TaskAttemptID taskId)

Sets task id.

参数:

taskId -

setTaskStatus

public void setTaskStatus(TaskCompletionEvent.Status status)

Set task status.

参数:

status -

setTaskTrackerHttp

public void setTaskTrackerHttp(String taskTrackerHttp)

Set task tracker http location.

参数:

taskTrackerHttp -

toString

public String toString()

覆盖:

toString 在类中 Object

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

isMapTask

public boolean isMapTask()

idWithinJob

public int idWithinJob()

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