org.apache.hadoop.hbase.quotas

Class TimeBasedLimiter

java.lang.Object

org.apache.hadoop.hbase.quotas.TimeBasedLimiter

All Implemented Interfaces:

QuotaLimiter

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class TimeBasedLimiter
extends Object
implements QuotaLimiter

Simple time based limiter that checks the quota Throttle

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.conf.Configuration	conf
private RateLimiter	readCapacityUnitLimiter
private RateLimiter	readReqsLimiter
private RateLimiter	readSizeLimiter
private RateLimiter	reqCapacityUnitLimiter
private RateLimiter	reqSizeLimiter
private RateLimiter	reqsLimiter
private RateLimiter	writeCapacityUnitLimiter
private RateLimiter	writeReqsLimiter
private RateLimiter	writeSizeLimiter

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TimeBasedLimiter()

Method Summary

Modifier and Type	Method and Description
void	checkQuota(long writeReqs, long estimateWriteSize, long readReqs, long estimateReadSize, long estimateWriteCapacityUnit, long estimateReadCapacityUnit) Checks if it is possible to execute the specified operation.
void	consumeRead(long size, long capacityUnit) Removes or add back some read amount to the quota.
void	consumeWrite(long size, long capacityUnit) Removes or add back some write amount to the quota.
(package private) static QuotaLimiter	fromThrottle(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Throttle throttle)
long	getReadAvailable()
long	getWriteAvailable()
void	grabQuota(long writeReqs, long writeSize, long readReqs, long readSize, long writeCapacityUnit, long readCapacityUnit) Removes the specified write and read amount from the quota.
boolean	isBypass()
private static void	setFromTimedQuota(RateLimiter limiter, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.TimedQuota timedQuota)
String	toString()
void	update(TimeBasedLimiter other)

Methods inherited from class java.lang.Object

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

Field Detail

conf

private static final org.apache.hadoop.conf.Configuration conf

reqsLimiter

private RateLimiter reqsLimiter

reqSizeLimiter

private RateLimiter reqSizeLimiter

writeReqsLimiter

private RateLimiter writeReqsLimiter

writeSizeLimiter

private RateLimiter writeSizeLimiter

readReqsLimiter

private RateLimiter readReqsLimiter

readSizeLimiter

private RateLimiter readSizeLimiter

reqCapacityUnitLimiter

private RateLimiter reqCapacityUnitLimiter

writeCapacityUnitLimiter

private RateLimiter writeCapacityUnitLimiter

readCapacityUnitLimiter

private RateLimiter readCapacityUnitLimiter

Constructor Detail

TimeBasedLimiter

private TimeBasedLimiter()

Method Detail

fromThrottle

static QuotaLimiter fromThrottle(org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Throttle throttle)

update

public void update(TimeBasedLimiter other)

setFromTimedQuota

private static void setFromTimedQuota(RateLimiter limiter,
                                      org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.TimedQuota timedQuota)

checkQuota

public void checkQuota(long writeReqs,
                       long estimateWriteSize,
                       long readReqs,
                       long estimateReadSize,
                       long estimateWriteCapacityUnit,
                       long estimateReadCapacityUnit)
                throws RpcThrottlingException

Description copied from interface: QuotaLimiter

Checks if it is possible to execute the specified operation.

Specified by:

checkQuota in interface QuotaLimiter

Parameters:

writeReqs - the write requests that will be checked against the available quota

estimateWriteSize - the write size that will be checked against the available quota

readReqs - the read requests that will be checked against the available quota

estimateReadSize - the read size that will be checked against the available quota

estimateWriteCapacityUnit - the write capacity unit that will be checked against the available quota

estimateReadCapacityUnit - the read capacity unit that will be checked against the available quota

Throws:

RpcThrottlingException - thrown if not enough available resources to perform operation.

grabQuota

public void grabQuota(long writeReqs,
                      long writeSize,
                      long readReqs,
                      long readSize,
                      long writeCapacityUnit,
                      long readCapacityUnit)

Description copied from interface: QuotaLimiter

Removes the specified write and read amount from the quota. At this point the write and read amount will be an estimate, that will be later adjusted with a consumeWrite()/consumeRead() call.

Specified by:

grabQuota in interface QuotaLimiter

Parameters:

writeReqs - the write requests that will be removed from the current quota

writeSize - the write size that will be removed from the current quota

readReqs - the read requests that will be removed from the current quota

readSize - the read size that will be removed from the current quota

writeCapacityUnit - the write capacity unit that will be removed from the current quota

readCapacityUnit - the read capacity unit num that will be removed from the current quota

consumeWrite

public void consumeWrite(long size,
                         long capacityUnit)

Description copied from interface: QuotaLimiter

Removes or add back some write amount to the quota. (called at the end of an operation in case the estimate quota was off)

Specified by:

consumeWrite in interface QuotaLimiter

consumeRead

public void consumeRead(long size,
                        long capacityUnit)

Description copied from interface: QuotaLimiter

Removes or add back some read amount to the quota. (called at the end of an operation in case the estimate quota was off)

Specified by:

consumeRead in interface QuotaLimiter

isBypass

public boolean isBypass()

Specified by:

isBypass in interface QuotaLimiter

Returns:

true if the limiter is a noop

getWriteAvailable

public long getWriteAvailable()

Specified by:

getWriteAvailable in interface QuotaLimiter

Returns:

the number of bytes available to write to avoid exceeding the quota

getReadAvailable

public long getReadAvailable()

Specified by:

getReadAvailable in interface QuotaLimiter

Returns:

the number of bytes available to read to avoid exceeding the quota

toString

public String toString()

Overrides:

toString in class Object