Field Detail

• maxThroughputUpperBound

  protected long maxThroughputUpperBound

• maxThroughputLowerBound

  protected long maxThroughputLowerBound

• offPeakHours

  protected OffPeakHours offPeakHours

• controlPerSize

  protected long controlPerSize

• tuningPeriod

  protected int tuningPeriod

• activeOperations

  protected final ConcurrentMap<String,org.apache.hadoop.hbase.regionserver.throttle.PressureAwareThroughputController.ActiveOperation> activeOperations

Constructor Detail

• PressureAwareThroughputController

  public PressureAwareThroughputController()

Method Detail

• setup

  public abstract void setup(RegionServerServices server)

  Description copied from interface: ThroughputController
  Setup controller for the given region server.

  Specified by:

  setup in interface ThroughputController

• throughputDesc

  protected String throughputDesc(long deltaSize,
                      long elapsedTime)

• throughputDesc

  protected String throughputDesc(double speed)

• start

  public void start(String opName)

  Description copied from interface: ThroughputController
  Start the throughput controller.

  Specified by:

  start in interface ThroughputController

• control

  public long control(String opName,
             long size)
               throws InterruptedException

  Description copied from interface: ThroughputController
  Control the throughput. Will sleep if too fast.

  Specified by:

  control in interface ThroughputController

  Returns:

  the actual sleep time.

  Throws:

  InterruptedException

• finish

  public void finish(String opName)

  Description copied from interface: ThroughputController
  Finish the controller. Should call this method in a finally block.

  Specified by:

  finish in interface ThroughputController

• stop

  public void stop(String why)

  Description copied from interface: Stoppable
  Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

  Specified by:

  stop in interface Stoppable

  Parameters:

  why - Why we're stopping.

• isStopped

  public boolean isStopped()

  Specified by:

  isStopped in interface Stoppable

  Returns:

  True if Stoppable.stop(String) has been closed.

• getMaxThroughput

  public double getMaxThroughput()

• setMaxThroughput

  public void setMaxThroughput(double maxThroughput)