MasterCoprocessorHost (Apache HBase 2.2.3 API)

java.lang.Object
- org.apache.hadoop.hbase.coprocessor.CoprocessorHost<MasterCoprocessor,MasterCoprocessorEnvironment>
- - org.apache.hadoop.hbase.master.MasterCoprocessorHost

```
@InterfaceAudience.Private
public class MasterCoprocessorHost
extends CoprocessorHost<MasterCoprocessor,MasterCoprocessorEnvironment>
```
Provides the coprocessor framework and environment for master oriented operations. HMaster interacts with the loaded coprocessors through this class.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`private static class`	`MasterCoprocessorHost.MasterEnvironment` Coprocessor environment extension providing access to master related services.
`private static class`	`MasterCoprocessorHost.MasterEnvironmentForCoreCoprocessors` Special version of MasterEnvironment that exposes MasterServices for Core Coprocessors only.
`(package private) class`	`MasterCoprocessorHost.MasterObserverOperation`

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost
CoprocessorHost.ObserverGetter<C,O>, CoprocessorHost.ObserverOperationWithoutResult<O>, CoprocessorHost.ObserverOperationWithResult<O,R>

Field Summary

Fields
Modifier and Type	Field and Description
`private static org.slf4j.Logger`	`LOG`
`private CoprocessorHost.ObserverGetter<MasterCoprocessor,MasterObserver>`	`masterObserverGetter`
`private MasterServices`	`masterServices`

Constructor Summary

Constructors
Constructor and Description

MasterCoprocessorHost(MasterServices services, org.apache.hadoop.conf.Configuration conf)

