Class TestRemoteProcedureDispatcherUncaughtExceptionHandler.Dispatcher
- Enclosing class:
- TestRemoteProcedureDispatcherUncaughtExceptionHandler
private static final class TestRemoteProcedureDispatcherUncaughtExceptionHandler.Dispatcher
extends org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<Void,Integer>
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.BufferNode, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteNode<TEnv extends Object,
TRemote extends Object>, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation, org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure<TEnv extends Object, TRemote extends Object> -
Field Summary
Fields inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
DISPATCH_DELAY_CONF_KEY, DISPATCH_MAX_QUEUE_SIZE_CONF_KEY, THREAD_POOL_SIZE_CONF_KEY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
abortPendingOperations
(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations) protected Thread.UncaughtExceptionHandler
protected void
remoteDispatch
(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations) Methods inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
addNode, addOperationToNode, buildAndGroupRequestByType, fetchType, hasNode, join, removeCompletedOperation, removeNode, setTimeoutExecutorUncaughtExceptionHandler, start, stop, submitTask, submitTask
-
Field Details
-
handler
-
-
Constructor Details
-
Dispatcher
-
-
Method Details
-
getUncaughtExceptionHandler
-
remoteDispatch
protected void remoteDispatch(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations) -
abortPendingOperations
protected void abortPendingOperations(Integer key, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> operations)
-