Package 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	Description
private static final int	DEFAULT_MAX_CALL_DELAY
private final int	maxDelay
private final PriorityFunction	priority

Constructor Summary

Constructors

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

Method Summary

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

equals, reversed, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Details

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 Details

CallPriorityComparator

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

Method Details

compare

public int compare(CallRunner a,
 CallRunner b)

Specified by:

compare in interface Comparator<CallRunner>