@InterfaceAudience.Private class RSAnnotationReadingPriorityFunction extends AnnotationReadingPriorityFunction<RSRpcServices>
Modifier and Type | Field and Description |
---|---|
private Map<String,Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>> |
argumentToClassMap |
private Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>[] |
knownArgumentClasses |
private static org.slf4j.Logger |
LOG |
private Map<String,Map<Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>,Method>> |
methodMap |
static String |
SCAN_VTIME_WEIGHT_CONF_KEY
Used to control the scan delay, currently sqrt(numNextCall * weight)
|
private float |
scanVirtualTimeWeight |
annotatedQos, rpcServices
Constructor and Description |
---|
RSAnnotationReadingPriorityFunction(RSRpcServices 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)
Based on the request content, returns the deadline of the request.
|
protected int |
normalizePriority(int priority) |
getAnnotatedPriority, getPriority
private static final org.slf4j.Logger LOG
public static final String SCAN_VTIME_WEIGHT_CONF_KEY
private final Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>[] knownArgumentClasses
private final Map<String,Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>> argumentToClassMap
private final Map<String,Map<Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>,Method>> methodMap
private final float scanVirtualTimeWeight
RSAnnotationReadingPriorityFunction(RSRpcServices rpcServices)
protected int normalizePriority(int priority)
normalizePriority
in class AnnotationReadingPriorityFunction<RSRpcServices>
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<RSRpcServices>
public long getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.