|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use TaskInProgress | |
---|---|
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. |
Uses of TaskInProgress in org.apache.hadoop.mapred |
---|
Methods in org.apache.hadoop.mapred that return TaskInProgress | |
---|---|
protected TaskInProgress |
JobInProgress.findSpeculativeTask(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. |
Methods in org.apache.hadoop.mapred that return types with arguments of type TaskInProgress | |
---|---|
Vector<TaskInProgress> |
JobInProgress.reportCleanupTIPs(boolean shouldBeComplete)
Return a vector of cleanup TaskInProgress objects |
Vector<TaskInProgress> |
JobInProgress.reportSetupTIPs(boolean shouldBeComplete)
Return a vector of setup TaskInProgress objects |
Vector<TaskInProgress> |
JobInProgress.reportTasksInProgress(boolean shouldBeMap,
boolean shouldBeComplete)
Return a vector of completed TaskInProgress objects |
Methods in org.apache.hadoop.mapred with parameters of type TaskInProgress | |
---|---|
boolean |
JobInProgress.completedTask(TaskInProgress tip,
TaskStatus status)
A taskid assigned to this JobInProgress has reported in successfully. |
void |
JobInProgress.failedTask(TaskInProgress tip,
TaskAttemptID taskid,
String reason,
TaskStatus.Phase phase,
TaskStatus.State state,
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. |
Method parameters in org.apache.hadoop.mapred with type arguments of type TaskInProgress | |
---|---|
protected TaskInProgress |
JobInProgress.findSpeculativeTask(Collection<TaskInProgress> list,
TaskTrackerStatus ttStatus,
double avgProgress,
long currentTime,
boolean shouldRemove)
Find a speculative task |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |