org.apache.hadoop.hbase

Class HBaseRpcServicesBase<S extends HBaseServerBase<?>>

java.lang.Object

org.apache.hadoop.hbase.HBaseRpcServicesBase<S>

All Implemented Interfaces:

ConfigurationObserver, HBaseRPCErrorHandler, PriorityFunction, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Direct Known Subclasses:

MasterRpcServices, RSRpcServices

@InterfaceAudience.Private
public abstract class HBaseRpcServicesBase<S extends HBaseServerBase<?>>
extends Object
implements org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, HBaseRPCErrorHandler, PriorityFunction, ConfigurationObserver

Base class for Master and RegionServer RpcServices.

Field Summary

Fields

Modifier and Type	Field and Description
private AccessChecker	accessChecker
static String	CLIENT_BOOTSTRAP_NODE_LIMIT
static int	DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT
private InetSocketAddress	isa
private static org.slf4j.Logger	LOG
protected PriorityFunction	priority
protected RpcServer	rpcServer
protected S	server
private ZKPermissionWatcher	zkPermissionWatcher

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HBaseRpcServicesBase(S server, String processName)

Method Summary

Modifier and Type	Method and Description
boolean	checkOOME(Throwable e) Check if an OOME and, if so, abort immediately to avoid creating more objects.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearSlowLogResponses	clearSlowLogsResponses(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearSlowLogResponseRequest request)
protected abstract PriorityFunction	createPriority()
protected abstract boolean	defaultReservoirEnabled()
AccessChecker	getAccessChecker()
org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetActiveMasterResponse	getActiveMaster(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetActiveMasterRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesResponse	getBootstrapNodes(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdResponse	getClusterId(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdRequest request)
org.apache.hadoop.conf.Configuration	getConfiguration()
long	getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param) Returns the deadline of the specified request.
protected abstract int	getDefaultPort()
protected abstract DNS.ServerType	getDNSServerType()
protected abstract String	getHostname(org.apache.hadoop.conf.Configuration conf, String defaultHostname)
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.LogEntry	getLogEntries(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.LogRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersResponse	getMasters(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMetaRegionLocationsResponse	getMetaRegionLocations(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMetaRegionLocationsRequest request)
protected abstract String	getPortConfigName()
int	getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user) Returns the 'priority type' of the specified request.
RpcScheduler	getRpcScheduler()
protected abstract Class<?>	getRpcSchedulerFactoryClass(org.apache.hadoop.conf.Configuration conf)
RpcServerInterface	getRpcServer()
S	getServer()
protected abstract List<RpcServer.BlockingServiceAndInterface>	getServices()
private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload>	getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request, NamedQueueRecorder namedQueueRecorder)
InetSocketAddress	getSocketAddress()
ZKPermissionWatcher	getZkPermissionWatcher()
protected void	internalStart(ZKWatcher zkWatcher)
protected void	internalStop()
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf) This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
protected void	requirePermission(String request, Permission.Action perm)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse	updateConfiguration(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)

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.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

clearCompactionQueues, clearRegionBlockCache, closeRegion, compactionSwitch, compactRegion, executeProcedures, flushRegion, getCachedFilesList, getOnlineRegion, getRegionInfo, getRegionLoad, getServerInfo, getSpaceQuotaSnapshots, getStoreFile, openRegion, replay, replicateToReplica, replicateWALEntry, rollWALWriter, stopServer, updateFavoredNodes, warmupRegion

Field Detail

LOG

private static final org.slf4j.Logger LOG

CLIENT_BOOTSTRAP_NODE_LIMIT

public static final String CLIENT_BOOTSTRAP_NODE_LIMIT

See Also:

Constant Field Values

DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT

public static final int DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT

See Also:

Constant Field Values

server

protected final S extends HBaseServerBase<?> server

rpcServer

protected final RpcServer rpcServer

isa

private final InetSocketAddress isa

priority

protected final PriorityFunction priority

accessChecker

private AccessChecker accessChecker

zkPermissionWatcher

private ZKPermissionWatcher zkPermissionWatcher

Constructor Detail

HBaseRpcServicesBase

protected HBaseRpcServicesBase(S server,
                               String processName)
                        throws IOException

Throws:

IOException

Method Detail

defaultReservoirEnabled

protected abstract boolean defaultReservoirEnabled()

getDNSServerType

protected abstract DNS.ServerType getDNSServerType()

getHostname

protected abstract String getHostname(org.apache.hadoop.conf.Configuration conf,
                                      String defaultHostname)

getPortConfigName

protected abstract String getPortConfigName()

getDefaultPort

protected abstract int getDefaultPort()

createPriority

protected abstract PriorityFunction createPriority()

getRpcSchedulerFactoryClass

protected abstract Class<?> getRpcSchedulerFactoryClass(org.apache.hadoop.conf.Configuration conf)

getServices

protected abstract List<RpcServer.BlockingServiceAndInterface> getServices()

internalStart

protected final void internalStart(ZKWatcher zkWatcher)

requirePermission

protected final void requirePermission(String request,
                                       Permission.Action perm)
                                throws IOException

Throws:

IOException

getAccessChecker

public AccessChecker getAccessChecker()

getZkPermissionWatcher

public ZKPermissionWatcher getZkPermissionWatcher()

internalStop

protected final void internalStop()

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

getServer

public S getServer()

getSocketAddress

public InetSocketAddress getSocketAddress()

getRpcServer

public RpcServerInterface getRpcServer()

getRpcScheduler

public RpcScheduler getRpcScheduler()

getPriority

public int getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
                       org.apache.hbase.thirdparty.com.google.protobuf.Message param,
                       User user)

Description copied from interface: PriorityFunction

Returns the 'priority type' of the specified request. The returned value is mainly used to select the dispatch queue.

Specified by:

getPriority in interface PriorityFunction

Returns:

Priority of this request.

getDeadline

public long getDeadline(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
                        org.apache.hbase.thirdparty.com.google.protobuf.Message param)

Description copied from interface: PriorityFunction

Returns the deadline of the specified request. The returned value is used to sort the dispatch queue.

Specified by:

getDeadline in interface PriorityFunction

Returns:

Deadline of this request. 0 now, otherwise msec of 'delay'

checkOOME

public boolean checkOOME(Throwable e)

Check if an OOME and, if so, abort immediately to avoid creating more objects.

Specified by:

checkOOME in interface HBaseRPCErrorHandler

Parameters:

e - the throwable

Returns:

True if we OOME'd and are aborting.

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

getClusterId

public org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdResponse getClusterId(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                          org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetClusterIdRequest request)
                                                                                                   throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getClusterId in interface org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getActiveMaster

public org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetActiveMasterResponse getActiveMaster(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetActiveMasterRequest request)
                                                                                                         throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getActiveMaster in interface org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getMasters

public org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersResponse getMasters(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMastersRequest request)
                                                                                               throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getMasters in interface org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getMetaRegionLocations

public org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMetaRegionLocationsResponse getMetaRegionLocations(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                              org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetMetaRegionLocationsRequest request)
                                                                                                                       throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getMetaRegionLocations in interface org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getBootstrapNodes

public final org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesResponse getBootstrapNodes(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                          org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.GetBootstrapNodesRequest request)
                                                                                                                   throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getBootstrapNodes in interface org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

updateConfiguration

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse updateConfiguration(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                     org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest request)
                                                                                                              throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

updateConfiguration in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

clearSlowLogsResponses

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearSlowLogResponses clearSlowLogsResponses(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                                                  org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearSlowLogResponseRequest request)
                                                                                                           throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

clearSlowLogsResponses in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getSlowLogPayloads

private List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> getSlowLogPayloads(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SlowLogResponseRequest request,
                                                                                                             NamedQueueRecorder namedQueueRecorder)

getLogEntries

public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.LogEntry getLogEntries(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                            org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.LogRequest request)
                                                                                     throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

getLogEntries in interface org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException