org.apache.hadoop.hbase.procedure2

Class ProcedureFairRunQueues<TKey,TQueue extends ProcedureFairRunQueues.FairObject>

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureFairRunQueues<TKey,TQueue>

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class ProcedureFairRunQueues<TKey,TQueue extends ProcedureFairRunQueues.FairObject>
extends Object

This class is a container of queues that allows to select a queue in a round robin fashion, considering priority of the queue. the quantum is just how many poll() will return the same object. e.g. if quantum is 1 and you have A and B as object you'll get: A B A B e.g. if quantum is 2 and you have A and B as object you'll get: A A B B A A B B then the object priority is just a priority * quantum Example: - three queues (A, B, C) with priorities (1, 1, 2) - The first poll() will return A - The second poll() will return B - The third and forth poll() will return C - and so on again and again.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcedureFairRunQueues.FairObject

Constructor Summary

Constructors

Constructor and Description
ProcedureFairRunQueues(int quantum)

Method Summary

Modifier and Type	Method and Description
TQueue	add(TKey key, TQueue queue)
void	clear()
TQueue	get(TKey key)
TQueue	poll()
TQueue	remove(TKey key)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureFairRunQueues

public ProcedureFairRunQueues(int quantum)

Parameters:

quantum - how many poll() will return the same object.

Method Detail

get

public TQueue get(TKey key)

add

public TQueue add(TKey key,
                  TQueue queue)

remove

public TQueue remove(TKey key)

clear

public void clear()

poll

public TQueue poll()

Returns:

the next available item if present

toString

public String toString()

Overrides:

toString in class Object