Constructors
Constructor and Description
`MasterCoprocessorHost(MasterServices services, org.apache.hadoop.conf.Configuration conf)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`MasterCoprocessor`	`checkAndGetInstance(Class<?> implClass)` Called when a new Coprocessor class needs to be loaded.
`MasterCoprocessorHost.MasterEnvironment`	`createEnvironment(MasterCoprocessor instance, int priority, int seq, org.apache.hadoop.conf.Configuration conf)` Called when a new Coprocessor class is loaded
`void`	`postAbortProcedure()`
`void`	`postAddReplicationPeer(String peerId, ReplicationPeerConfig peerConfig)`
`void`	`postAddRSGroup(String name)`
`void`	`postAssign(RegionInfo regionInfo)`
`void`	`postBalance(List<RegionPlan> plans)`
`void`	`postBalanceRSGroup(String name, boolean balanceRan)`
`void`	`postBalanceSwitch(boolean oldValue, boolean newValue)`
`void`	`postClearDeadServers(List<ServerName> servers, List<ServerName> notClearedServers)`
`void`	`postCloneSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`postCompletedCreateTableAction(TableDescriptor htd, RegionInfo[] regions, User user)`
`void`	`postCompletedDeleteTableAction(TableName tableName, User user)`
`void`	`postCompletedDisableTableAction(TableName tableName, User user)`
`void`	`postCompletedEnableTableAction(TableName tableName, User user)`
`void`	`postCompletedMergeRegionsAction(RegionInfo[] regionsToMerge, RegionInfo mergedRegion, User user)` Invoked after completing merge regions operation
`void`	`postCompletedModifyTableAction(TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor, User user)`
`void`	`postCompletedSplitRegionAction(RegionInfo regionInfoA, RegionInfo regionInfoB, User user)` Invoked just after a split
`void`	`postCompletedTruncateTableAction(TableName tableName, User user)`
`void`	`postCreateNamespace(NamespaceDescriptor ns)`
`void`	`postCreateTable(TableDescriptor htd, RegionInfo[] regions)`
`void`	`postDecommissionRegionServers(List<ServerName> servers, boolean offload)`
`void`	`postDeleteNamespace(String namespaceName)`
`void`	`postDeleteSnapshot(SnapshotDescription snapshot)`
`void`	`postDeleteTable(TableName tableName)`
`void`	`postDisableReplicationPeer(String peerId)`
`void`	`postDisableTable(TableName tableName)`
`void`	`postEnableReplicationPeer(String peerId)`
`void`	`postEnableTable(TableName tableName)`
`void`	`postGetClusterMetrics(ClusterMetrics status)`
`void`	`postGetLocks(List<LockedResource> lockedResources)`
`void`	`postGetNamespaceDescriptor(NamespaceDescriptor ns)`
`void`	`postGetProcedures(List<Procedure<?>> procInfoList)`
`void`	`postGetReplicationPeerConfig(String peerId)`
`void`	`postGetTableDescriptors(List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex)`
`void`	`postGetTableNames(List<TableDescriptor> descriptors, String regex)`
`void`	`postGetUserPermissions(String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier)`
`void`	`postGrant(UserPermission userPermission, boolean mergeExistingPermissions)`
`void`	`postHasUserPermissions(String userName, List<Permission> permissions)`
`void`	`postIsRpcThrottleEnabled(boolean enabled)`
`void`	`postListDecommissionedRegionServers()`
`void`	`postListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)`
`void`	`postListReplicationPeers(String regex)`
`void`	`postListSnapshot(SnapshotDescription snapshot)`
`void`	`postLockHeartbeat(LockProcedure proc, boolean keepAlive)`
`void`	`postMergeRegions(RegionInfo[] regionsToMerge)`
`void`	`postMergeRegionsCommit(RegionInfo[] regionsToMerge, RegionInfo mergedRegion, User user)` Invoked after merge regions operation writes the new region to hbase:meta
`void`	`postModifyNamespace(NamespaceDescriptor oldNsDescriptor, NamespaceDescriptor currentNsDescriptor)`
`void`	`postModifyTable(TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor)`
`void`	`postMove(RegionInfo region, ServerName srcServer, ServerName destServer)`
`void`	`postMoveServers(Set<Address> servers, String targetGroup)`
`void`	`postMoveServersAndTables(Set<Address> servers, Set<TableName> tables, String targetGroup)`
`void`	`postMoveTables(Set<TableName> tables, String targetGroup)`
`void`	`postRecommissionRegionServer(ServerName server, List<byte[]> encodedRegionNames)`
`void`	`postRegionOffline(RegionInfo regionInfo)`
`void`	`postRemoveReplicationPeer(String peerId)`
`void`	`postRemoveRSGroup(String name)`
`void`	`postRemoveServers(Set<Address> servers)`
`void`	`postRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos, LockType type, String description)`
`void`	`postRestoreSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`postRevoke(UserPermission userPermission)`
`void`	`postRollBackMergeRegionsAction(RegionInfo[] regionsToMerge, User user)` Invoked after rollback merge regions operation
`void`	`postRollBackSplitRegionAction(User user)` Invoked just after the rollback of a failed split
`void`	`postSetNamespaceQuota(String namespace, GlobalQuotaSettings quotas)`
`void`	`postSetRegionServerQuota(String regionServer, GlobalQuotaSettings quotas)`
`void`	`postSetSplitOrMergeEnabled(boolean newValue, MasterSwitchType switchType)`
`void`	`postSetTableQuota(TableName table, GlobalQuotaSettings quotas)`
`void`	`postSetUserQuota(String user, GlobalQuotaSettings quotas)`
`void`	`postSetUserQuota(String user, String namespace, GlobalQuotaSettings quotas)`
`void`	`postSetUserQuota(String user, TableName table, GlobalQuotaSettings quotas)`
`void`	`postSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`postStartMaster()`
`void`	`postSwitchExceedThrottleQuota(boolean oldValue, boolean newValue)`
`void`	`postSwitchRpcThrottle(boolean oldValue, boolean newValue)`
`void`	`postTableFlush(TableName tableName)`
`void`	`postTruncateTable(TableName tableName)`
`void`	`postUnassign(RegionInfo regionInfo, boolean force)`
`void`	`postUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)`
`void`	`preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv, long procId)`
`void`	`preAddReplicationPeer(String peerId, ReplicationPeerConfig peerConfig)`
`void`	`preAddRSGroup(String name)`
`void`	`preAssign(RegionInfo regionInfo)`
`boolean`	`preBalance()`
`void`	`preBalanceRSGroup(String name)`
`void`	`preBalanceSwitch(boolean b)`
`void`	`preClearDeadServers()`
`void`	`preCloneSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`preCreateNamespace(NamespaceDescriptor ns)`
`void`	`preCreateTable(TableDescriptor htd, RegionInfo[] regions)`
`void`	`preCreateTableAction(TableDescriptor htd, RegionInfo[] regions, User user)`
`TableDescriptor`	`preCreateTableRegionsInfos(TableDescriptor desc)`
`void`	`preDecommissionRegionServers(List<ServerName> servers, boolean offload)`
`void`	`preDeleteNamespace(String namespaceName)`
`void`	`preDeleteSnapshot(SnapshotDescription snapshot)`
`void`	`preDeleteTable(TableName tableName)`
`void`	`preDeleteTableAction(TableName tableName, User user)`
`void`	`preDisableReplicationPeer(String peerId)`
`void`	`preDisableTable(TableName tableName)`
`void`	`preDisableTableAction(TableName tableName, User user)`
`void`	`preEnableReplicationPeer(String peerId)`
`void`	`preEnableTable(TableName tableName)`
`void`	`preEnableTableAction(TableName tableName, User user)`
`void`	`preGetClusterMetrics()`
`void`	`preGetLocks()`
`void`	`preGetNamespaceDescriptor(String namespaceName)`
`void`	`preGetProcedures()`
`void`	`preGetReplicationPeerConfig(String peerId)`
`void`	`preGetTableDescriptors(List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex)`
`void`	`preGetTableNames(List<TableDescriptor> descriptors, String regex)`
`void`	`preGetUserPermissions(String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier)`
`void`	`preGrant(UserPermission userPermission, boolean mergeExistingPermissions)`
`void`	`preHasUserPermissions(String userName, List<Permission> permissions)`
`void`	`preIsRpcThrottleEnabled()`
`void`	`preListDecommissionedRegionServers()`
`void`	`preListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)`
`void`	`preListReplicationPeers(String regex)`
`void`	`preListSnapshot(SnapshotDescription snapshot)`
`void`	`preLockHeartbeat(LockProcedure proc, boolean keepAlive)`
`void`	`preMasterInitialization()`
`void`	`preMergeRegions(RegionInfo[] regionsToMerge)`
`void`	`preMergeRegionsAction(RegionInfo[] regionsToMerge, User user)` Invoked just before a merge
`void`	`preMergeRegionsCommit(RegionInfo[] regionsToMerge, List<Mutation> metaEntries, User user)` Invoked before merge regions operation writes the new region to hbase:meta
`void`	`preModifyNamespace(NamespaceDescriptor currentNsDescriptor, NamespaceDescriptor newNsDescriptor)`
`TableDescriptor`	`preModifyTable(TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor)`
`void`	`preModifyTableAction(TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor, User user)`
`void`	`preMove(RegionInfo region, ServerName srcServer, ServerName destServer)`
`void`	`preMoveServers(Set<Address> servers, String targetGroup)`
`void`	`preMoveServersAndTables(Set<Address> servers, Set<TableName> tables, String targetGroup)`
`void`	`preMoveTables(Set<TableName> tables, String targetGroup)`
`void`	`preRecommissionRegionServer(ServerName server, List<byte[]> encodedRegionNames)`
`void`	`preRegionOffline(RegionInfo regionInfo)`
`void`	`preRemoveReplicationPeer(String peerId)`
`void`	`preRemoveRSGroup(String name)`
`void`	`preRemoveServers(Set<Address> servers)`
`void`	`preRequestLock(String namespace, TableName tableName, RegionInfo[] regionInfos, LockType type, String description)`
`void`	`preRestoreSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`preRevoke(UserPermission userPermission)`
`void`	`preSetNamespaceQuota(String namespace, GlobalQuotaSettings quotas)`
`void`	`preSetRegionServerQuota(String regionServer, GlobalQuotaSettings quotas)`
`void`	`preSetSplitOrMergeEnabled(boolean newValue, MasterSwitchType switchType)`
`void`	`preSetTableQuota(TableName table, GlobalQuotaSettings quotas)`
`void`	`preSetUserQuota(String user, GlobalQuotaSettings quotas)`
`void`	`preSetUserQuota(String user, String namespace, GlobalQuotaSettings quotas)`
`void`	`preSetUserQuota(String user, TableName table, GlobalQuotaSettings quotas)`
`void`	`preShutdown()`
`void`	`preSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)`
`void`	`preSplitAfterMETAAction(User user)` This will be called after update META step as part of split table region procedure.
`void`	`preSplitBeforeMETAAction(byte[] splitKey, List<Mutation> metaEntries, User user)` This will be called before update META step as part of split table region procedure.
`void`	`preSplitRegion(TableName tableName, byte[] splitRow)` Invoked just before calling the split region procedure
`void`	`preSplitRegionAction(TableName tableName, byte[] splitRow, User user)` Invoked just before a split
`void`	`preStopMaster()`
`void`	`preSwitchExceedThrottleQuota(boolean enable)`
`void`	`preSwitchRpcThrottle(boolean enable)`
`void`	`preTableFlush(TableName tableName)`
`void`	`preTruncateTable(TableName tableName)`
`void`	`preTruncateTableAction(TableName tableName, User user)`
`void`	`preUnassign(RegionInfo regionInfo, boolean force)`
`void`	`preUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)`

