@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() |
long |
getWriteAvailable() |
void checkQuota(int numWrites, int numReads, int numScans) throws ThrottlingException
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 performedThrottlingException
- if the operation cannot be performedvoid close()
void addGetResult(Result result)
void addScanResult(List<Result> results)
void addMutation(Mutation mutation)
long getReadAvailable()
long getWriteAvailable()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.