org.apache.hadoop.hbase.regionserver.wal

Class WALCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost.WALEnvironment>

org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost

@InterfaceAudience.Private
public class WALCoprocessorHost
extends CoprocessorHost<org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost.WALEnvironment>

Implements the coprocessor environment and runtime support for coprocessors loaded within a FSHLog.

Nested Class Summary

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

CoprocessorHost.Environment

Field Summary

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

ABORT_ON_ERROR_KEY, abortable, conf, coprocessors, DEFAULT_ABORT_ON_ERROR, loadSequence, MASTER_COPROCESSOR_CONF_KEY, pathPrefix, REGION_COPROCESSOR_CONF_KEY, REGIONSERVER_COPROCESSOR_CONF_KEY, USER_REGION_COPROCESSOR_CONF_KEY, WAL_COPROCESSOR_CONF_KEY

Constructor Summary

Constructors

Constructor and Description
WALCoprocessorHost(org.apache.hadoop.hbase.regionserver.wal.FSHLog log, org.apache.hadoop.conf.Configuration conf) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.hbase.regionserver.wal.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, HLogKey logKey, WALEdit logEdit)
boolean	preWALWrite(HRegionInfo info, HLogKey logKey, WALEdit logEdit)

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

abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, load, load, loadInstance, loadSystemCoprocessors, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WALCoprocessorHost

public WALCoprocessorHost(org.apache.hadoop.hbase.regionserver.wal.FSHLog log,
                  org.apache.hadoop.conf.Configuration conf)

Constructor

Parameters:

log - the write ahead log

conf - the configuration

Method Detail

createEnvironment

public org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost.WALEnvironment createEnvironment(Class<?> implClass,
                                                                                           Coprocessor instance,
                                                                                           int priority,
                                                                                           int seq,
                                                                                           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<org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost.WALEnvironment>

preWALWrite

public boolean preWALWrite(HRegionInfo info,
                  HLogKey logKey,
                  WALEdit logEdit)
                    throws IOException

Parameters:

info -

logKey -

logEdit -

Returns:

true if default behavior should be bypassed, false otherwise

Throws:

IOException

postWALWrite

public void postWALWrite(HRegionInfo info,
                HLogKey logKey,
                WALEdit logEdit)
                  throws IOException

Parameters:

info -

logKey -

logEdit -

Throws:

IOException