Package org.apache.hadoop.hbase.ipc

Interface PriorityFunction

All Known Implementing Classes:
AnnotationReadingPriorityFunction, MasterAnnotationReadingPriorityFunction, MasterRpcServices, RSRpcServices
@LimitedPrivate({"Coprocesssor","Phoenix"}) @Evolving public interface PriorityFunction
Function to figure priority of incoming request.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param)
    Returns the deadline of the specified request.
    int
    getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user)
    Returns the 'priority type' of the specified request.

  • Method Details

    • getPriority

      int getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user)
      Returns the 'priority type' of the specified request. The returned value is mainly used to select the dispatch queue.
      Returns:
      Priority of this request.

    • getDeadline

      long getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param)
      Returns the deadline of the specified request. The returned value is used to sort the dispatch queue.
      Returns:
      Deadline of this request. 0 now, otherwise msec of 'delay'