Package org.apache.hadoop.hbase.coprocessor

Class ClientMetaCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<ClientMetaCoprocessor,ClientMetaCoprocessorEnvironment>

org.apache.hadoop.hbase.coprocessor.ClientMetaCoprocessorHost

@Private
public class ClientMetaCoprocessorHost
extends CoprocessorHost<ClientMetaCoprocessor,ClientMetaCoprocessorEnvironment>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ClientMetaCoprocessorHost.ClientMetaEnvironment

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

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

Field Summary

Fields

Modifier and Type	Field	Description
private final CoprocessorHost.ObserverGetter<ClientMetaCoprocessor,ClientMetaObserver>	clientMetaObserverGetter
private static final org.slf4j.Logger	LOG

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

ABORT_ON_ERROR_KEY, abortable, CLIENT_META_COPROCESSOR_CONF_KEY, 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
ClientMetaCoprocessorHost(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
ClientMetaCoprocessor	checkAndGetInstance(Class<?> implClass)	Called when a new Coprocessor class needs to be loaded.
ClientMetaCoprocessorEnvironment	createEnvironment(ClientMetaCoprocessor instance, int priority, int sequence, org.apache.hadoop.conf.Configuration conf)	Called when a new Coprocessor class is loaded
ServerName	postGetActiveMaster(ServerName serverName)
List<ServerName>	postGetBootstrapNodes(List<ServerName> bootstrapNodes)
String	postGetClusterId(String clusterId)
Map<ServerName,Boolean>	postGetMasters(Map<ServerName,Boolean> serverNames)
List<HRegionLocation>	postGetMetaLocations(List<HRegionLocation> metaLocations)
void	preGetActiveMaster()
void	preGetBootstrapNodes()
void	preGetClusterId()
void	preGetMasters()
void	preGetMetaLocations()

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

abortServer, abortServer, checkAndLoadInstance, execOperation, execOperationWithResult, execShutdown, findCoprocessor, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessorClassNames, getCoprocessors, getExternalClassLoaders, 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

clientMetaObserverGetter

private final CoprocessorHost.ObserverGetter<ClientMetaCoprocessor,ClientMetaObserver> clientMetaObserverGetter

Constructor Details

ClientMetaCoprocessorHost

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

Method Details

createEnvironment

public ClientMetaCoprocessorEnvironment createEnvironment(ClientMetaCoprocessor 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<ClientMetaCoprocessor,ClientMetaCoprocessorEnvironment>

checkAndGetInstance

public ClientMetaCoprocessor 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<ClientMetaCoprocessor,ClientMetaCoprocessorEnvironment>

Throws:

InstantiationException

IllegalAccessException

preGetClusterId

public void preGetClusterId()
                     throws IOException

Throws:

IOException

postGetClusterId

public String postGetClusterId(String clusterId)
                        throws IOException

Throws:

IOException

preGetActiveMaster

public void preGetActiveMaster()
                        throws IOException

Throws:

IOException

postGetActiveMaster

public ServerName postGetActiveMaster(ServerName serverName)
                               throws IOException

Throws:

IOException

preGetMasters

public void preGetMasters()
                   throws IOException

Throws:

IOException

postGetMasters

public Map<ServerName,Boolean> postGetMasters(Map<ServerName,Boolean> serverNames)
                                       throws IOException

Throws:

IOException

preGetBootstrapNodes

public void preGetBootstrapNodes()
                          throws IOException

Throws:

IOException

postGetBootstrapNodes

public List<ServerName> postGetBootstrapNodes(List<ServerName> bootstrapNodes)
                                       throws IOException

Throws:

IOException

preGetMetaLocations

public void preGetMetaLocations()
                         throws IOException

Throws:

IOException

postGetMetaLocations

public List<HRegionLocation> postGetMetaLocations(List<HRegionLocation> metaLocations)
                                           throws IOException

Throws:

IOException