@InterfaceAudience.Private @InterfaceStability.Evolving class NoopOperationQuota extends Object implements OperationQuota
OperationQuota.OperationType
Modifier and Type | Field and Description |
---|---|
private static OperationQuota |
instance |
Modifier | Constructor and Description |
---|---|
private |
NoopOperationQuota() |
Modifier and Type | Method and Description |
---|---|
void |
addGetResult(Result result)
Add a get result.
|
void |
addMutation(Mutation mutation)
Add a mutation result.
|
void |
addScanResult(List<Result> results)
Add a scan result.
|
void |
checkQuota(int numWrites,
int numReads,
int numScans)
Checks if it is possible to execute the specified operation.
|
void |
close()
Cleanup method on operation completion
|
static OperationQuota |
get() |
long |
getReadAvailable()
Returns the number of bytes available to read to avoid exceeding the quota
|
private static OperationQuota instance
private NoopOperationQuota()
public static OperationQuota get()
public void checkQuota(int numWrites, int numReads, int numScans) throws RpcThrottlingException
OperationQuota
checkQuota
in interface OperationQuota
numWrites
- number of write operation that will be performednumReads
- number of small-read operation that will be performednumScans
- number of long-read operation that will be performedRpcThrottlingException
- if the operation cannot be performed because RPC quota is
exceeded.public void close()
OperationQuota
close
in interface OperationQuota
public void addGetResult(Result result)
OperationQuota
addGetResult
in interface OperationQuota
public void addScanResult(List<Result> results)
OperationQuota
addScanResult
in interface OperationQuota
public void addMutation(Mutation mutation)
OperationQuota
addMutation
in interface OperationQuota
public long getReadAvailable()
OperationQuota
getReadAvailable
in interface OperationQuota
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.