Package | Description |
---|---|
org.apache.hadoop.mapred |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
Modifier and Type | Method and Description |
---|---|
protected TaskInProgress |
JobInProgress.findSpeculativeTask(java.util.Collection<TaskInProgress> list,
TaskTrackerStatus ttStatus,
double avgProgress,
long currentTime,
boolean shouldRemove)
Find a speculative task
|
TaskInProgress |
JobInProgress.getTaskInProgress(TaskID tipid)
Return the TaskInProgress that matches the tipid.
|
TaskInProgress |
JobTracker.getTip(TaskID tipid)
Returns specified TaskInProgress, or null.
|
Modifier and Type | Method and Description |
---|---|
java.util.Vector<TaskInProgress> |
JobInProgress.reportCleanupTIPs(boolean shouldBeComplete)
Return a vector of cleanup TaskInProgress objects
|
java.util.Vector<TaskInProgress> |
JobInProgress.reportSetupTIPs(boolean shouldBeComplete)
Return a vector of setup TaskInProgress objects
|
java.util.Vector<TaskInProgress> |
JobInProgress.reportTasksInProgress(boolean shouldBeMap,
boolean shouldBeComplete)
Return a vector of completed TaskInProgress objects
|
Modifier and Type | Method and Description |
---|---|
boolean |
JobInProgress.completedTask(TaskInProgress tip,
TaskStatus status)
A taskid assigned to this JobInProgress has reported in successfully.
|
void |
JobInProgress.failedTask(TaskInProgress tip,
TaskAttemptID taskid,
java.lang.String reason,
TaskStatus.Phase phase,
TaskStatus.State state,
java.lang.String trackerName)
Fail a task with a given reason, but without a status object.
|
protected void |
JobInProgress.scheduleMap(TaskInProgress tip)
Adds a map tip to the list of running maps.
|
protected void |
JobInProgress.scheduleReduce(TaskInProgress tip)
Adds a reduce tip to the list of running reduces
|
void |
JobInProgress.updateTaskStatus(TaskInProgress tip,
TaskStatus status)
Assuming
JobTracker is locked on entry. |
Modifier and Type | Method and Description |
---|---|
protected TaskInProgress |
JobInProgress.findSpeculativeTask(java.util.Collection<TaskInProgress> list,
TaskTrackerStatus ttStatus,
double avgProgress,
long currentTime,
boolean shouldRemove)
Find a speculative task
|
Copyright © 2009 The Apache Software Foundation