Package org.apache.hadoop.hbase.regionserver

Class RSAnnotationReadingPriorityFunction

java.lang.Object

org.apache.hadoop.hbase.ipc.AnnotationReadingPriorityFunction<RSRpcServices>

org.apache.hadoop.hbase.regionserver.RSAnnotationReadingPriorityFunction

All Implemented Interfaces:

PriorityFunction

@Private
public class RSAnnotationReadingPriorityFunction
extends AnnotationReadingPriorityFunction<RSRpcServices>

Priority function specifically for the region server.

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<String,Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>>	argumentToClassMap
static final int	INTERNAL_READ_QOS
private final Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>[]	knownArgumentClasses
private static final org.slf4j.Logger	LOG
private final Map<String,Map<Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>,Method>>	methodMap
static final String	SCAN_VTIME_WEIGHT_CONF_KEY	Used to control the scan delay, currently sqrt(numNextCall * weight)
private final float	scanVirtualTimeWeight

Fields inherited from class org.apache.hadoop.hbase.ipc.AnnotationReadingPriorityFunction

annotatedQos, rpcServices

Constructor Summary

Constructors

Constructor	Description
RSAnnotationReadingPriorityFunction(RSRpcServices rpcServices)

Method Summary

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

Methods inherited from class org.apache.hadoop.hbase.ipc.AnnotationReadingPriorityFunction

getAnnotatedPriority, getPriority

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

SCAN_VTIME_WEIGHT_CONF_KEY

public static final String SCAN_VTIME_WEIGHT_CONF_KEY

Used to control the scan delay, currently sqrt(numNextCall * weight)

See Also:

• Constant Field Values

INTERNAL_READ_QOS

public static final int INTERNAL_READ_QOS

See Also:

• Constant Field Values

knownArgumentClasses

private final Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>[] knownArgumentClasses

argumentToClassMap

private final Map<String,Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>> argumentToClassMap

methodMap

private final Map<String,Map<Class<? extends org.apache.hbase.thirdparty.com.google.protobuf.Message>,Method>> methodMap

scanVirtualTimeWeight

private final float scanVirtualTimeWeight

Constructor Details

RSAnnotationReadingPriorityFunction

RSAnnotationReadingPriorityFunction(RSRpcServices rpcServices)

Method Details

normalizePriority

protected int normalizePriority(int priority)

Specified by:

normalizePriority in class AnnotationReadingPriorityFunction<RSRpcServices>

getBasePriority

protected int getBasePriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
 org.apache.hbase.thirdparty.com.google.protobuf.Message param)

Description copied from class: AnnotationReadingPriorityFunction

Get the priority for a given request from the header and the param.

This doesn't consider which user is sending the request at all.

This doesn't consider annotations

Specified by:

getBasePriority in class AnnotationReadingPriorityFunction<RSRpcServices>

getDeadline

public 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.

Returns:

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