| Modifier and Type | Method and Description |
|---|---|
private RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,?> |
HMaster.getRemoteProcedure(long procId) |
| Modifier and Type | Class and Description |
|---|---|
class |
AssignProcedure
Deprecated.
Do not use any more.
|
class |
CloseRegionProcedure
The remote procedure used to close a region.
|
class |
OpenRegionProcedure
The remote procedure used to open a region.
|
class |
RegionRemoteProcedureBase
The base class for the remote procedures used to open/close a region.
|
class |
RegionTransitionProcedure
Deprecated.
Do not use any more.
|
class |
UnassignProcedure
Deprecated.
Do not use any more.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ServerRemoteProcedure |
class |
SplitWALRemoteProcedure
A remote procedure which is used to send split WAL request to region server.
|
class |
SwitchRpcThrottleRemoteProcedure
The procedure to switch rpc throttle on region server
|
| Modifier and Type | Field and Description |
|---|---|
private Set<RemoteProcedureDispatcher.RemoteProcedure> |
RSProcedureDispatcher.ExecuteProceduresRemoteCall.remoteProcedures |
| Modifier and Type | Method and Description |
|---|---|
protected void |
RSProcedureDispatcher.abortPendingOperations(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> operations) |
protected void |
RSProcedureDispatcher.remoteDispatch(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
void |
RSProcedureDispatcher.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. |
| Constructor and Description |
|---|
RegionCloseOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo,
long procId,
ServerName destinationServer) |
RegionOpenOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo,
long procId) |
RegionOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo,
long procId) |
ServerOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
long procId,
Class<?> rsProcClass,
byte[] rsProcData) |
| Constructor and Description |
|---|
DeadRSRemoteCall(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
ExecuteProceduresRemoteCall(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
| Modifier and Type | Class and Description |
|---|---|
class |
RefreshPeerProcedure |
| Modifier and Type | Field and Description |
|---|---|
private RemoteProcedureDispatcher.RemoteProcedure |
RemoteProcedureDispatcher.RemoteOperation.remoteProcedure |
| Modifier and Type | Field and Description |
|---|---|
private Set<RemoteProcedureDispatcher.RemoteProcedure> |
RemoteProcedureDispatcher.BufferNode.dispatchedOperations |
private Set<RemoteProcedureDispatcher.RemoteProcedure> |
RemoteProcedureDispatcher.BufferNode.operations |
| Modifier and Type | Method and Description |
|---|---|
RemoteProcedureDispatcher.RemoteProcedure |
RemoteProcedureDispatcher.RemoteOperation.getRemoteProcedure() |
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteProcedureDispatcher.BufferNode.add(RemoteProcedureDispatcher.RemoteProcedure operation) |
void |
RemoteProcedureDispatcher.RemoteNode.add(RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote> operation) |
void |
RemoteProcedureDispatcher.addOperationToNode(TRemote key,
RemoteProcedureDispatcher.RemoteProcedure rp)
Add a remote rpc.
|
void |
RemoteProcedureDispatcher.BufferNode.operationCompleted(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure) |
void |
RemoteProcedureDispatcher.removeCompletedOperation(TRemote key,
RemoteProcedureDispatcher.RemoteProcedure rp) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
RemoteProcedureDispatcher.abortPendingOperations(TRemote key,
Set<RemoteProcedureDispatcher.RemoteProcedure> operations) |
protected org.apache.hbase.thirdparty.com.google.common.collect.ArrayListMultimap<Class<?>,RemoteProcedureDispatcher.RemoteOperation> |
RemoteProcedureDispatcher.buildAndGroupRequestByType(TEnv env,
TRemote remote,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
protected abstract void |
RemoteProcedureDispatcher.remoteDispatch(TRemote key,
Set<RemoteProcedureDispatcher.RemoteProcedure> operations) |
| Constructor and Description |
|---|
RemoteOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.