org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair
Class NewAppWeightBooster

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.NewAppWeightBooster
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, WeightAdjuster

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class NewAppWeightBooster
extends org.apache.hadoop.conf.Configured
implements WeightAdjuster

A 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 Summary
NewAppWeightBooster()
           
 
Method Summary
 double adjustWeight(AppSchedulable app, double curWeight)
           
 void setConf(org.apache.hadoop.conf.Configuration conf)
           
 
Methods inherited from class org.apache.hadoop.conf.Configured
getConf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

NewAppWeightBooster

public NewAppWeightBooster()
Method Detail

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)
Specified by:
setConf in interface org.apache.hadoop.conf.Configurable
Overrides:
setConf in class org.apache.hadoop.conf.Configured

adjustWeight

public double adjustWeight(AppSchedulable app,
                           double curWeight)
Specified by:
adjustWeight in interface WeightAdjuster


Copyright © 2014 Apache Software Foundation. All Rights Reserved.