Methods inherited from class org.apache.hadoop.hbase.coprocessor.CoprocessorHost
abortServer, abortServer, checkAndLoadInstance, execOperation, execOperationWithResult, execShutdown, findCoprocessor, findCoprocessor, findCoprocessorEnvironment, findCoprocessors, getCoprocessors, getLoadedCoprocessors, handleCoprocessorThrowable, load, load, load, loadSystemCoprocessors, shutdown

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

masterServices
```
private MasterServices masterServices
```

masterObserverGetter

private CoprocessorHost.ObserverGetter<MasterCoprocessor,MasterObserver> masterObserverGetter

Constructor Detail

MasterCoprocessorHost

public MasterCoprocessorHost(MasterServices services,
                             org.apache.hadoop.conf.Configuration conf)

Method Detail

createEnvironment

public MasterCoprocessorHost.MasterEnvironment createEnvironment(MasterCoprocessor 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<MasterCoprocessor,MasterCoprocessorEnvironment>

checkAndGetInstance
```
public MasterCoprocessor checkAndGetInstance(Class<?> implClass)
                                      throws InstantiationException,
                                             IllegalAccessException
```
Description copied from class: CoprocessorHost

Called when a new Coprocessor class needs to be loaded. Checks if type of the given class is what the corresponding host implementation expects. If it is of correct type, returns an instance of the coprocessor to be loaded. If not, returns null. If an exception occurs when trying to create instance of a coprocessor, it's passed up and eventually results into server aborting.

Specified by:

checkAndGetInstance in class CoprocessorHost<MasterCoprocessor,MasterCoprocessorEnvironment>

Throws:

InstantiationException

IllegalAccessException

preCreateNamespace

public void preCreateNamespace(NamespaceDescriptor ns)
                        throws IOException

Throws:: IOException

postCreateNamespace

public void postCreateNamespace(NamespaceDescriptor ns)
                         throws IOException

Throws:: IOException

preDeleteNamespace

public void preDeleteNamespace(String namespaceName)
                        throws IOException

Throws:: IOException

postDeleteNamespace

public void postDeleteNamespace(String namespaceName)
                         throws IOException

Throws:: IOException

preModifyNamespace

public void preModifyNamespace(NamespaceDescriptor currentNsDescriptor,
                               NamespaceDescriptor newNsDescriptor)
                        throws IOException

Throws:: IOException

postModifyNamespace

public void postModifyNamespace(NamespaceDescriptor oldNsDescriptor,
                                NamespaceDescriptor currentNsDescriptor)
                         throws IOException

Throws:: IOException

preGetNamespaceDescriptor

public void preGetNamespaceDescriptor(String namespaceName)
                               throws IOException

Throws:: IOException

postGetNamespaceDescriptor

public void postGetNamespaceDescriptor(NamespaceDescriptor ns)
                                throws IOException

Throws:: IOException

preListNamespaceDescriptors

public void preListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
                                 throws IOException

Throws:: IOException

postListNamespaceDescriptors

public void postListNamespaceDescriptors(List<NamespaceDescriptor> descriptors)
                                  throws IOException

Throws:: IOException

preCreateTableRegionsInfos

public TableDescriptor preCreateTableRegionsInfos(TableDescriptor desc)
                                           throws IOException

Throws:: IOException

preCreateTable

public void preCreateTable(TableDescriptor htd,
                           RegionInfo[] regions)
                    throws IOException

Throws:: IOException

postCreateTable

public void postCreateTable(TableDescriptor htd,
                            RegionInfo[] regions)
                     throws IOException

Throws:: IOException

preCreateTableAction

public void preCreateTableAction(TableDescriptor htd,
                                 RegionInfo[] regions,
                                 User user)
                          throws IOException

Throws:: IOException

postCompletedCreateTableAction

public void postCompletedCreateTableAction(TableDescriptor htd,
                                           RegionInfo[] regions,
                                           User user)
                                    throws IOException

Throws:: IOException

preDeleteTable

public void preDeleteTable(TableName tableName)
                    throws IOException

Throws:: IOException

postDeleteTable

public void postDeleteTable(TableName tableName)
                     throws IOException

Throws:: IOException

preDeleteTableAction

public void preDeleteTableAction(TableName tableName,
                                 User user)
                          throws IOException

Throws:: IOException

postCompletedDeleteTableAction

public void postCompletedDeleteTableAction(TableName tableName,
                                           User user)
                                    throws IOException

Throws:: IOException

preTruncateTable

public void preTruncateTable(TableName tableName)
                      throws IOException

Throws:: IOException

postTruncateTable

public void postTruncateTable(TableName tableName)
                       throws IOException

Throws:: IOException

preTruncateTableAction

public void preTruncateTableAction(TableName tableName,
                                   User user)
                            throws IOException

Throws:: IOException

postCompletedTruncateTableAction

public void postCompletedTruncateTableAction(TableName tableName,
                                             User user)
                                      throws IOException

Throws:: IOException

preModifyTable

public TableDescriptor preModifyTable(TableName tableName,
                                      TableDescriptor currentDescriptor,
                                      TableDescriptor newDescriptor)
                               throws IOException

Throws:: IOException

postModifyTable

public void postModifyTable(TableName tableName,
                            TableDescriptor oldDescriptor,
                            TableDescriptor currentDescriptor)
                     throws IOException

Throws:: IOException

preModifyTableAction

public void preModifyTableAction(TableName tableName,
                                 TableDescriptor currentDescriptor,
                                 TableDescriptor newDescriptor,
                                 User user)
                          throws IOException

Throws:: IOException

postCompletedModifyTableAction

public void postCompletedModifyTableAction(TableName tableName,
                                           TableDescriptor oldDescriptor,
                                           TableDescriptor currentDescriptor,
                                           User user)
                                    throws IOException

Throws:: IOException

preEnableTable

public void preEnableTable(TableName tableName)
                    throws IOException

Throws:: IOException

postEnableTable

public void postEnableTable(TableName tableName)
                     throws IOException

Throws:: IOException

preEnableTableAction

public void preEnableTableAction(TableName tableName,
                                 User user)
                          throws IOException

Throws:: IOException

postCompletedEnableTableAction

public void postCompletedEnableTableAction(TableName tableName,
                                           User user)
                                    throws IOException

Throws:: IOException

preDisableTable

public void preDisableTable(TableName tableName)
                     throws IOException

Throws:: IOException

postDisableTable

public void postDisableTable(TableName tableName)
                      throws IOException

Throws:: IOException

preDisableTableAction

public void preDisableTableAction(TableName tableName,
                                  User user)
                           throws IOException

Throws:: IOException

postCompletedDisableTableAction

public void postCompletedDisableTableAction(TableName tableName,
                                            User user)
                                     throws IOException

Throws:: IOException

preAbortProcedure

public void preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv,
                              long procId)
                       throws IOException

