@InterfaceAudience.Public @InterfaceStability.Stable public class TaskCompletionEvent extends TaskCompletionEvent
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,
String taskTrackerHttp)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
TaskAttemptID |
getTaskAttemptId()
Returns task id.
|
String |
getTaskId()
Deprecated.
use
getTaskAttemptId() instead. |
TaskCompletionEvent.Status |
getTaskStatus()
Returns
TaskCompletionEvent.Status |
protected void |
setTaskAttemptId(TaskAttemptID taskId)
Sets task id.
|
void |
setTaskId(String taskId)
Deprecated.
use
setTaskAttemptId(TaskAttemptID) instead. |
void |
setTaskID(TaskAttemptID taskId)
Deprecated.
use
setTaskAttemptId(TaskAttemptID) instead. |
equals, getEventId, getStatus, getTaskRunTime, getTaskTrackerHttp, hashCode, idWithinJob, isMapTask, readFields, setTaskAttemptId, setTaskStatus, toString, write
public static final TaskCompletionEvent[] EMPTY_ARRAY
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.@Deprecated public String getTaskId()
getTaskAttemptId()
instead.public TaskAttemptID getTaskAttemptId()
getTaskAttemptId
in class TaskCompletionEvent
public TaskCompletionEvent.Status getTaskStatus()
TaskCompletionEvent.Status
@Deprecated public void setTaskId(String taskId)
setTaskAttemptId(TaskAttemptID)
instead.taskId
- @Deprecated public void setTaskID(TaskAttemptID taskId)
setTaskAttemptId(TaskAttemptID)
instead.taskId
- protected void setTaskAttemptId(TaskAttemptID taskId)
taskId
- Copyright © 2015 Apache Software Foundation. All rights reserved.