org.apache.hadoop.hbase.ipc

Class RpcExecutor.CallPriorityComparator

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcExecutor.CallPriorityComparator

All Implemented Interfaces:

Comparator<CallRunner>

Enclosing class:

RpcExecutor

private static class RpcExecutor.CallPriorityComparator
extends Object
implements Comparator<CallRunner>

Comparator used by the "normal callQueue" if DEADLINE_CALL_QUEUE_CONF_KEY is set to true. It uses the calculated "deadline" e.g. to deprioritize long-running job If multiple requests have the same deadline BoundedPriorityBlockingQueue will order them in FIFO (first-in-first-out) manner.

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEFAULT_MAX_CALL_DELAY
private int	maxDelay
private PriorityFunction	priority

Constructor Summary

Constructors

Constructor and Description
CallPriorityComparator(org.apache.hadoop.conf.Configuration conf, PriorityFunction priority)

Method Summary

Modifier and Type	Method and Description
int	compare(CallRunner a, CallRunner b)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Detail

DEFAULT_MAX_CALL_DELAY

private static final int DEFAULT_MAX_CALL_DELAY

See Also:

Constant Field Values

priority

private final PriorityFunction priority

maxDelay

private final int maxDelay

Constructor Detail

CallPriorityComparator

public CallPriorityComparator(org.apache.hadoop.conf.Configuration conf,
                              PriorityFunction priority)

Method Detail

compare

public int compare(CallRunner a,
                   CallRunner b)

Specified by:

compare in interface Comparator<CallRunner>