public class HadoopTaskInfo extends Object implements Externalizable
| Constructor and Description |
|---|
HadoopTaskInfo()
For
Externalizable. |
HadoopTaskInfo(HadoopTaskType type,
HadoopJobId jobId,
int taskNum,
int attempt,
HadoopInputSplit inputSplit)
Creates new task info.
|
| Modifier and Type | Method and Description |
|---|---|
int |
attempt() |
boolean |
equals(Object o) |
int |
hashCode() |
HadoopInputSplit |
inputSplit() |
HadoopJobId |
jobId() |
void |
readExternal(ObjectInput in) |
int |
taskNumber() |
String |
toString() |
HadoopTaskType |
type() |
void |
writeExternal(ObjectOutput out) |
public HadoopTaskInfo()
Externalizable.public HadoopTaskInfo(HadoopTaskType type, HadoopJobId jobId, int taskNum, int attempt, @Nullable HadoopInputSplit inputSplit)
type - Task type.jobId - Job id.taskNum - Task number.attempt - Attempt for this task.inputSplit - Input split.public void writeExternal(ObjectOutput out) throws IOException
writeExternal in interface ExternalizableIOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizableIOExceptionClassNotFoundExceptionpublic HadoopTaskType type()
public HadoopJobId jobId()
public int taskNumber()
public int attempt()
@Nullable public HadoopInputSplit inputSplit()
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015