Uses of Class
org.apache.hadoop.hbase.quotas.RpcThrottlingException

Packages that use RpcThrottlingException
Package
Description
org.apache.hadoop.hbase.quotas
 

  • Uses of RpcThrottlingException in org.apache.hadoop.hbase.quotas

    Methods in org.apache.hadoop.hbase.quotas that throw RpcThrottlingException
    Modifier and Type
    Method
    Description
    void
    DefaultOperationQuota.checkBatchQuota(int numWrites, int numReads)
     
    void
    ExceedOperationQuota.checkBatchQuota(int numWrites, int numReads)
     
    void
    NoopOperationQuota.checkBatchQuota(int numWrites, int numReads)
     
    void
    OperationQuota.checkBatchQuota(int numWrites, int numReads)
    Checks if it is possible to execute the specified operation.
    private OperationQuota
    RegionServerRpcQuotaManager.checkBatchQuota(Region region, int numWrites, int numReads)
    Check the quota for the current (rpc-context) user.
    OperationQuota
    RegionServerRpcQuotaManager.checkBatchQuota(Region region, List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions, boolean hasCondition)
    Check the quota for the current (rpc-context) user.
    OperationQuota
    RegionServerRpcQuotaManager.checkBatchQuota(Region region, OperationQuota.OperationType type)
    Check the quota for the current (rpc-context) user.
    private void
    DefaultOperationQuota.checkQuota(long numWrites, long numReads)
     
    private void
    ExceedOperationQuota.checkQuota(Runnable estimateQuota, ExceedOperationQuota.CheckQuotaRunnable checkQuota, int numWrites, int numReads, int numScans)
     
    void
    NoopQuotaLimiter.checkQuota(long writeReqs, long estimateWriteSize, long readReqs, long estimateReadSize, long estimateWriteCapacityUnit, long estimateReadCapacityUnit)
     
    void
    QuotaLimiter.checkQuota(long writeReqs, long estimateWriteSize, long readReqs, long estimateReadSize, long estimateWriteCapacityUnit, long estimateReadCapacityUnit)
    Checks if it is possible to execute the specified operation.
    void
    TimeBasedLimiter.checkQuota(long writeReqs, long estimateWriteSize, long readReqs, long estimateReadSize, long estimateWriteCapacityUnit, long estimateReadCapacityUnit)
     
    void
    DefaultOperationQuota.checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
     
    void
    ExceedOperationQuota.checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
     
    void
    NoopOperationQuota.checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
     
    void
    OperationQuota.checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
    Checks if it is possible to execute the scan.
    OperationQuota
    RegionServerRpcQuotaManager.checkScanQuota(Region region, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
    Check the quota for the current (rpc-context) user.
    void
    ExceedOperationQuota.CheckQuotaRunnable.run()
     
    static void
    RpcThrottlingException.throwNumReadRequestsExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwNumRequestsExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwNumWriteRequestsExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwReadCapacityUnitExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwReadSizeExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwRequestCapacityUnitExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwRequestSizeExceeded(long waitInterval)
     
    private static void
    RpcThrottlingException.throwThrottlingException(RpcThrottlingException.Type type, long waitInterval)
     
    static void
    RpcThrottlingException.throwWriteCapacityUnitExceeded(long waitInterval)
     
    static void
    RpcThrottlingException.throwWriteSizeExceeded(long waitInterval)