public class RSProcedureDispatcher extends <any> implements ServerListener
Modifier and Type | Class and Description |
---|---|
protected class |
RSProcedureDispatcher.AbstractRSRemoteCall
Base remote call
|
protected class |
RSProcedureDispatcher.CompatRemoteProcedureResolver
Compatibility class to open and close regions using old endpoints (openRegion/closeRegion) in
AdminService . |
protected class |
RSProcedureDispatcher.ExecuteProceduresRemoteCall |
static class |
RSProcedureDispatcher.RegionCloseOperation |
static class |
RSProcedureDispatcher.RegionOpenOperation |
static class |
RSProcedureDispatcher.RegionOperation |
Modifier and Type | Field and Description |
---|---|
protected MasterServices |
master |
static java.lang.String |
RS_RPC_STARTUP_WAIT_TIME_CONF_KEY |
Constructor and Description |
---|
RSProcedureDispatcher(MasterServices master) |
Modifier and Type | Method and Description |
---|---|
protected void |
abortPendingOperations(ServerName serverName,
java.util.Set<RemoteProcedure> operations) |
protected void |
remoteDispatch(ServerName serverName,
java.util.Set<RemoteProcedure> remoteProcedures) |
void |
serverAdded(ServerName serverName)
The server has joined the cluster.
|
void |
serverRemoved(ServerName serverName)
The server was removed from the cluster.
|
void |
splitAndResolveOperation(ServerName serverName,
java.util.Set<RemoteProcedure> remoteProcedures,
org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RemoteProcedureResolver resolver)
Fetches
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation s
from the given remoteProcedures and groups them by class of the returned operation. |
boolean |
start() |
boolean |
stop() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
waiting
public static final java.lang.String RS_RPC_STARTUP_WAIT_TIME_CONF_KEY
protected final MasterServices master
public RSProcedureDispatcher(MasterServices master)
public boolean start()
public boolean stop()
protected void remoteDispatch(ServerName serverName, java.util.Set<RemoteProcedure> remoteProcedures)
protected void abortPendingOperations(ServerName serverName, java.util.Set<RemoteProcedure> operations)
public void serverAdded(ServerName serverName)
ServerListener
serverAdded
in interface ServerListener
serverName
- The remote servers name.public void serverRemoved(ServerName serverName)
ServerListener
serverRemoved
in interface ServerListener
serverName
- The remote servers name.public void splitAndResolveOperation(ServerName serverName, java.util.Set<RemoteProcedure> remoteProcedures, org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RemoteProcedureResolver resolver)
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation
s
from the given remoteProcedures
and groups them by class of the returned operation.
Then resolver
is used to dispatch RSProcedureDispatcher.RegionOpenOperation
s and
RSProcedureDispatcher.RegionCloseOperation
s.serverName
- RegionServer to which the remote operations are sentremoteProcedures
- Remote procedures which are dispatched to the given serverresolver
- Used to dispatch remote procedures to given server.