Throws:: IOException

postAbortProcedure

public void postAbortProcedure()
                        throws IOException

Throws:: IOException

preGetProcedures

public void preGetProcedures()
                      throws IOException

Throws:: IOException

postGetProcedures

public void postGetProcedures(List<Procedure<?>> procInfoList)
                       throws IOException

Throws:: IOException

preGetLocks

public void preGetLocks()
                 throws IOException

Throws:: IOException

postGetLocks

public void postGetLocks(List<LockedResource> lockedResources)
                  throws IOException

Throws:: IOException

preMove

public void preMove(RegionInfo region,
                    ServerName srcServer,
                    ServerName destServer)
             throws IOException

Throws:: IOException

postMove

public void postMove(RegionInfo region,
                     ServerName srcServer,
                     ServerName destServer)
              throws IOException

Throws:: IOException

preAssign

public void preAssign(RegionInfo regionInfo)
               throws IOException

Throws:: IOException

postAssign

public void postAssign(RegionInfo regionInfo)
                throws IOException

Throws:: IOException

preUnassign

public void preUnassign(RegionInfo regionInfo,
                        boolean force)
                 throws IOException

Throws:: IOException

postUnassign

public void postUnassign(RegionInfo regionInfo,
                         boolean force)
                  throws IOException

Throws:: IOException

