@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, useLegacyMethod
private 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)
CoprocessorHost
createEnvironment
in class CoprocessorHost<WALCoprocessorHost.WALEnvironment>
public boolean preWALWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
info
- logKey
- logEdit
- IOException
public void postWALWrite(HRegionInfo info, WALKey logKey, WALEdit logEdit) throws IOException
info
- logKey
- logEdit
- IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.