@InterfaceAudience.Private
public interface TaskUmbilicalProtocol
extends org.apache.hadoop.ipc.VersionedProtocol
Modifier and Type | Field and Description |
---|---|
static long |
versionID
Changed the version to 2, since we have a new method getMapOutputs
Changed version to 3 to have progress() return a boolean
Changed the version to 4, since we have replaced
TaskUmbilicalProtocol.progress(String, float, String,
org.apache.hadoop.mapred.TaskStatus.Phase, Counters)
with statusUpdate(String, TaskStatus)
Version 5 changed counters representation for HADOOP-2248
Version 6 changes the TaskStatus representation for HADOOP-2208
Version 7 changes the done api (via HADOOP-3140).
|
Modifier and Type | Method and Description |
---|---|
boolean |
canCommit(TaskAttemptID taskid,
org.apache.hadoop.mapred.JvmContext jvmContext)
Polling to know whether the task can go-ahead with commit
|
void |
commitPending(TaskAttemptID taskId,
TaskStatus taskStatus,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report that the task is complete, but its commit is pending.
|
void |
done(TaskAttemptID taskid,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report that the task is successfully completed.
|
void |
fatalError(TaskAttemptID taskId,
java.lang.String message,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report that the task encounted a fatal error.
|
void |
fsError(TaskAttemptID taskId,
java.lang.String message,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report that the task encounted a local filesystem error.
|
MapTaskCompletionEventsUpdate |
getMapCompletionEvents(JobID jobId,
int fromIndex,
int maxLocs,
TaskAttemptID id,
org.apache.hadoop.mapred.JvmContext jvmContext)
Called by a reduce task to get the map output locations for finished maps.
|
JvmTask |
getTask(org.apache.hadoop.mapred.JvmContext context)
Called when a child task process starts, to get its task.
|
boolean |
ping(TaskAttemptID taskid,
org.apache.hadoop.mapred.JvmContext jvmContext)
Periodically called by child to check if parent is still alive.
|
void |
reportDiagnosticInfo(TaskAttemptID taskid,
java.lang.String trace,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report error messages back to parent.
|
void |
reportNextRecordRange(TaskAttemptID taskid,
org.apache.hadoop.mapred.SortedRanges.Range range,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report the record range which is going to process next by the Task.
|
void |
shuffleError(TaskAttemptID taskId,
java.lang.String message,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report that a reduce-task couldn't shuffle map-outputs.
|
boolean |
statusUpdate(TaskAttemptID taskId,
TaskStatus taskStatus,
org.apache.hadoop.mapred.JvmContext jvmContext)
Report child's progress to parent.
|
void |
updatePrivateDistributedCacheSizes(JobID jobId,
long[] sizes)
The job initializer needs to report the sizes of the archive
objects and directories in the private distributed cache.
|
static final long versionID
JvmTask getTask(org.apache.hadoop.mapred.JvmContext context) throws java.io.IOException
context
- the JvmContext of the JVM w.r.t the TaskTracker that
launched itjava.io.IOException
boolean statusUpdate(TaskAttemptID taskId, TaskStatus taskStatus, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException, java.lang.InterruptedException
taskId
- task-id of the childtaskStatus
- status of the childjvmContext
- context the jvmContext running the task.java.io.IOException
java.lang.InterruptedException
void reportDiagnosticInfo(TaskAttemptID taskid, java.lang.String trace, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
taskid
- the id of the task involvedtrace
- the text to reportjvmContext
- context the jvmContext running the task.java.io.IOException
void reportNextRecordRange(TaskAttemptID taskid, org.apache.hadoop.mapred.SortedRanges.Range range, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
taskid
- the id of the task involvedrange
- the range of record sequence nosjvmContext
- context the jvmContext running the task.java.io.IOException
boolean ping(TaskAttemptID taskid, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
taskid
- the id of the task involvedjvmContext
- context the jvmContext running the task.java.io.IOException
void done(TaskAttemptID taskid, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
taskid
- task's idjvmContext
- context the jvmContext running the task.java.io.IOException
void commitPending(TaskAttemptID taskId, TaskStatus taskStatus, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException, java.lang.InterruptedException
taskId
- task's idtaskStatus
- status of the childjvmContext
- context the jvmContext running the task.java.io.IOException
java.lang.InterruptedException
boolean canCommit(TaskAttemptID taskid, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
taskid
- jvmContext
- context the jvmContext running the task.java.io.IOException
void shuffleError(TaskAttemptID taskId, java.lang.String message, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
java.io.IOException
void fsError(TaskAttemptID taskId, java.lang.String message, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
java.io.IOException
void fatalError(TaskAttemptID taskId, java.lang.String message, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
java.io.IOException
MapTaskCompletionEventsUpdate getMapCompletionEvents(JobID jobId, int fromIndex, int maxLocs, TaskAttemptID id, org.apache.hadoop.mapred.JvmContext jvmContext) throws java.io.IOException
jobId
- the reducer job idfromIndex
- the index starting from which the locations should be
fetchedmaxLocs
- the max number of locations to fetchid
- The attempt id of the task that is trying to communicateMapTaskCompletionEventsUpdate
java.io.IOException
void updatePrivateDistributedCacheSizes(JobID jobId, long[] sizes) throws java.io.IOException
jobId
- the job to updatesizes
- the array of sizes that were computedjava.io.IOException
Copyright © 2009 The Apache Software Foundation