preRegionOffline

public void preRegionOffline(RegionInfo regionInfo)
                      throws IOException

Throws:: IOException

postRegionOffline

public void postRegionOffline(RegionInfo regionInfo)
                       throws IOException

Throws:: IOException

preMergeRegions

public void preMergeRegions(RegionInfo[] regionsToMerge)
                     throws IOException

Throws:: IOException

postMergeRegions

public void postMergeRegions(RegionInfo[] regionsToMerge)
                      throws IOException

Throws:: IOException

preBalance

public boolean preBalance()
                   throws IOException

Throws:: IOException

postBalance

public void postBalance(List<RegionPlan> plans)
                 throws IOException

Throws:: IOException

preSetSplitOrMergeEnabled

public void preSetSplitOrMergeEnabled(boolean newValue,
                                      MasterSwitchType switchType)
                               throws IOException

Throws:: IOException

postSetSplitOrMergeEnabled

public void postSetSplitOrMergeEnabled(boolean newValue,
                                       MasterSwitchType switchType)
                                throws IOException

Throws:: IOException

preSplitRegion
```
public void preSplitRegion(TableName tableName,
                           byte[] splitRow)
                    throws IOException
```
Invoked just before calling the split region procedure

Parameters:

tableName - the table where the region belongs to

splitRow - the split point

Throws:

IOException

preSplitRegionAction

public void preSplitRegionAction(TableName tableName,
                                 byte[] splitRow,
                                 User user)
                          throws IOException

Invoked just before a split

Parameters:: tableName - the table where the region belongs to; splitRow - the split point; user - the user
Throws:: IOException

postCompletedSplitRegionAction

public void postCompletedSplitRegionAction(RegionInfo regionInfoA,
                                           RegionInfo regionInfoB,
                                           User user)
                                    throws IOException

Invoked just after a split

Parameters:: regionInfoA - the new left-hand daughter region; regionInfoB - the new right-hand daughter region; user - the user
Throws:: IOException

preSplitBeforeMETAAction

public void preSplitBeforeMETAAction(byte[] splitKey,
                                     List<Mutation> metaEntries,
                                     User user)
                              throws IOException

This will be called before update META step as part of split table region procedure.

Parameters:: splitKey -; metaEntries -; user - the user
Throws:: IOException

preSplitAfterMETAAction
```
public void preSplitAfterMETAAction(User user)
                             throws IOException
```
This will be called after update META step as part of split table region procedure.

Parameters:

user - the user

Throws:

IOException

postRollBackSplitRegionAction
```
public void postRollBackSplitRegionAction(User user)
                                   throws IOException
```
Invoked just after the rollback of a failed split

Parameters:

user - the user

Throws:

IOException

preMergeRegionsAction

public void preMergeRegionsAction(RegionInfo[] regionsToMerge,
                                  User user)
                           throws IOException

Invoked just before a merge

Parameters:: regionsToMerge - the regions to merge; user - the user
Throws:: IOException

postCompletedMergeRegionsAction

public void postCompletedMergeRegionsAction(RegionInfo[] regionsToMerge,
                                            RegionInfo mergedRegion,
                                            User user)
                                     throws IOException

Invoked after completing merge regions operation

Parameters:: regionsToMerge - the regions to merge; mergedRegion - the new merged region; user - the user
Throws:: IOException

preMergeRegionsCommit

public void preMergeRegionsCommit(RegionInfo[] regionsToMerge,
                                  @MetaMutationAnnotation
                                  List<Mutation> metaEntries,
                                  User user)
                           throws IOException

Invoked before merge regions operation writes the new region to hbase:meta

