@InterfaceAudience.Private @InterfaceStability.Unstable public class NewAppWeightBooster extends org.apache.hadoop.conf.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(FSAppAttempt app,
double curWeight) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
setConf
in class org.apache.hadoop.conf.Configured
public double adjustWeight(FSAppAttempt app, double curWeight)
adjustWeight
in interface WeightAdjuster
Copyright © 2019 Apache Software Foundation. All Rights Reserved.