public class TaskCompletionEvent
extends java.lang.Object
implements org.apache.hadoop.io.Writable
Modifier and Type | Class and Description |
---|---|
static class |
TaskCompletionEvent.Status |
Modifier and Type | Field and Description |
---|---|
static TaskCompletionEvent[] |
EMPTY_ARRAY |
Constructor and Description |
---|
TaskCompletionEvent()
Default constructor for Writable.
|
TaskCompletionEvent(int eventId,
TaskAttemptID taskId,
int idWithinJob,
boolean isMap,
TaskCompletionEvent.Status status,
java.lang.String taskTrackerHttp)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
int |
getEventId()
Returns event Id.
|
TaskAttemptID |
getTaskAttemptId()
Returns task id.
|
java.lang.String |
getTaskId()
Deprecated.
use
getTaskAttemptId() instead. |
int |
getTaskRunTime()
Returns time (in millisec) the task took to complete.
|
TaskCompletionEvent.Status |
getTaskStatus()
Returns enum Status.SUCESS or Status.FAILURE.
|
java.lang.String |
getTaskTrackerHttp()
http location of the tasktracker where this task ran.
|
int |
hashCode() |
int |
idWithinJob() |
boolean |
isMapTask() |
void |
readFields(java.io.DataInput in) |
void |
setEventId(int eventId)
set event Id.
|
void |
setTaskId(java.lang.String taskId)
Deprecated.
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(java.lang.String taskTrackerHttp)
Set task tracker http location.
|
java.lang.String |
toString() |
void |
write(java.io.DataOutput out) |
public static final TaskCompletionEvent[] EMPTY_ARRAY
public TaskCompletionEvent()
public TaskCompletionEvent(int eventId, TaskAttemptID taskId, int idWithinJob, boolean isMap, TaskCompletionEvent.Status status, java.lang.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.public int getEventId()
@Deprecated public java.lang.String getTaskId()
getTaskAttemptId()
instead.public TaskAttemptID getTaskAttemptId()
public TaskCompletionEvent.Status getTaskStatus()
public java.lang.String getTaskTrackerHttp()
public int getTaskRunTime()
public void setTaskRunTime(int taskCompletionTime)
taskCompletionTime
- time (in millisec) the task took to completepublic void setEventId(int eventId)
eventId
- @Deprecated public void setTaskId(java.lang.String taskId)
setTaskID(TaskAttemptID)
instead.taskId
- public void setTaskID(TaskAttemptID taskId)
taskId
- public void setTaskStatus(TaskCompletionEvent.Status status)
status
- public void setTaskTrackerHttp(java.lang.String taskTrackerHttp)
taskTrackerHttp
- public java.lang.String toString()
toString
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public boolean isMapTask()
public int idWithinJob()
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