Package | Description |
---|---|
org.apache.hadoop.mapred |
Modifier and Type | Method and Description |
---|---|
static TaskAttemptID |
TaskAttemptID.downgrade(TaskAttemptID old)
Downgrade a new TaskAttemptID to an old one
|
static TaskAttemptID |
TaskAttemptID.forName(String str)
Construct a TaskAttemptID object from given string
|
TaskAttemptID |
TaskReport.getSuccessfulTaskAttempt()
Get the attempt ID that took this task to completion
|
TaskAttemptID |
TaskCompletionEvent.getTaskAttemptId()
Returns task id.
|
TaskAttemptID |
TaskAttemptContext.getTaskAttemptID() |
static TaskAttemptID |
TaskAttemptID.read(DataInput in)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Collection<TaskAttemptID> |
TaskReport.getRunningTaskAttempts()
Get the running task attempt IDs for this task
|
Modifier and Type | Method and Description |
---|---|
String[] |
RunningJob.getTaskDiagnostics(TaskAttemptID taskid)
Gets the diagnostic messages for a given task attempt.
|
void |
RunningJob.killTask(TaskAttemptID taskId,
boolean shouldFail)
Kill indicated task attempt.
|
void |
TaskReport.setSuccessfulAttempt(TaskAttemptID t)
set successful attempt ID of the task.
|
protected void |
TaskCompletionEvent.setTaskAttemptId(TaskAttemptID taskId)
Sets task id.
|
void |
TaskCompletionEvent.setTaskID(TaskAttemptID taskId)
Deprecated.
use
TaskCompletionEvent.setTaskAttemptId(TaskAttemptID) instead. |
Modifier and Type | Method and Description |
---|---|
void |
TaskReport.setRunningTaskAttempts(Collection<TaskAttemptID> runningAttempts)
set running attempt(s) of the task.
|
Constructor and Description |
---|
TaskCompletionEvent(int eventId,
TaskAttemptID taskId,
int idWithinJob,
boolean isMap,
TaskCompletionEvent.Status status,
String taskTrackerHttp)
Constructor.
|
Copyright © 2019 Apache Software Foundation. All rights reserved.