Package org.apache.hadoop.mapreduce.v2.app.speculate

Interface Speculator

All Superinterfaces:

org.apache.hadoop.yarn.event.EventHandler<SpeculatorEvent>

All Known Implementing Classes:

DefaultSpeculator

public interface Speculator
extends org.apache.hadoop.yarn.event.EventHandler<SpeculatorEvent>

Speculator component. Task Attempts' status updates are sent to this component. Concrete implementation runs the speculative algorithm and sends the TaskEventType.T_ADD_ATTEMPT. An implementation also has to arrange for the jobs to be scanned from time to time, to launch the speculations.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	Speculator.EventType

Method Summary

Modifier and Type	Method	Description
void	handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status)

Methods inherited from interface org.apache.hadoop.yarn.event.EventHandler

handle

Method Details

handleAttempt

void handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status)