public interface TaskRuntimeEstimator
Modifier and Type | Method and Description |
---|---|
long |
attemptEnrolledTime(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID) |
void |
contextualize(org.apache.hadoop.conf.Configuration conf,
AppContext context) |
void |
enrollAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus,
long timestamp) |
long |
estimatedNewAttemptRuntime(org.apache.hadoop.mapreduce.v2.api.records.TaskId id)
Estimates how long a new attempt on this task will take if we start
one now
|
long |
estimatedRuntime(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id)
Estimate a task attempt's total runtime.
|
default boolean |
hasStagnatedProgress(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id,
long timeStamp)
Returns true if the estimator has no updates records for a threshold time
window.
|
long |
runtimeEstimateVariance(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id)
Computes the width of the error band of our estimate of the task
runtime as returned by
estimatedRuntime(TaskAttemptId) |
long |
thresholdRuntime(org.apache.hadoop.mapreduce.v2.api.records.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(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID)
void updateAttempt(TaskAttemptStatusUpdateEvent.TaskAttemptStatus reportedStatus, long timestamp)
void contextualize(org.apache.hadoop.conf.Configuration conf, AppContext context)
long thresholdRuntime(org.apache.hadoop.mapreduce.v2.api.records.TaskId id)
id
- the TaskId
of the task we are asking aboutlong estimatedRuntime(org.apache.hadoop.mapreduce.v2.api.records.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(org.apache.hadoop.mapreduce.v2.api.records.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(org.apache.hadoop.mapreduce.v2.api.records.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.default boolean hasStagnatedProgress(org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId id, long timeStamp)
id
- the TaskAttemptId
of the attempt we are asking abouttimeStamp
- the time of the report we compare withCopyright © 2008–2024 Apache Software Foundation. All rights reserved.