Parameters:: regionsToMerge - the regions to merge; metaEntries - the meta entry; user - the user
Throws:: IOException

postMergeRegionsCommit

public void postMergeRegionsCommit(RegionInfo[] regionsToMerge,
                                   RegionInfo mergedRegion,
                                   User user)
                            throws IOException

Invoked after merge regions operation writes the new region to hbase:meta

Parameters:: regionsToMerge - the regions to merge; mergedRegion - the new merged region; user - the user
Throws:: IOException

postRollBackMergeRegionsAction

public void postRollBackMergeRegionsAction(RegionInfo[] regionsToMerge,
                                           User user)
                                    throws IOException

Invoked after rollback merge regions operation

Parameters:: regionsToMerge - the regions to merge; user - the user
Throws:: IOException

preBalanceSwitch

public void preBalanceSwitch(boolean b)
                      throws IOException

Throws:: IOException

postBalanceSwitch

public void postBalanceSwitch(boolean oldValue,
                              boolean newValue)
                       throws IOException

Throws:: IOException

preShutdown

public void preShutdown()
                 throws IOException

Throws:: IOException

preStopMaster

public void preStopMaster()
                   throws IOException

Throws:: IOException

preMasterInitialization

public void preMasterInitialization()
                             throws IOException

Throws:: IOException

postStartMaster

public void postStartMaster()
                     throws IOException

Throws:: IOException

preSnapshot

public void preSnapshot(SnapshotDescription snapshot,
                        TableDescriptor hTableDescriptor)
                 throws IOException

Throws:: IOException

postSnapshot

public void postSnapshot(SnapshotDescription snapshot,
                         TableDescriptor hTableDescriptor)
                  throws IOException

Throws:: IOException

preListSnapshot

public void preListSnapshot(SnapshotDescription snapshot)
                     throws IOException

Throws:: IOException

postListSnapshot

public void postListSnapshot(SnapshotDescription snapshot)
                      throws IOException

Throws:: IOException

preCloneSnapshot

public void preCloneSnapshot(SnapshotDescription snapshot,
                             TableDescriptor hTableDescriptor)
                      throws IOException

Throws:: IOException

postCloneSnapshot

public void postCloneSnapshot(SnapshotDescription snapshot,
                              TableDescriptor hTableDescriptor)
                       throws IOException

Throws:: IOException

preRestoreSnapshot

public void preRestoreSnapshot(SnapshotDescription snapshot,
                               TableDescriptor hTableDescriptor)
                        throws IOException

Throws:: IOException

postRestoreSnapshot

public void postRestoreSnapshot(SnapshotDescription snapshot,
                                TableDescriptor hTableDescriptor)
                         throws IOException

Throws:: IOException

preDeleteSnapshot

public void preDeleteSnapshot(SnapshotDescription snapshot)
                       throws IOException

Throws:: IOException

postDeleteSnapshot

public void postDeleteSnapshot(SnapshotDescription snapshot)
                        throws IOException

Throws:: IOException

preGetTableDescriptors

public void preGetTableDescriptors(List<TableName> tableNamesList,
                                   List<TableDescriptor> descriptors,
                                   String regex)
                            throws IOException

Throws:: IOException

postGetTableDescriptors

public void postGetTableDescriptors(List<TableName> tableNamesList,
                                    List<TableDescriptor> descriptors,
                                    String regex)
                             throws IOException

Throws:: IOException

preGetTableNames

public void preGetTableNames(List<TableDescriptor> descriptors,
                             String regex)
                      throws IOException

Throws:: IOException

postGetTableNames

public void postGetTableNames(List<TableDescriptor> descriptors,
                              String regex)
                       throws IOException

Throws:: IOException

preTableFlush

public void preTableFlush(TableName tableName)
                   throws IOException

Throws:: IOException

postTableFlush

public void postTableFlush(TableName tableName)
                    throws IOException

Throws:: IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            GlobalQuotaSettings quotas)
                     throws IOException

Throws:: IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             GlobalQuotaSettings quotas)
                      throws IOException

Throws:: IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            TableName table,
                            GlobalQuotaSettings quotas)
                     throws IOException

Throws:: IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             TableName table,
                             GlobalQuotaSettings quotas)
                      throws IOException

Throws:: IOException

preSetUserQuota

public void preSetUserQuota(String user,
                            String namespace,
                            GlobalQuotaSettings quotas)
                     throws IOException

Throws:: IOException

postSetUserQuota

public void postSetUserQuota(String user,
                             String namespace,
                             GlobalQuotaSettings quotas)
                      throws IOException

Throws:: IOException

preSetTableQuota

public void preSetTableQuota(TableName table,
                             GlobalQuotaSettings quotas)
                      throws IOException

Throws:: IOException

postSetTableQuota

public void postSetTableQuota(TableName table,
                              GlobalQuotaSettings quotas)
                       throws IOException

Throws:: IOException

preSetNamespaceQuota

public void preSetNamespaceQuota(String namespace,
                                 GlobalQuotaSettings quotas)
                          throws IOException

Throws:: IOException

postSetNamespaceQuota

