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

Class SpeculatorEvent

java.lang.Object

org.apache.hadoop.yarn.event.AbstractEvent<Speculator.EventType>

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

All Implemented Interfaces:

Event<Speculator.EventType>

public class SpeculatorEvent
extends AbstractEvent<Speculator.EventType>

Constructor Summary

Constructors

Constructor and Description
SpeculatorEvent(JobId jobID, long timestamp)
SpeculatorEvent(TaskAttemptId attemptID, boolean flag, long timestamp)
SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus, long timestamp)
SpeculatorEvent(TaskId taskID, int containersNeededChange)

Method Summary

Methods

Modifier and Type	Method and Description
int	containersNeededChange()
JobId	getJobID()
TaskAttemptStatusUpdateEvent.TaskAttemptStatus	getReportedStatus()
TaskId	getTaskID()

Methods inherited from class org.apache.hadoop.yarn.event.AbstractEvent

getTimestamp, getType, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SpeculatorEvent

public SpeculatorEvent(JobId jobID,
               long timestamp)

SpeculatorEvent

public SpeculatorEvent(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
               long timestamp)

SpeculatorEvent

public SpeculatorEvent(TaskAttemptId attemptID,
               boolean flag,
               long timestamp)

SpeculatorEvent

public SpeculatorEvent(TaskId taskID,
               int containersNeededChange)

Method Detail

getReportedStatus

public TaskAttemptStatusUpdateEvent.TaskAttemptStatus getReportedStatus()

containersNeededChange

public int containersNeededChange()

getTaskID

public TaskId getTaskID()

getJobID

public JobId getJobID()