Package org.apache.hadoop.hbase.master

Class MasterCoprocessorHost

java.lang.Object

org.apache.hadoop.hbase.coprocessor.CoprocessorHost<MasterCoprocessor,MasterCoprocessorEnvironment>

org.apache.hadoop.hbase.master.MasterCoprocessorHost

@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	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	Description
private static final org.slf4j.Logger	LOG
private CoprocessorHost.ObserverGetter<MasterCoprocessor,MasterObserver>	masterObserverGetter
private MasterServices	masterServices

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

ABORT_ON_ERROR_KEY, abortable, conf, coprocEnvironments, COPROCESSORS_ENABLED_CONF_KEY, DEFAULT_ABORT_ON_ERROR, DEFAULT_COPROCESSORS_ENABLED, DEFAULT_SKIP_LOAD_DUPLICATE_TABLE_COPROCESSOR, DEFAULT_USER_COPROCESSORS_ENABLED, loadSequence, MASTER_COPROCESSOR_CONF_KEY, pathPrefix, REGION_COPROCESSOR_CONF_KEY, REGIONSERVER_COPROCESSOR_CONF_KEY, SKIP_LOAD_DUPLICATE_TABLE_COPROCESSOR, USER_COPROCESSORS_ENABLED_CONF_KEY, USER_REGION_COPROCESSOR_CONF_KEY, WAL_COPROCESSOR_CONF_KEY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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(BalanceRequest request, List<RegionPlan> plans)
void	postBalanceRSGroup(String name, BalanceRequest request, BalanceResponse response)
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	postCompletedSnapshotAction(SnapshotDescription snapshot, TableDescriptor hTableDescriptor)
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	postListNamespaces(List<String> namespaces)
void	postListReplicationPeers(String regex)
void	postListSnapshot(SnapshotDescription snapshot)
void	postLockHeartbeat(LockProcedure proc, boolean keepAlive)
void	postMasterStoreFlush()
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	postModifyColumnFamilyStoreFileTracker(TableName tableName, byte[] family, String dstSFT)
void	postModifyNamespace(NamespaceDescriptor oldNsDescriptor, NamespaceDescriptor currentNsDescriptor)
void	postModifyTable(TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor)
void	postModifyTableStoreFileTracker(TableName tableName, String dstSFT)
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	postRenameRSGroup(String oldName, String newName)
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, String namespace, GlobalQuotaSettings quotas)
void	postSetUserQuota(String user, GlobalQuotaSettings quotas)
void	postSetUserQuota(String user, TableName table, GlobalQuotaSettings quotas)
void	postSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor, User user)
void	postStartMaster()
void	postSwitchExceedThrottleQuota(boolean oldValue, boolean newValue)
void	postSwitchRpcThrottle(boolean oldValue, boolean newValue)
void	postTableFlush(TableName tableName)
void	postTruncateRegion(RegionInfo regionInfo)	Invoked after calling the truncate region procedure
void	postTruncateRegionAction(RegionInfo region, User user)	Invoked after calling the truncate region procedure
void	postTruncateTable(TableName tableName)
void	postUnassign(RegionInfo regionInfo)
void	postUpdateConfiguration(org.apache.hadoop.conf.Configuration postReloadConf)
void	postUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)
void	postUpdateRSGroupConfig(String groupName, Map<String,String> configuration)
void	preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv, long procId)
void	preAddReplicationPeer(String peerId, ReplicationPeerConfig peerConfig)
void	preAddRSGroup(String name)
void	preAssign(RegionInfo regionInfo)
boolean	preBalance(BalanceRequest request)
void	preBalanceRSGroup(String name, BalanceRequest request)
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	preListNamespaces(List<String> namespaces)
void	preListReplicationPeers(String regex)
void	preListSnapshot(SnapshotDescription snapshot)
void	preLockHeartbeat(LockProcedure proc, boolean keepAlive)
void	preMasterInitialization()
void	preMasterStoreFlush()
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
String	preModifyColumnFamilyStoreFileTracker(TableName tableName, byte[] family, String dstSFT)
void	preModifyNamespace(NamespaceDescriptor currentNsDescriptor, NamespaceDescriptor newNsDescriptor)
TableDescriptor	preModifyTable(TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor)
void	preModifyTableAction(TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor, User user)
String	preModifyTableStoreFileTracker(TableName tableName, String dstSFT)
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	preRenameRSGroup(String oldName, String newName)
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, String namespace, GlobalQuotaSettings quotas)
void	preSetUserQuota(String user, GlobalQuotaSettings quotas)
void	preSetUserQuota(String user, TableName table, GlobalQuotaSettings quotas)
void	preShutdown()
void	preSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor, User user)
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	preTruncateRegion(RegionInfo regionInfo)	Invoked just before calling the truncate region procedure
void	preTruncateRegionAction(RegionInfo region, User user)	Invoked just before calling the truncate region procedure
void	preTruncateTable(TableName tableName)
void	preTruncateTableAction(TableName tableName, User user)
void	preUnassign(RegionInfo regionInfo)
void	preUpdateConfiguration(org.apache.hadoop.conf.Configuration preReloadConf)
void	preUpdateReplicationPeerConfig(String peerId, ReplicationPeerConfig peerConfig)
void	preUpdateRSGroupConfig(String groupName, Map<String,String> configuration)

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 Details