public void postSetNamespaceQuota(String namespace,
                                  GlobalQuotaSettings quotas)
                           throws IOException

Throws:: IOException

preSetRegionServerQuota

public void preSetRegionServerQuota(String regionServer,
                                    GlobalQuotaSettings quotas)
                             throws IOException

Throws:: IOException

postSetRegionServerQuota

public void postSetRegionServerQuota(String regionServer,
                                     GlobalQuotaSettings quotas)
                              throws IOException

Throws:: IOException

preMoveServersAndTables

public void preMoveServersAndTables(Set<Address> servers,
                                    Set<TableName> tables,
                                    String targetGroup)
                             throws IOException

Throws:: IOException

postMoveServersAndTables

public void postMoveServersAndTables(Set<Address> servers,
                                     Set<TableName> tables,
                                     String targetGroup)
                              throws IOException

Throws:: IOException

preMoveServers

public void preMoveServers(Set<Address> servers,
                           String targetGroup)
                    throws IOException

Throws:: IOException

postMoveServers

public void postMoveServers(Set<Address> servers,
                            String targetGroup)
                     throws IOException

Throws:: IOException

preMoveTables

public void preMoveTables(Set<TableName> tables,
                          String targetGroup)
                   throws IOException

Throws:: IOException

postMoveTables

public void postMoveTables(Set<TableName> tables,
                           String targetGroup)
                    throws IOException

Throws:: IOException

preAddRSGroup

public void preAddRSGroup(String name)
                   throws IOException

Throws:: IOException

postAddRSGroup

public void postAddRSGroup(String name)
                    throws IOException

Throws:: IOException

preRemoveRSGroup

public void preRemoveRSGroup(String name)
                      throws IOException

Throws:: IOException

postRemoveRSGroup

public void postRemoveRSGroup(String name)
                       throws IOException

Throws:: IOException

preBalanceRSGroup

public void preBalanceRSGroup(String name)
                       throws IOException

Throws:: IOException

postBalanceRSGroup

public void postBalanceRSGroup(String name,
                               boolean balanceRan)
                        throws IOException

Throws:: IOException

preRemoveServers

public void preRemoveServers(Set<Address> servers)
                      throws IOException

Throws:: IOException

postRemoveServers

public void postRemoveServers(Set<Address> servers)
                       throws IOException

Throws:: IOException

preAddReplicationPeer

public void preAddReplicationPeer(String peerId,
                                  ReplicationPeerConfig peerConfig)
                           throws IOException

Throws:: IOException

postAddReplicationPeer

public void postAddReplicationPeer(String peerId,
                                   ReplicationPeerConfig peerConfig)
                            throws IOException

Throws:: IOException

preRemoveReplicationPeer

public void preRemoveReplicationPeer(String peerId)
                              throws IOException

Throws:: IOException

postRemoveReplicationPeer

public void postRemoveReplicationPeer(String peerId)
                               throws IOException

Throws:: IOException

preEnableReplicationPeer

public void preEnableReplicationPeer(String peerId)
                              throws IOException

Throws:: IOException

postEnableReplicationPeer

public void postEnableReplicationPeer(String peerId)
                               throws IOException

Throws:: IOException

preDisableReplicationPeer

public void preDisableReplicationPeer(String peerId)
                               throws IOException

Throws:: IOException

postDisableReplicationPeer

public void postDisableReplicationPeer(String peerId)
                                throws IOException

Throws:: IOException

preGetReplicationPeerConfig

public void preGetReplicationPeerConfig(String peerId)
                                 throws IOException

Throws:: IOException

postGetReplicationPeerConfig

public void postGetReplicationPeerConfig(String peerId)
                                  throws IOException

Throws:: IOException

preUpdateReplicationPeerConfig

public void preUpdateReplicationPeerConfig(String peerId,
                                           ReplicationPeerConfig peerConfig)
                                    throws IOException

Throws:: IOException

postUpdateReplicationPeerConfig

public void postUpdateReplicationPeerConfig(String peerId,
                                            ReplicationPeerConfig peerConfig)
                                     throws IOException

Throws:: IOException

preListReplicationPeers

public void preListReplicationPeers(String regex)
                             throws IOException

Throws:: IOException

postListReplicationPeers

public void postListReplicationPeers(String regex)
                              throws IOException

Throws:: IOException

preRequestLock

public void preRequestLock(String namespace,
                           TableName tableName,
                           RegionInfo[] regionInfos,
                           LockType type,
                           String description)
                    throws IOException

Throws:: IOException

postRequestLock

public void postRequestLock(String namespace,
                            TableName tableName,
                            RegionInfo[] regionInfos,
                            LockType type,
                            String description)
                     throws IOException

Throws:: IOException

preLockHeartbeat

public void preLockHeartbeat(LockProcedure proc,
                             boolean keepAlive)
                      throws IOException

Throws:: IOException

postLockHeartbeat

public void postLockHeartbeat(LockProcedure proc,
                              boolean keepAlive)
                       throws IOException

Throws:: IOException

preGetClusterMetrics

public void preGetClusterMetrics()
                          throws IOException

Throws:: IOException

postGetClusterMetrics

