Package org.apache.accumulo.core.util.ratelimit

Class SharedRateLimiterFactory.SharedRateLimiter

java.lang.Object

org.apache.accumulo.core.util.ratelimit.GuavaRateLimiter

org.apache.accumulo.core.util.ratelimit.SharedRateLimiterFactory.SharedRateLimiter

All Implemented Interfaces:

RateLimiter

Enclosing class:

SharedRateLimiterFactory

protected class SharedRateLimiterFactory.SharedRateLimiter
extends GuavaRateLimiter

Method Summary

Modifier and Type	Method	Description
void	acquire(long permits)	Sleep until the specified number of queries are available.
void	report()	Report the current throughput and usage of this rate limiter to the debug log.
void	update()	Poll the callback, updating the current rate if necessary.

Methods inherited from class org.apache.accumulo.core.util.ratelimit.GuavaRateLimiter

getRate, setRate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

acquire

public void acquire(long permits)

Description copied from interface: RateLimiter

Sleep until the specified number of queries are available.

Specified by:

acquire in interface RateLimiter

Overrides:

acquire in class GuavaRateLimiter

update

public void update()

Poll the callback, updating the current rate if necessary.

report

public void report()

Report the current throughput and usage of this rate limiter to the debug log.