Package | Description |
---|---|
org.apache.hadoop.mapred | |
org.apache.hadoop.mapreduce | |
org.apache.hadoop.mapreduce.tools |
Modifier and Type | Class and Description |
---|---|
class |
TaskAttemptID
TaskAttemptID represents the immutable and unique identifier for
a task attempt.
|
Modifier and Type | Method and Description |
---|---|
static TaskAttemptID |
TaskAttemptID.downgrade(TaskAttemptID old)
Downgrade a new TaskAttemptID to an old one
|
Modifier and Type | Method and Description |
---|---|
static TaskAttemptID |
TaskAttemptID.forName(String str)
Construct a TaskAttemptID object from given string
|
TaskAttemptID |
TaskCompletionEvent.getTaskAttemptId()
Returns task id.
|
TaskAttemptID |
TaskAttemptContext.getTaskAttemptID()
Get the unique name for this task attempt.
|
Modifier and Type | Method and Description |
---|---|
void |
Job.failTask(TaskAttemptID taskId)
Fail indicated task attempt.
|
org.apache.hadoop.mapreduce.v2.LogParams |
Cluster.getLogParams(JobID jobID,
TaskAttemptID taskAttemptID)
Get log parameters for the specified jobID or taskAttemptID
|
String[] |
Job.getTaskDiagnostics(TaskAttemptID taskid)
Gets the diagnostic messages for a given task attempt.
|
void |
Job.killTask(TaskAttemptID taskId)
Kill indicated task attempt.
|
protected void |
TaskCompletionEvent.setTaskAttemptId(TaskAttemptID taskId)
Sets task id.
|
Constructor and Description |
---|
TaskCompletionEvent(int eventId,
TaskAttemptID taskId,
int idWithinJob,
boolean isMap,
TaskCompletionEvent.Status status,
String taskTrackerHttp)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected static String |
CLI.getTaskLogURL(TaskAttemptID taskId,
String baseUrl) |
Copyright © 2018 Apache Software Foundation. All rights reserved.