@InterfaceAudience.Private public class WALCoprocessorHost extends CoprocessorHost<WALCoprocessorHost.WALEnvironment>
WAL.| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
WALCoprocessorHost.WALEnvironment
Encapsulation of the environment of each coprocessor
|
CoprocessorHost.Environment| Modifier and Type | Field and Description |
|---|---|
private WAL |
wal |
ABORT_ON_ERROR_KEY, abortable, conf, coprocessors, COPROCESSORS_ENABLED_CONF_KEY, DEFAULT_ABORT_ON_ERROR, DEFAULT_COPROCESSORS_ENABLED, DEFAULT_USER_COPROCESSORS_ENABLED, loadSequence, MASTER_COPROCESSOR_CONF_KEY, pathPrefix, REGION_COPROCESSOR_CONF_KEY, REGIONSERVER_COPROCESSOR_CONF_KEY, 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 |
|---|---|
WALCoprocessorHost.WALEnvironment |
createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf)
Called when a new Coprocessor class is loaded
|
void |
postWALWrite(HRegionInfo info,
WALKey logKey,
WALEdit logEdit) |
boolean |
preWALWrite(HRegionInfo info,
WALKey logKey,
WALEdit logEdit) |
abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethodprivate final WAL wal
public WALCoprocessorHost(WAL log, org.apache.hadoop.conf.Configuration conf)
log - the write ahead logconf - the configurationpublic WALCoprocessorHost.WALEnvironment createEnvironment(Class<?> implClass, Coprocessor instance, int priority, int seq, org.apache.hadoop.conf.Configuration conf)
CoprocessorHostcreateEnvironment in class CoprocessorHost<WALCoprocessorHost.WALEnvironment>public boolean preWALWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
info - logKey - logEdit - IOExceptionpublic void postWALWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
info - logKey - logEdit - IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.