public void postGetClusterMetrics(ClusterMetrics status)
                           throws IOException

Throws:: IOException

preClearDeadServers

public void preClearDeadServers()
                         throws IOException

Throws:: IOException

postClearDeadServers

public void postClearDeadServers(List<ServerName> servers,
                                 List<ServerName> notClearedServers)
                          throws IOException

Throws:: IOException

preDecommissionRegionServers

public void preDecommissionRegionServers(List<ServerName> servers,
                                         boolean offload)
                                  throws IOException

Throws:: IOException

postDecommissionRegionServers

public void postDecommissionRegionServers(List<ServerName> servers,
                                          boolean offload)
                                   throws IOException

Throws:: IOException

preListDecommissionedRegionServers

public void preListDecommissionedRegionServers()
                                        throws IOException

Throws:: IOException

postListDecommissionedRegionServers

public void postListDecommissionedRegionServers()
                                         throws IOException

Throws:: IOException

preRecommissionRegionServer

public void preRecommissionRegionServer(ServerName server,
                                        List<byte[]> encodedRegionNames)
                                 throws IOException

Throws:: IOException

postRecommissionRegionServer

public void postRecommissionRegionServer(ServerName server,
                                         List<byte[]> encodedRegionNames)
                                  throws IOException

Throws:: IOException

preSwitchRpcThrottle

public void preSwitchRpcThrottle(boolean enable)
                          throws IOException

Throws:: IOException

postSwitchRpcThrottle

public void postSwitchRpcThrottle(boolean oldValue,
                                  boolean newValue)
                           throws IOException

Throws:: IOException

preIsRpcThrottleEnabled

public void preIsRpcThrottleEnabled()
                             throws IOException

Throws:: IOException

postIsRpcThrottleEnabled

public void postIsRpcThrottleEnabled(boolean enabled)
                              throws IOException

Throws:: IOException

preSwitchExceedThrottleQuota

public void preSwitchExceedThrottleQuota(boolean enable)
                                  throws IOException

Throws:: IOException

postSwitchExceedThrottleQuota

public void postSwitchExceedThrottleQuota(boolean oldValue,
                                          boolean newValue)
                                   throws IOException

Throws:: IOException

preGrant

public void preGrant(UserPermission userPermission,
                     boolean mergeExistingPermissions)
              throws IOException

Throws:: IOException

postGrant

public void postGrant(UserPermission userPermission,
                      boolean mergeExistingPermissions)
               throws IOException

Throws:: IOException

preRevoke

public void preRevoke(UserPermission userPermission)
               throws IOException

Throws:: IOException

postRevoke

public void postRevoke(UserPermission userPermission)
                throws IOException

Throws:: IOException

preGetUserPermissions

public void preGetUserPermissions(String userName,
                                  String namespace,
                                  TableName tableName,
                                  byte[] family,
                                  byte[] qualifier)
                           throws IOException

Throws:: IOException

postGetUserPermissions

public void postGetUserPermissions(String userName,
                                   String namespace,
                                   TableName tableName,
                                   byte[] family,
                                   byte[] qualifier)
                            throws IOException

Throws:: IOException

preHasUserPermissions

public void preHasUserPermissions(String userName,
                                  List<Permission> permissions)
                           throws IOException

Throws:: IOException

postHasUserPermissions

public void postHasUserPermissions(String userName,
                                   List<Permission> permissions)
                            throws IOException

Throws:: IOException

Class MasterCoprocessorHost

Nested Class Summary

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

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

LOG

masterServices

masterObserverGetter

Constructor Detail

MasterCoprocessorHost

Method Detail

createEnvironment

checkAndGetInstance

preCreateNamespace

postCreateNamespace

preDeleteNamespace

postDeleteNamespace

preModifyNamespace

postModifyNamespace

preGetNamespaceDescriptor

postGetNamespaceDescriptor

preListNamespaceDescriptors

postListNamespaceDescriptors

preCreateTableRegionsInfos

preCreateTable

postCreateTable

preCreateTableAction

postCompletedCreateTableAction

preDeleteTable

postDeleteTable

preDeleteTableAction

postCompletedDeleteTableAction

preTruncateTable

postTruncateTable

preTruncateTableAction

postCompletedTruncateTableAction

preModifyTable

postModifyTable

preModifyTableAction

postCompletedModifyTableAction

preEnableTable

postEnableTable

preEnableTableAction

postCompletedEnableTableAction

preDisableTable

postDisableTable

preDisableTableAction

postCompletedDisableTableAction

preAbortProcedure

postAbortProcedure

preGetProcedures

postGetProcedures

preGetLocks

postGetLocks

preMove

postMove

preAssign

postAssign

preUnassign

postUnassign

preRegionOffline

postRegionOffline

preMergeRegions

postMergeRegions

preBalance

postBalance

preSetSplitOrMergeEnabled

postSetSplitOrMergeEnabled

preSplitRegion

preSplitRegionAction

postCompletedSplitRegionAction

preSplitBeforeMETAAction

preSplitAfterMETAAction

postRollBackSplitRegionAction

preMergeRegionsAction