org.apache.hadoop.hbase.ipc

Interface PriorityFunction

All Known Implementing Classes:

AnnotationReadingPriorityFunction, MasterAnnotationReadingPriorityFunction, MasterRpcServices, RSRpcServices

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
 @InterfaceStability.Evolving
public interface PriorityFunction

Function to figure priority of incoming request.

Method Summary

Modifier and Type	Method and 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 Detail

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.

Parameters:

header -

param -

user -

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.

Parameters:

header -

param -

Returns:

Deadline of this request. 0 now, otherwise msec of 'delay'