Package | Description |
---|---|
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOperationQuota |
class |
ExceedOperationQuota |
(package private) class |
NoopOperationQuota
Noop operation quota returned when no quota is associated to the user/table
|
Modifier and Type | Field and Description |
---|---|
private static OperationQuota |
NoopOperationQuota.instance |
Modifier and Type | Method and Description |
---|---|
private OperationQuota |
RegionServerRpcQuotaManager.checkQuota(Region region,
int numWrites,
int numReads,
int numScans)
Check the quota for the current (rpc-context) user.
|
OperationQuota |
RegionServerRpcQuotaManager.checkQuota(Region region,
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions)
Check the quota for the current (rpc-context) user.
|
OperationQuota |
RegionServerRpcQuotaManager.checkQuota(Region region,
OperationQuota.OperationType type)
Check the quota for the current (rpc-context) user.
|
static OperationQuota |
NoopOperationQuota.get() |
OperationQuota |
RegionServerRpcQuotaManager.getQuota(org.apache.hadoop.security.UserGroupInformation ugi,
TableName table)
Returns the quota for an operation.
|
Modifier and Type | Method and Description |
---|---|
private Result |
RSRpcServices.append(HRegion region,
OperationQuota quota,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
CellScanner cellScanner,
long nonceGroup,
ActivePolicyEnforcement spaceQuota)
Execute an append mutation.
|
private void |
RSRpcServices.doAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
HRegion region,
OperationQuota quota,
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
CellScanner cells,
ActivePolicyEnforcement spaceQuotaEnforcement) |
private void |
RSRpcServices.doBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
HRegion region,
OperationQuota quota,
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
CellScanner cells,
ActivePolicyEnforcement spaceQuotaEnforcement,
boolean atomic)
Execute a list of Put/Delete mutations.
|
private void |
RSRpcServices.doNonAtomicBatchOp(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
HRegion region,
OperationQuota quota,
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> mutations,
CellScanner cells,
ActivePolicyEnforcement spaceQuotaEnforcement) |
private List<CellScannable> |
RSRpcServices.doNonAtomicRegionMutation(HRegion region,
OperationQuota quota,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionAction actions,
CellScanner cellScanner,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
List<CellScannable> cellsToReturn,
long nonceGroup,
RSRpcServices.RegionScannersCloseCallBack closeCallBack,
RpcCallContext context,
ActivePolicyEnforcement spaceQuotaEnforcement)
Run through the regionMutation
rm and per Mutation, do the work, and then when
done, add an instance of a ClientProtos.ResultOrException that corresponds to each Mutation. |
private Result |
RSRpcServices.increment(HRegion region,
OperationQuota quota,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto mutation,
CellScanner cells,
long nonceGroup,
ActivePolicyEnforcement spaceQuota)
Execute an increment mutation.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.