Modifier and Type | Class and Description |
---|---|
class |
AssignProcedure
Procedure that describe the assignment of a single region.
|
class |
RegionTransitionProcedure
Base class for the Assign and Unassign Procedure.
|
class |
UnassignProcedure
Procedure that describes the unassignment of a single region.
|
Modifier and Type | Class and Description |
---|---|
class |
ServerRemoteProcedure |
Modifier and Type | Field and Description |
---|---|
protected 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,
org.apache.hadoop.hbase.master.procedure.RSProcedureDispatcher.RemoteProcedureResolver resolver)
Fetches
RemoteProcedureDispatcher.RemoteOperation s
from the given remoteProcedures and groups them by class of the returned operation. |
Constructor and Description |
---|
RegionCloseOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo,
ServerName destinationServer) |
RegionOpenOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo,
List<ServerName> favoredNodes,
boolean openForReplay) |
RegionOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
RegionInfo regionInfo) |
ServerOperation(RemoteProcedureDispatcher.RemoteProcedure remoteProcedure,
long procId,
Class<?> rsProcClass,
byte[] rsProcData) |
Constructor and Description |
---|
ExecuteProceduresRemoteCall(ServerName serverName,
Set<RemoteProcedureDispatcher.RemoteProcedure> remoteProcedures) |
Modifier and Type | Class and Description |
---|---|
class |
RefreshPeerProcedure |
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–2019 Cloudera. All rights reserved.