org.apache.hadoop.hbase.master.procedure

Class RSProcedureDispatcher

java.lang.Object

org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher

All Implemented Interfaces:

ServerListener

@InterfaceAudience.Private
public class RSProcedureDispatcher
extends RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>
implements ServerListener

A remote procecdure dispatcher for regionservers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	RSProcedureDispatcher.AbstractRSRemoteCall Base remote call
private class	RSProcedureDispatcher.CloseRegionRemoteCall Compatibility class used by CompatRemoteProcedureResolver to close regions using old AdminService#closeRegion(RpcController, CloseRegionRequest, RpcCallback) rpc.
private class	RSProcedureDispatcher.DeadRSRemoteCall
protected class	RSProcedureDispatcher.ExecuteProceduresRemoteCall
private class	RSProcedureDispatcher.OpenRegionRemoteCall Compatibility class used by CompatRemoteProcedureResolver to open regions using old AdminService#openRegion(RpcController, OpenRegionRequest, RpcCallback) rpc.
static class	RSProcedureDispatcher.RegionCloseOperation
static class	RSProcedureDispatcher.RegionOpenOperation
static class	RSProcedureDispatcher.RegionOperation
private static interface	RSProcedureDispatcher.RemoteProcedureResolver

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher

RemoteProcedureDispatcher.BufferNode, RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote>, RemoteProcedureDispatcher.RemoteOperation, RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote>

Field Summary

Fields

Modifier and Type	Field and Description
private static int	DEFAULT_RS_RPC_STARTUP_WAIT_TIME
private static org.slf4j.Logger	LOG
protected MasterServices	master
private MasterProcedureEnv	procedureEnv
static String	RS_RPC_STARTUP_WAIT_TIME_CONF_KEY
private static int	RS_VERSION_WITH_EXEC_PROCS
private long	rsStartupWaitTime

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

Constructors

Constructor and Description
RSProcedureDispatcher(MasterServices master)

Method Summary

Modifier and Type	Method and Description
protected void	abortPendingOperations(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> operations)
protected static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest	buildOpenRegionRequest(MasterProcedureEnv env, ServerName serverName, List<RSProcedureDispatcher.RegionOpenOperation> operations)
protected Thread.UncaughtExceptionHandler	getUncaughtExceptionHandler()
protected void	remoteDispatch(ServerName serverName, Set<RemoteProcedureDispatcher.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, Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures, RSProcedureDispatcher.RemoteProcedureResolver resolver) Fetches RemoteProcedureDispatcher.RemoteOperations from the given remoteProcedures and groups them by class of the returned operation.
boolean	start()
boolean	stop()

Methods inherited from class org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher

addNode, addOperationToNode, buildAndGroupRequestByType, fetchType, join, removeNode, 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 Detail

LOG

private static final org.slf4j.Logger LOG

RS_RPC_STARTUP_WAIT_TIME_CONF_KEY

public static final String RS_RPC_STARTUP_WAIT_TIME_CONF_KEY

See Also:

Constant Field Values

DEFAULT_RS_RPC_STARTUP_WAIT_TIME

private static final int DEFAULT_RS_RPC_STARTUP_WAIT_TIME

See Also:

Constant Field Values

RS_VERSION_WITH_EXEC_PROCS

private static final int RS_VERSION_WITH_EXEC_PROCS

See Also:

Constant Field Values

master

protected final MasterServices master

rsStartupWaitTime

private final long rsStartupWaitTime

procedureEnv

private MasterProcedureEnv procedureEnv

Constructor Detail

RSProcedureDispatcher

public RSProcedureDispatcher(MasterServices master)

Method Detail

getUncaughtExceptionHandler

protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

Specified by:

getUncaughtExceptionHandler in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

start

public boolean start()

Overrides:

start in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

stop

public boolean stop()

Overrides:

stop in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

remoteDispatch

protected void remoteDispatch(ServerName serverName,
                              Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures)

Specified by:

remoteDispatch in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

abortPendingOperations

protected void abortPendingOperations(ServerName serverName,
                                      Set<RemoteProcedureDispatcher.RemoteProcedure> operations)

Specified by:

abortPendingOperations in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

serverAdded

public void serverAdded(ServerName serverName)

Description copied from interface: ServerListener

The server has joined the cluster.

Specified by:

serverAdded in interface ServerListener

Parameters:

serverName - The remote servers name.

serverRemoved

public void serverRemoved(ServerName serverName)

Description copied from interface: ServerListener

The server was removed from the cluster.

Specified by:

serverRemoved in interface ServerListener

Parameters:

serverName - The remote servers name.

splitAndResolveOperation

public void splitAndResolveOperation(ServerName serverName,
                                     Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures,
                                     RSProcedureDispatcher.RemoteProcedureResolver resolver)

Fetches RemoteProcedureDispatcher.RemoteOperations from the given remoteProcedures and groups them by class of the returned operation. Then resolver is used to dispatch RSProcedureDispatcher.RegionOpenOperations and RSProcedureDispatcher.RegionCloseOperations.

Parameters:

serverName - RegionServer to which the remote operations are sent

remoteProcedures - Remote procedures which are dispatched to the given server

resolver - Used to dispatch remote procedures to given server.

buildOpenRegionRequest

protected static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest buildOpenRegionRequest(MasterProcedureEnv env,
                                                                                                                        ServerName serverName,
                                                                                                                        List<RSProcedureDispatcher.RegionOpenOperation> operations)