Package org.apache.hadoop.hbase.quotas

Class TestNoopOperationQuota

java.lang.Object
org.apache.hadoop.hbase.quotas.TestNoopOperationQuota
All Implemented Interfaces:
org.apache.hadoop.hbase.quotas.OperationQuota
public class TestNoopOperationQuota extends Object implements org.apache.hadoop.hbase.quotas.OperationQuota

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

    org.apache.hadoop.hbase.quotas.OperationQuota.OperationType

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final TestNoopOperationQuota
    INSTANCE
     

    Fields inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

    USE_RESULT_SIZE_BYTES, USE_RESULT_SIZE_BYTES_DEFAULT

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestNoopOperationQuota()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addGetResult(org.apache.hadoop.hbase.client.Result result)
     
    void
    addMutation(org.apache.hadoop.hbase.client.Mutation mutation)
     
    void
    addScanResult(List<org.apache.hadoop.hbase.client.Result> results)
     
    void
    addScanResultCells(List<org.apache.hadoop.hbase.Cell> cells)
     
    void
    checkBatchQuota(int numWrites, int numReads, boolean isAtomic)
     
    void
    checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference)
     
    void
    close()
     
    long
    getReadAvailable()
     
    long
    getReadConsumed()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.hadoop.hbase.quotas.OperationQuota

    getMaxResultSize

  • Field Details

  • Constructor Details

  • Method Details

    • checkBatchQuota

      public void checkBatchQuota(int numWrites, int numReads, boolean isAtomic) throws org.apache.hadoop.hbase.quotas.RpcThrottlingException
      Specified by:
      checkBatchQuota in interface org.apache.hadoop.hbase.quotas.OperationQuota
      Throws:
      org.apache.hadoop.hbase.quotas.RpcThrottlingException

    • checkScanQuota

      public void checkScanQuota(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest scanRequest, long maxScannerResultSize, long maxBlockBytesScanned, long prevBlockBytesScannedDifference) throws org.apache.hadoop.hbase.quotas.RpcThrottlingException
      Specified by:
      checkScanQuota in interface org.apache.hadoop.hbase.quotas.OperationQuota
      Throws:
      org.apache.hadoop.hbase.quotas.RpcThrottlingException

    • close

      public void close()
      Specified by:
      close in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • addGetResult

      public void addGetResult(org.apache.hadoop.hbase.client.Result result)
      Specified by:
      addGetResult in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • addScanResult

      public void addScanResult(List<org.apache.hadoop.hbase.client.Result> results)
      Specified by:
      addScanResult in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • addScanResultCells

      public void addScanResultCells(List<org.apache.hadoop.hbase.Cell> cells)
      Specified by:
      addScanResultCells in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • addMutation

      public void addMutation(org.apache.hadoop.hbase.client.Mutation mutation)
      Specified by:
      addMutation in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • getReadAvailable

      public long getReadAvailable()
      Specified by:
      getReadAvailable in interface org.apache.hadoop.hbase.quotas.OperationQuota

    • getReadConsumed

      public long getReadConsumed()
      Specified by:
      getReadConsumed in interface org.apache.hadoop.hbase.quotas.OperationQuota