@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,
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<org.apache.hadoop.hbase.protobuf.generated.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<org.apache.hadoop.hbase.protobuf.generated.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, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethod
public 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)
CoprocessorHost
createEnvironment
in class CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>
public void preStop(String message) throws IOException
IOException
public boolean preMerge(HRegion regionA, HRegion regionB) throws IOException
IOException
public void postMerge(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws IOException
IOException
public boolean preMergeCommit(HRegion regionA, HRegion regionB, @MetaMutationAnnotation List<Mutation> metaEntries) throws IOException
IOException
public void postMergeCommit(HRegion regionA, HRegion regionB, HRegion mergedRegion) throws IOException
IOException
public void preRollBackMerge(HRegion regionA, HRegion regionB) throws IOException
IOException
public void postRollBackMerge(HRegion regionA, HRegion regionB) throws IOException
IOException
public void preRollWALWriterRequest() throws IOException
IOException
public void postRollWALWriterRequest() throws IOException
IOException
public void preReplicateLogEntries(List<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries, CellScanner cells) throws IOException
IOException
public void postReplicateLogEntries(List<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.WALEntry> entries, CellScanner cells) throws IOException
IOException
public ReplicationEndpoint postCreateReplicationEndPoint(ReplicationEndpoint endpoint) throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.