void |
TaskRuntimeEstimator.enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp) |
void |
NullTaskRuntimesEngine.enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
void |
Speculator.handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status) |
void |
DefaultSpeculator.handleAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status) |
protected void |
DefaultSpeculator.statusUpdate(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp)
Absorbs one TaskAttemptStatus
|
void |
TaskRuntimeEstimator.updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp) |
void |
LegacyTaskRuntimeEstimator.updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
void |
ExponentiallySmoothedTaskRuntimeEstimator.updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
void |
NullTaskRuntimesEngine.updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
void |
SimpleExponentialTaskRuntimeEstimator.updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |