Package org.apache.hadoop.hbase.ipc

Class RpcCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<RpcCoprocessor,RpcCoprocessorEnvironment>

org.apache.hadoop.hbase.ipc.RpcCoprocessorHost

@Private
public class RpcCoprocessorHost
extends CoprocessorHost<RpcCoprocessor,RpcCoprocessorEnvironment>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	RpcCoprocessorHost.RpcEnvironment
(package private) class	RpcCoprocessorHost.RpcObserverOperation

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

CoprocessorHost.ObserverGetter<C,O>, CoprocessorHost.ObserverOperationWithoutResult<O>, CoprocessorHost.ObserverOperationWithResult<O,R>

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final CoprocessorHost.ObserverGetter<RpcCoprocessor,RpcObserver>	rpcObserverGetter

Fields inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

ABORT_ON_ERROR_KEY, abortable, conf, coprocEnvironments, COPROCESSORS_ENABLED_CONF_KEY, DEFAULT_ABORT_ON_ERROR, DEFAULT_COPROCESSORS_ENABLED, DEFAULT_SKIP_LOAD_DUPLICATE_TABLE_COPROCESSOR, DEFAULT_USER_COPROCESSORS_ENABLED, loadSequence, MASTER_COPROCESSOR_CONF_KEY, pathPrefix, REGION_COPROCESSOR_CONF_KEY, REGIONSERVER_COPROCESSOR_CONF_KEY, RPC_COPROCESSOR_CONF_KEY, SKIP_LOAD_DUPLICATE_TABLE_COPROCESSOR, USER_COPROCESSORS_ENABLED_CONF_KEY, USER_REGION_COPROCESSOR_CONF_KEY, WAL_COPROCESSOR_CONF_KEY

Constructor Summary

Constructors

Constructor	Description
RpcCoprocessorHost(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
RpcCoprocessor	checkAndGetInstance(Class<?> implClass)	Called when a new Coprocessor class needs to be loaded.
RpcCoprocessorEnvironment	createEnvironment(RpcCoprocessor instance, int priority, int sequence, org.apache.hadoop.conf.Configuration conf)	Called when a new Coprocessor class is loaded
void	postAuthorizeConnection(String userName, X509Certificate[] clientCertificates)
void	preAuthorizeConnection(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader, InetAddress remoteAddr)

Methods inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost

abortServer, abortServer, checkAndLoadInstance, execOperation, execOperationWithResult, execShutdown, findCoprocessor, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, load, load, load, loadSystemCoprocessors, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

rpcObserverGetter

private final CoprocessorHost.ObserverGetter<RpcCoprocessor,RpcObserver> rpcObserverGetter

Constructor Details

RpcCoprocessorHost

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

Method Details

createEnvironment

public RpcCoprocessorEnvironment createEnvironment(RpcCoprocessor instance,
 int priority,
 int sequence,
 org.apache.hadoop.conf.Configuration conf)

Description copied from class: CoprocessorHost

Called when a new Coprocessor class is loaded

Specified by:

createEnvironment in class CoprocessorHost<RpcCoprocessor,RpcCoprocessorEnvironment>

checkAndGetInstance

public RpcCoprocessor checkAndGetInstance(Class<?> implClass)
                                   throws InstantiationException,
IllegalAccessException

Description copied from class: CoprocessorHost

Called when a new Coprocessor class needs to be loaded. Checks if type of the given class is what the corresponding host implementation expects. If it is of correct type, returns an instance of the coprocessor to be loaded. If not, returns null. If an exception occurs when trying to create instance of a coprocessor, it's passed up and eventually results into server aborting.

Specified by:

checkAndGetInstance in class CoprocessorHost<RpcCoprocessor,RpcCoprocessorEnvironment>

Throws:

InstantiationException

IllegalAccessException

preAuthorizeConnection

public void preAuthorizeConnection(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader,
 InetAddress remoteAddr)
                            throws IOException

Throws:

IOException

postAuthorizeConnection

public void postAuthorizeConnection(String userName,
 X509Certificate[] clientCertificates)
                             throws IOException

Throws:

IOException