@InterfaceAudience.Private public class WALCoprocessorHost extends CoprocessorHost<WALCoprocessor,WALCoprocessorEnvironment>
WAL
.Modifier and Type | Class and Description |
---|---|
(package private) static class |
WALCoprocessorHost.WALEnvironment
Encapsulation of the environment of each coprocessor
|
(package private) class |
WALCoprocessorHost.WALObserverOperation |
CoprocessorHost.ObserverGetter<C,O>, CoprocessorHost.ObserverOperationWithoutResult<O>, CoprocessorHost.ObserverOperationWithResult<O,R>
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private WAL |
wal |
private CoprocessorHost.ObserverGetter<WALCoprocessor,WALObserver> |
walObserverGetter |
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 and Description |
---|
WALCoprocessorHost(WAL log,
org.apache.hadoop.conf.Configuration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
WALCoprocessor |
checkAndGetInstance(Class<?> implClass)
Called when a new Coprocessor class needs to be loaded.
|
WALCoprocessorHost.WALEnvironment |
createEnvironment(WALCoprocessor instance,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf)
Called when a new Coprocessor class is loaded
|
void |
postWALRoll(org.apache.hadoop.fs.Path oldPath,
org.apache.hadoop.fs.Path newPath)
Called after rolling the current WAL
|
void |
postWALWrite(RegionInfo info,
WALKey logKey,
WALEdit logEdit) |
void |
preWALRoll(org.apache.hadoop.fs.Path oldPath,
org.apache.hadoop.fs.Path newPath)
Called before rolling the current WAL
|
void |
preWALWrite(RegionInfo info,
WALKey logKey,
WALEdit logEdit) |
abortServer, abortServer, checkAndLoadInstance, execOperation, execOperationWithResult, execShutdown, findCoprocessor, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, load, load, load, loadSystemCoprocessors, shutdown
private static final org.slf4j.Logger LOG
private CoprocessorHost.ObserverGetter<WALCoprocessor,WALObserver> walObserverGetter
public WALCoprocessorHost(WAL log, org.apache.hadoop.conf.Configuration conf)
log
- the write ahead logconf
- the configurationpublic WALCoprocessorHost.WALEnvironment createEnvironment(WALCoprocessor instance, int priority, int seq, org.apache.hadoop.conf.Configuration conf)
CoprocessorHost
createEnvironment
in class CoprocessorHost<WALCoprocessor,WALCoprocessorEnvironment>
public WALCoprocessor checkAndGetInstance(Class<?> implClass) throws IllegalAccessException, InstantiationException
CoprocessorHost
checkAndGetInstance
in class CoprocessorHost<WALCoprocessor,WALCoprocessorEnvironment>
IllegalAccessException
InstantiationException
public void preWALWrite(RegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
IOException
public void postWALWrite(RegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
IOException
public void preWALRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path of the current wal that we are replacingnewPath
- the path of the wal we are going to createIOException
public void postWALRoll(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) throws IOException
oldPath
- the path of the wal that we replacednewPath
- the path of the wal we have created and now is the currentIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.