LOG

private static final org.slf4j.Logger LOG

masterServices

private MasterServices masterServices

masterObserverGetter

private CoprocessorHost.ObserverGetter<MasterCoprocessor,MasterObserver> masterObserverGetter

Constructor Details

MasterCoprocessorHost

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

Method Details

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

preListNamespaces

public void preListNamespaces(List<String> namespaces)
                       throws IOException

Throws:

IOException

postListNamespaces

public void postListNamespaces(List<String> namespaces)
                        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

preModifyTableStoreFileTracker

public String preModifyTableStoreFileTracker(TableName tableName,
 String dstSFT)
                                      throws IOException

Throws:

IOException

postModifyTableStoreFileTracker

public void postModifyTableStoreFileTracker(TableName tableName,
 String dstSFT)
                                     throws IOException

Throws:

IOException

preModifyColumnFamilyStoreFileTracker

public String preModifyColumnFamilyStoreFileTracker(TableName tableName,
 byte[] family,
 String dstSFT)
                                             throws IOException

Throws:

IOException

postModifyColumnFamilyStoreFileTracker

public void postModifyColumnFamilyStoreFileTracker(TableName tableName,
 byte[] family,
 String dstSFT)
                                            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)
                 throws IOException

Throws:

IOException

postUnassign

public void postUnassign(RegionInfo regionInfo)
                  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(BalanceRequest request)
                   throws IOException

Throws:

IOException

postBalance

public void postBalance(BalanceRequest request,
 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

preTruncateRegion

public void preTruncateRegion(RegionInfo regionInfo)
                       throws IOException

Invoked just before calling the truncate region procedure

Parameters:

regionInfo - region being truncated

Throws:

IOException

postTruncateRegion

public void postTruncateRegion(RegionInfo regionInfo)
                        throws IOException

Invoked after calling the truncate region procedure

Parameters:

regionInfo - region being truncated

Throws:

IOException

preTruncateRegionAction

public void preTruncateRegionAction(RegionInfo region,
 User user)
                             throws IOException

Invoked just before calling the truncate region procedure

Parameters:

region - Region to be truncated

user - The user

Throws:

IOException

postTruncateRegionAction

public void postTruncateRegionAction(RegionInfo region,
 User user)
                              throws IOException

Invoked after calling the truncate region procedure

Parameters:

region - Region which was truncated

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:

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,
 User user)
                 throws IOException

Throws:

IOException

postSnapshot

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

Throws:

IOException

postCompletedSnapshotAction

public void postCompletedSnapshotAction(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

preMasterStoreFlush

public void preMasterStoreFlush()
                         throws IOException

Throws:

IOException

postMasterStoreFlush

public void postMasterStoreFlush()
                          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,
 BalanceRequest request)
                       throws IOException

Throws:

IOException

postBalanceRSGroup

public void postBalanceRSGroup(String name,
 BalanceRequest request,
 BalanceResponse response)
                        throws IOException

Throws:

IOException

preRenameRSGroup

public void preRenameRSGroup(String oldName,
 String newName)
                      throws IOException

Throws:

IOException

postRenameRSGroup

public void postRenameRSGroup(String oldName,
 String newName)
                       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

preUpdateRSGroupConfig

public void preUpdateRSGroupConfig(String groupName,
 Map<String,String> configuration)
                            throws IOException

Throws:

IOException

postUpdateRSGroupConfig

public void postUpdateRSGroupConfig(String groupName,
 Map<String,String> configuration)
                             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

preUpdateConfiguration

public void preUpdateConfiguration(org.apache.hadoop.conf.Configuration preReloadConf)
                            throws IOException

Throws:

IOException

postUpdateConfiguration

public void postUpdateConfiguration(org.apache.hadoop.conf.Configuration postReloadConf)
                             throws IOException

Throws:

IOException