public class NullTaskRuntimesEngine extends Object implements TaskRuntimeEstimator
Constructor and Description |
---|
NullTaskRuntimesEngine() |
Modifier and Type | Method and Description |
---|---|
long |
attemptEnrolledTime(TaskAttemptId attemptID) |
void |
contextualize(Configuration conf,
AppContext context) |
void |
enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
long |
estimatedNewAttemptRuntime(TaskId id)
Estimates how long a new attempt on this task will take if we start
one now
|
long |
estimatedRuntime(TaskAttemptId id)
Estimate a task attempt's total runtime.
|
long |
runtimeEstimateVariance(TaskAttemptId id)
Computes the width of the error band of our estimate of the task
runtime as returned by
TaskRuntimeEstimator.estimatedRuntime(TaskAttemptId) |
long |
thresholdRuntime(TaskId id)
Find a maximum reasonable execution wallclock time.
|
void |
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status,
long timestamp) |
public void enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status, long timestamp)
enrollAttempt
in interface TaskRuntimeEstimator
public long attemptEnrolledTime(TaskAttemptId attemptID)
attemptEnrolledTime
in interface TaskRuntimeEstimator
public void updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus status, long timestamp)
updateAttempt
in interface TaskRuntimeEstimator
public void contextualize(Configuration conf, AppContext context)
contextualize
in interface TaskRuntimeEstimator
public long thresholdRuntime(TaskId id)
TaskRuntimeEstimator
thresholdRuntime
in interface TaskRuntimeEstimator
id
- the TaskId
of the task we are asking aboutpublic long estimatedRuntime(TaskAttemptId id)
TaskRuntimeEstimator
estimatedRuntime
in interface TaskRuntimeEstimator
id
- the TaskAttemptId
of the attempt we are asking about-1
if
we don't have enough information yet to produce an estimate.public long estimatedNewAttemptRuntime(TaskId id)
TaskRuntimeEstimator
estimatedNewAttemptRuntime
in interface TaskRuntimeEstimator
id
- the TaskId
of the task we are asking about-1
if
we don't have enough information yet to produce an estimate.public long runtimeEstimateVariance(TaskAttemptId id)
TaskRuntimeEstimator
TaskRuntimeEstimator.estimatedRuntime(TaskAttemptId)
runtimeEstimateVariance
in interface TaskRuntimeEstimator
id
- the TaskAttemptId
of the attempt we are asking about-1
if
we don't have enough information yet to produce an estimate.Copyright © 2013 Apache Software Foundation. All rights reserved.