@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public class RegionServerCoprocessorHost extends CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>
CoprocessorHost.EnvironmentABORT_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 |
|---|
RegionServerCoprocessorHost(RegionServerServices rsServices,
org.apache.hadoop.conf.Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment |
createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int sequence,
org.apache.hadoop.conf.Configuration conf)
Called when a new Coprocessor class is loaded
|
ReplicationEndpoint |
postCreateReplicationEndPoint(ReplicationEndpoint endpoint) |
void |
postMerge(HRegion regionA,
HRegion regionB,
HRegion mergedRegion) |
void |
postMergeCommit(HRegion regionA,
HRegion regionB,
HRegion mergedRegion) |
void |
postReplicateLogEntries(List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
postRollBackMerge(HRegion regionA,
HRegion regionB) |
void |
postRollWALWriterRequest() |
boolean |
preMerge(HRegion regionA,
HRegion regionB) |
boolean |
preMergeCommit(HRegion regionA,
HRegion regionB,
List<Mutation> metaEntries) |
void |
preReplicateLogEntries(List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
preRollBackMerge(HRegion regionA,
HRegion regionB) |
void |
preRollWALWriterRequest() |
void |
preStop(String message) |
abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethodpublic RegionServerCoprocessorHost(RegionServerServices rsServices, org.apache.hadoop.conf.Configuration conf)
public org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment createEnvironment(Class<?> implClass, Coprocessor instance, int priority, int sequence, org.apache.hadoop.conf.Configuration conf)
CoprocessorHostcreateEnvironment in class CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>public void preStop(String message) throws IOException
IOExceptionpublic boolean preMerge(HRegion regionA, HRegion regionB) throws IOException
IOExceptionpublic void postMerge(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws IOException
IOExceptionpublic boolean preMergeCommit(HRegion regionA, HRegion regionB, @MetaMutationAnnotation List<Mutation> metaEntries) throws IOException
IOExceptionpublic void postMergeCommit(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws IOException
IOExceptionpublic void preRollBackMerge(HRegion regionA, HRegion regionB) throws IOException
IOExceptionpublic void postRollBackMerge(HRegion regionA, HRegion regionB) throws IOException
IOExceptionpublic void preRollWALWriterRequest()
throws IOException
IOExceptionpublic void postRollWALWriterRequest()
throws IOException
IOExceptionpublic void preReplicateLogEntries(List<AdminProtos.WALEntry> entries, CellScanner cells) throws IOException
IOExceptionpublic void postReplicateLogEntries(List<AdminProtos.WALEntry> entries, CellScanner cells) throws IOException
IOExceptionpublic ReplicationEndpoint postCreateReplicationEndPoint(ReplicationEndpoint endpoint) throws IOException
IOExceptionCopyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.