@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public class RegionServerCoprocessorHost extends CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>
CoprocessorHost.Environment
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 |
---|
RegionServerCoprocessorHost(RegionServerServices rsServices,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment |
createEnvironment(java.lang.Class<?> implClass,
Coprocessor instance,
int priority,
int sequence,
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(java.util.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,
java.util.List<Mutation> metaEntries) |
void |
preReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
preRollBackMerge(HRegion regionA,
HRegion regionB) |
void |
preRollWALWriterRequest() |
void |
preStop(java.lang.String message) |
abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethod
public RegionServerCoprocessorHost(RegionServerServices rsServices, Configuration conf)
public org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment createEnvironment(java.lang.Class<?> implClass, Coprocessor instance, int priority, int sequence, Configuration conf)
CoprocessorHost
createEnvironment
in class CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>
public void preStop(java.lang.String message) throws java.io.IOException
java.io.IOException
public boolean preMerge(HRegion regionA, HRegion regionB) throws java.io.IOException
java.io.IOException
public void postMerge(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws java.io.IOException
java.io.IOException
public boolean preMergeCommit(HRegion regionA, HRegion regionB, @MetaMutationAnnotation java.util.List<Mutation> metaEntries) throws java.io.IOException
java.io.IOException
public void postMergeCommit(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws java.io.IOException
java.io.IOException
public void preRollBackMerge(HRegion regionA, HRegion regionB) throws java.io.IOException
java.io.IOException
public void postRollBackMerge(HRegion regionA, HRegion regionB) throws java.io.IOException
java.io.IOException
public void preRollWALWriterRequest() throws java.io.IOException
java.io.IOException
public void postRollWALWriterRequest() throws java.io.IOException
java.io.IOException
public void preReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries, CellScanner cells) throws java.io.IOException
java.io.IOException
public void postReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries, CellScanner cells) throws java.io.IOException
java.io.IOException
public ReplicationEndpoint postCreateReplicationEndPoint(ReplicationEndpoint endpoint) throws java.io.IOException
java.io.IOException