@InterfaceAudience.Private public class MasterAnnotationReadingPriorityFunction extends AnnotationReadingPriorityFunction<MasterRpcServices>
Modifier and Type | Field and Description |
---|---|
static int |
META_TRANSITION_QOS
We reference this value in SimpleRpcScheduler so this class have to be public instead of
package private
|
annotatedQos, rpcServices
Constructor and Description |
---|
MasterAnnotationReadingPriorityFunction(MasterRpcServices rpcServices) |
Modifier and Type | Method and Description |
---|---|
protected int |
getBasePriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
org.apache.hbase.thirdparty.com.google.protobuf.Message param)
Get the priority for a given request from the header and the param.
|
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.
|
protected int |
normalizePriority(int priority) |
getAnnotatedPriority, getPriority
public static final int META_TRANSITION_QOS
MasterAnnotationReadingPriorityFunction(MasterRpcServices rpcServices)
protected int normalizePriority(int priority)
normalizePriority
in class AnnotationReadingPriorityFunction<MasterRpcServices>
protected int getBasePriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param)
AnnotationReadingPriorityFunction
getBasePriority
in class AnnotationReadingPriorityFunction<MasterRpcServices>
public long getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param)
PriorityFunction
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.