|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapreduce.TaskCompletionEvent
@InterfaceAudience.Public @InterfaceStability.Evolving public class TaskCompletionEvent
This is used to track task completion events on job tracker.
Nested Class Summary | |
---|---|
static class |
TaskCompletionEvent.Status
|
Field Summary | |
---|---|
static TaskCompletionEvent[] |
EMPTY_ARRAY
|
Constructor Summary | |
---|---|
TaskCompletionEvent()
Default constructor for Writable. |
|
TaskCompletionEvent(int eventId,
TaskAttemptID taskId,
int idWithinJob,
boolean isMap,
TaskCompletionEvent.Status status,
String taskTrackerHttp)
Constructor. |
Method Summary | |
---|---|
boolean |
equals(Object o)
|
int |
getEventId()
Returns event Id. |
TaskCompletionEvent.Status |
getStatus()
Returns enum Status.SUCESS or Status.FAILURE. |
TaskAttemptID |
getTaskAttemptId()
Returns task id. |
int |
getTaskRunTime()
Returns time (in millisec) the task took to complete. |
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 . |
protected void |
setEventId(int eventId)
set event Id. |
protected void |
setTaskAttemptId(TaskAttemptID taskId)
Sets task id. |
protected void |
setTaskRunTime(int taskCompletionTime)
Set the task completion time |
protected void |
setTaskStatus(TaskCompletionEvent.Status status)
Set task status. |
protected void |
setTaskTrackerHttp(String taskTrackerHttp)
Set task tracker http location. |
String |
toString()
|
void |
write(DataOutput out)
Serialize the fields of this object to out . |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final TaskCompletionEvent[] EMPTY_ARRAY
Constructor Detail |
---|
public TaskCompletionEvent()
public TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, String taskTrackerHttp)
eventId
- event id, event id should be unique and assigned in
incrementally, starting from 0.taskId
- task idstatus
- task's statustaskTrackerHttp
- task tracker's host:port for http.Method Detail |
---|
public int getEventId()
public TaskAttemptID getTaskAttemptId()
public TaskCompletionEvent.Status getStatus()
public String getTaskTrackerHttp()
public int getTaskRunTime()
protected void setTaskRunTime(int taskCompletionTime)
taskCompletionTime
- time (in millisec) the task took to completeprotected void setEventId(int eventId)
eventId
- protected void setTaskAttemptId(TaskAttemptID taskId)
taskId
- protected void setTaskStatus(TaskCompletionEvent.Status status)
status
- protected void setTaskTrackerHttp(String taskTrackerHttp)
taskTrackerHttp
- public String toString()
toString
in class Object
public boolean equals(Object o)
equals
in class Object
public int hashCode()
hashCode
in class Object
public boolean isMapTask()
public int idWithinJob()
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 |