org.apache.hadoop.hbase.regionserver

Class RegionServerCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>

org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost

@InterfaceAudience.LimitedPrivate(value="Coprocesssor")
 @InterfaceStability.Evolving
public class RegionServerCoprocessorHost
extends CoprocessorHost<org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment>

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, 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 Summary

Constructors

Constructor and Description
RegionServerCoprocessorHost(RegionServerServices rsServices, Configuration conf)

Method Summary

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)

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

abortServer, abortServer, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, legacyWarning, load, load, loadInstance, loadSystemCoprocessors, shutdown, useLegacyMethod

Methods inherited from class java.lang.Object

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

Constructor Detail

RegionServerCoprocessorHost

public RegionServerCoprocessorHost(RegionServerServices rsServices,
                                   Configuration conf)

Method Detail

createEnvironment

public org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment createEnvironment(java.lang.Class<?> implClass,
                                                                                                                  Coprocessor instance,
                                                                                                                  int priority,
                                                                                                                  int sequence,
                                                                                                                  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.RegionServerCoprocessorHost.RegionServerEnvironment>

preStop

public void preStop(java.lang.String message)
             throws java.io.IOException

Throws:

java.io.IOException

preMerge

public boolean preMerge(HRegion regionA,
                        HRegion regionB)
                 throws java.io.IOException

Throws:

java.io.IOException

postMerge

public void postMerge(HRegion regionA,
                      HRegion regionB,
                      HRegion mergedRegion)
               throws java.io.IOException

Throws:

java.io.IOException

preMergeCommit

public boolean preMergeCommit(HRegion regionA,
                              HRegion regionB,
                              @MetaMutationAnnotation
                              java.util.List<Mutation> metaEntries)
                       throws java.io.IOException

Throws:

java.io.IOException

postMergeCommit

public void postMergeCommit(HRegion regionA,
                            HRegion regionB,
                            HRegion mergedRegion)
                     throws java.io.IOException

Throws:

java.io.IOException

preRollBackMerge

public void preRollBackMerge(HRegion regionA,
                             HRegion regionB)
                      throws java.io.IOException

Throws:

java.io.IOException

postRollBackMerge

public void postRollBackMerge(HRegion regionA,
                              HRegion regionB)
                       throws java.io.IOException

Throws:

java.io.IOException

preRollWALWriterRequest

public void preRollWALWriterRequest()
                             throws java.io.IOException

Throws:

java.io.IOException

postRollWALWriterRequest

public void postRollWALWriterRequest()
                              throws java.io.IOException

Throws:

java.io.IOException

preReplicateLogEntries

public void preReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
                                   CellScanner cells)
                            throws java.io.IOException

Throws:

java.io.IOException

postReplicateLogEntries

public void postReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
                                    CellScanner cells)
                             throws java.io.IOException

Throws:

java.io.IOException

postCreateReplicationEndPoint

public ReplicationEndpoint postCreateReplicationEndPoint(ReplicationEndpoint endpoint)
                                                  throws java.io.IOException

Throws:

java.io.IOException