Package org.apache.hadoop.hbase.regionserver

Class RegionServerCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<RegionServerCoprocessor,RegionServerCoprocessorEnvironment>

org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost

@Private
public class RegionServerCoprocessorHost
extends CoprocessorHost<RegionServerCoprocessor,RegionServerCoprocessorEnvironment>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	RegionServerCoprocessorHost.RegionServerEnvironment	Coprocessor environment extension providing access to region server related services.
private static class	RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors	Special version of RegionServerEnvironment that exposes RegionServerServices for Core Coprocessors only.
(package private) class	RegionServerCoprocessorHost.RegionServerObserverOperation

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 CoprocessorHost.ObserverGetter<RegionServerCoprocessor,RegionServerObserver>	rsObserverGetter
private RegionServerServices	rsServices

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, SKIP_LOAD_DUPLICATE_TABLE_COPROCESSOR, USER_COPROCESSORS_ENABLED_CONF_KEY, USER_REGION_COPROCESSOR_CONF_KEY, WAL_COPROCESSOR_CONF_KEY

Constructor Summary

Constructors

Constructor	Description
RegionServerCoprocessorHost(RegionServerServices rsServices, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
RegionServerCoprocessor	checkAndGetInstance(Class<?> implClass)	Called when a new Coprocessor class needs to be loaded.
RegionServerCoprocessorHost.RegionServerEnvironment	createEnvironment(RegionServerCoprocessor instance, int priority, int sequence, org.apache.hadoop.conf.Configuration conf)	Called when a new Coprocessor class is loaded
void	postClearCompactionQueues()
void	postClearRegionBlockCache(CacheEvictionStats stats)
ReplicationEndpoint	postCreateReplicationEndPoint(ReplicationEndpoint endpoint)
void	postExecuteProcedures()
void	postReplicateLogEntries()
void	postReplicationSinkBatchMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, Mutation mutation)
void	postRollWALWriterRequest()
void	postUpdateConfiguration(org.apache.hadoop.conf.Configuration postReloadConf)
void	preClearCompactionQueues()
void	preClearRegionBlockCache()
void	preExecuteProcedures()
void	preReplicateLogEntries()
void	preReplicationSinkBatchMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, Mutation mutation)
void	preRollWALWriterRequest()
void	preStop(String message, User user)
void	preUpdateConfiguration(org.apache.hadoop.conf.Configuration preReloadConf)

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

rsServices

private RegionServerServices rsServices

rsObserverGetter

private CoprocessorHost.ObserverGetter<RegionServerCoprocessor,RegionServerObserver> rsObserverGetter

Constructor Details

RegionServerCoprocessorHost

public RegionServerCoprocessorHost(RegionServerServices rsServices,
 org.apache.hadoop.conf.Configuration conf)

Method Details

createEnvironment

public RegionServerCoprocessorHost.RegionServerEnvironment createEnvironment(RegionServerCoprocessor 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<RegionServerCoprocessor,RegionServerCoprocessorEnvironment>

checkAndGetInstance

public RegionServerCoprocessor 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<RegionServerCoprocessor,RegionServerCoprocessorEnvironment>

Throws:

InstantiationException

IllegalAccessException

preStop

public void preStop(String message,
 User user)
             throws IOException

Throws:

IOException

preRollWALWriterRequest

public void preRollWALWriterRequest()
                             throws IOException

Throws:

IOException

postRollWALWriterRequest

public void postRollWALWriterRequest()
                              throws IOException

Throws:

IOException

preReplicateLogEntries

public void preReplicateLogEntries()
                            throws IOException

Throws:

IOException

postReplicateLogEntries

public void postReplicateLogEntries()
                             throws IOException

Throws:

IOException

preReplicationSinkBatchMutate

public void preReplicationSinkBatchMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry,
 Mutation mutation)
                                   throws IOException

Throws:

IOException

postReplicationSinkBatchMutate

public void postReplicationSinkBatchMutate(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry,
 Mutation mutation)
                                    throws IOException

Throws:

IOException

postCreateReplicationEndPoint

public ReplicationEndpoint postCreateReplicationEndPoint(ReplicationEndpoint endpoint)
                                                  throws IOException

Throws:

IOException

preClearCompactionQueues

public void preClearCompactionQueues()
                              throws IOException

Throws:

IOException

postClearCompactionQueues

public void postClearCompactionQueues()
                               throws IOException

Throws:

IOException

preExecuteProcedures

public void preExecuteProcedures()
                          throws IOException

Throws:

IOException

postExecuteProcedures

public void postExecuteProcedures()
                           throws IOException

Throws:

IOException

preUpdateConfiguration

public void preUpdateConfiguration(org.apache.hadoop.conf.Configuration preReloadConf)
                            throws IOException

Throws:

IOException

postUpdateConfiguration

public void postUpdateConfiguration(org.apache.hadoop.conf.Configuration postReloadConf)
                             throws IOException

Throws:

IOException

preClearRegionBlockCache

public void preClearRegionBlockCache()
                              throws IOException

Throws:

IOException

postClearRegionBlockCache

public void postClearRegionBlockCache(CacheEvictionStats stats)
                               throws IOException

Throws:

IOException