@InterfaceAudience.Private @InterfaceStability.Evolving public interface OperationQuota
Modifier and Type | Interface and Description |
---|---|
static class |
OperationQuota.OperationType |
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
|
long |
getReadAvailable()
Returns the number of bytes available to read to avoid exceeding the quota
|
void checkQuota(int numWrites, int numReads, int numScans) throws RpcThrottlingException
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.void close()
void addGetResult(Result result)
void addScanResult(List<Result> results)
void addMutation(Mutation mutation)
long getReadAvailable()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.