Package 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

@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	Description
private class	RSProcedureDispatcher.DeadRSRemoteCall
protected class	RSProcedureDispatcher.ExecuteProceduresRemoteCall
static class	RSProcedureDispatcher.RegionCloseOperation
static class	RSProcedureDispatcher.RegionOpenOperation
static class	RSProcedureDispatcher.RegionOperation
private static interface	RSProcedureDispatcher.RemoteProcedureResolver
static final class	RSProcedureDispatcher.ServerOperation

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	Description
private static final int	DEFAULT_RS_RPC_STARTUP_WAIT_TIME
private static final org.slf4j.Logger	LOG
protected final MasterServices	master
private MasterProcedureEnv	procedureEnv
static final String	RS_RPC_STARTUP_WAIT_TIME_CONF_KEY
private final 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	Description
RSProcedureDispatcher(MasterServices master)

Method Summary

Modifier and Type	Method	Description
private void	abort(Thread t, Throwable e)
protected void	abortPendingOperations(ServerName serverName, Set<RemoteProcedureDispatcher.RemoteProcedure> operations)
private 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> operations, 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, 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

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

master

protected final MasterServices master

rsStartupWaitTime

private final long rsStartupWaitTime

procedureEnv

private MasterProcedureEnv procedureEnv

Constructor Details

RSProcedureDispatcher

public RSProcedureDispatcher(MasterServices master)

Method Details

getUncaughtExceptionHandler

protected Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()

Specified by:

getUncaughtExceptionHandler in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

start

public boolean start()

Overrides:

start in class RemoteProcedureDispatcher<MasterProcedureEnv,ServerName>

abort

private void abort(Thread t,
 Throwable e)

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> operations,
 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

operations - Remote procedures which are dispatched to the given server

resolver - Used to dispatch remote procedures to given server.

buildOpenRegionRequest

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