@InterfaceAudience.Public @InterfaceStability.Stable public class TaskID extends TaskID
JobID
, that this
TaskInProgress belongs to. Second part of the TaskID is either 'm' or 'r'
representing whether the task is a map task or a reduce task.
And the third part is the task number. task_200707121733_0003_m_000005
, which represents the
fifth map task in the third job running at the jobtracker
started at 200707121733
.
Applications should never construct or parse TaskID strings
, but rather use appropriate constructors or forName(String)
method.
JobID
,
TaskAttemptID
idFormat, TASK, TASK_ID_REGEX, taskIdPattern
Constructor and Description |
---|
TaskID() |
TaskID(JobID jobId,
boolean isMap,
int id)
Deprecated.
|
TaskID(JobID jobId,
TaskType type,
int id)
Constructs a TaskID object from given
JobID . |
TaskID(String jtIdentifier,
int jobId,
boolean isMap,
int id)
Deprecated.
|
TaskID(String jtIdentifier,
int jobId,
TaskType type,
int id)
Constructs a TaskInProgressId object from given parts.
|
Modifier and Type | Method and Description |
---|---|
static TaskID |
downgrade(TaskID old)
Downgrade a new TaskID to an old one
|
static TaskID |
forName(String str) |
JobID |
getJobID()
Returns the
JobID object that this tip belongs to. |
static String |
getTaskIDsPattern(String jtIdentifier,
Integer jobId,
Boolean isMap,
Integer taskId)
Deprecated.
|
static String |
getTaskIDsPattern(String jtIdentifier,
Integer jobId,
TaskType type,
Integer taskId)
Deprecated.
|
static TaskID |
read(DataInput in)
Deprecated.
|
appendTo, compareTo, equals, getAllTaskTypes, getRepresentingCharacter, getTaskType, getTaskType, hashCode, isMap, readFields, toString, write
@Deprecated public TaskID(JobID jobId, boolean isMap, int id)
TaskID(String, int, TaskType, int)
JobID
.jobId
- JobID that this tip belongs toisMap
- whether the tip is a mapid
- the tip number@Deprecated public TaskID(String jtIdentifier, int jobId, boolean isMap, int id)
TaskID(org.apache.hadoop.mapreduce.JobID, TaskType,
int)
jtIdentifier
- jobTracker identifierjobId
- job numberisMap
- whether the tip is a mapid
- the tip numberpublic TaskID(JobID jobId, TaskType type, int id)
JobID
.jobId
- JobID that this tip belongs totype
- the TaskType
id
- the tip numberpublic TaskID(String jtIdentifier, int jobId, TaskType type, int id)
jtIdentifier
- jobTracker identifierjobId
- job numbertype
- the TaskType
id
- the tip numberpublic TaskID()
public static TaskID downgrade(TaskID old)
old
- a new or old TaskID@Deprecated public static TaskID read(DataInput in) throws IOException
IOException
public JobID getJobID()
TaskID
JobID
object that this tip belongs to.@Deprecated public static String getTaskIDsPattern(String jtIdentifier, Integer jobId, Boolean isMap, Integer taskId)
getTaskIDsPattern(String, Integer, TaskType,
Integer)
TaskID.getTaskIDsPattern(null, null, true, 1);which will return :
"task_[^_]*_[0-9]*_m_000001*"
jtIdentifier
- jobTracker identifier, or nulljobId
- job number, or nullisMap
- whether the tip is a map, or nulltaskId
- taskId number, or null@Deprecated public static String getTaskIDsPattern(String jtIdentifier, Integer jobId, TaskType type, Integer taskId)
TaskID.getTaskIDsPattern(null, null, true, 1);which will return :
"task_[^_]*_[0-9]*_m_000001*"
jtIdentifier
- jobTracker identifier, or nulljobId
- job number, or nulltype
- the TaskType
, or nulltaskId
- taskId number, or nullpublic static TaskID forName(String str) throws IllegalArgumentException
IllegalArgumentException
Copyright © 2019 Apache Software Foundation. All rights reserved.