@InterfaceAudience.Private @InterfaceStability.Unstable public class NewAppWeightBooster extends Configured implements WeightAdjuster
WeightAdjuster
implementation that gives a weight boost to new jobs
for a certain amount of time -- by default, a 3x weight boost for 60 seconds.
This can be used to make shorter jobs finish faster, emulating Shortest Job
First scheduling while not starving long jobs.Constructor and Description |
---|
NewAppWeightBooster() |
Modifier and Type | Method and Description |
---|---|
double |
adjustWeight(AppSchedulable app,
double curWeight) |
void |
setConf(Configuration conf)
Set the configuration to be used by this object.
|
getConf
public void setConf(Configuration conf)
Configurable
setConf
in interface Configurable
setConf
in class Configured
public double adjustWeight(AppSchedulable app, double curWeight)
adjustWeight
in interface WeightAdjuster
Copyright © 2013 Apache Software Foundation. All rights reserved.