org.apache.accumulo.test.randomwalk.bulk

Class SelectiveQueueing

java.lang.Object

org.apache.accumulo.test.randomwalk.bulk.SelectiveQueueing

public class SelectiveQueueing
extends Object

Chooses whether or not an operation should be queued based on the current thread pool queue length and the number of available TServers.

Constructor Summary

Constructors

Constructor and Description
SelectiveQueueing()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	shouldQueueOperation(State state)

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectiveQueueing

public SelectiveQueueing()

Method Detail

shouldQueueOperation

public static boolean shouldQueueOperation(State state)
                                    throws Exception

Throws:

Exception