Class TestServerRemoteProcedure.MockRSProcedureDispatcher
java.lang.Object
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,org.apache.hadoop.hbase.ServerName>
org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher
org.apache.hadoop.hbase.master.procedure.TestServerRemoteProcedure.MockRSProcedureDispatcher
- All Implemented Interfaces:
org.apache.hadoop.hbase.master.ServerListener
- Enclosing class:
- TestServerRemoteProcedure
protected static class TestServerRemoteProcedure.MockRSProcedureDispatcher
extends org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher
-
Nested Class Summary
Modifier and TypeClassDescriptionprivate class
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher
org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ExecuteProceduresRemoteCall, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionCloseOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionOpenOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RegionOperation, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.ServerOperation
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.master.procedure.RSProcedureDispatcher
master, RS_RPC_STARTUP_WAIT_TIME_CONF_KEY
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
ConstructorDescriptionMockRSProcedureDispatcher
(org.apache.hadoop.hbase.master.MasterServices master) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
remoteDispatch
(org.apache.hadoop.hbase.ServerName serverName, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) void
Methods inherited from class org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher
abortPendingOperations, getUncaughtExceptionHandler, serverAdded, serverRemoved, splitAndResolveOperation, start, stop
Methods inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher
addNode, addOperationToNode, buildAndGroupRequestByType, fetchType, hasNode, join, removeCompletedOperation, removeNode, setTimeoutExecutorUncaughtExceptionHandler, submitTask, submitTask
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.hadoop.hbase.master.ServerListener
waiting
-
Field Details
-
mockRsExec
-
-
Constructor Details
-
MockRSProcedureDispatcher
-
-
Method Details
-
setMockRsExecutor
-
remoteDispatch
protected void remoteDispatch(org.apache.hadoop.hbase.ServerName serverName, Set<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) - Overrides:
remoteDispatch
in classorg.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher
-