public interface TaskRuntimeEstimator
Modifier and Type | Method and Description |
---|---|
long |
attemptEnrolledTime(TaskAttemptId attemptID) |
void |
contextualize(Configuration conf,
AppContext context) |
void |
enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
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
estimatedRuntime(TaskAttemptId) |
long |
thresholdRuntime(TaskId id)
Find a maximum reasonable execution wallclock time.
|
void |
updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp) |
void enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus, long timestamp)
long attemptEnrolledTime(TaskAttemptId attemptID)
void updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus, long timestamp)
void contextualize(Configuration conf, AppContext context)
long thresholdRuntime(TaskId id)
id
- the TaskId
of the task we are asking aboutlong estimatedRuntime(TaskAttemptId id)
id
- the TaskAttemptId
of the attempt we are asking about-1
if
we don't have enough information yet to produce an estimate.long estimatedNewAttemptRuntime(TaskId id)
id
- the TaskId
of the task we are asking about-1
if
we don't have enough information yet to produce an estimate.long runtimeEstimateVariance(TaskAttemptId id)
estimatedRuntime(TaskAttemptId)
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.