org.apache.hadoop.hbase.rsgroup

Class TestRSGroupsBase.CPMasterObserver

java.lang.Object

org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase.CPMasterObserver

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.MasterObserver

Enclosing class:

TestRSGroupsBase

public static class TestRSGroupsBase.CPMasterObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.MasterObserver

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	postAddRSGroupCalled
(package private) boolean	postBalanceRSGroupCalled
(package private) boolean	postMoveServersAndTables
(package private) boolean	postMoveServersCalled
(package private) boolean	postMoveTablesCalled
(package private) boolean	postRemoveRSGroupCalled
(package private) boolean	postRemoveServersCalled
(package private) boolean	preAddRSGroupCalled
(package private) boolean	preBalanceRSGroupCalled
(package private) boolean	preMoveServersAndTables
(package private) boolean	preMoveServersCalled
(package private) boolean	preMoveTablesCalled
(package private) boolean	preRemoveRSGroupCalled
(package private) boolean	preRemoveServersCalled

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
CPMasterObserver()

Method Summary

Modifier and Type	Method and Description
Optional<org.apache.hadoop.hbase.coprocessor.MasterObserver>	getMasterObserver()
void	postAddRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String name)
void	postBalanceRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String groupName, boolean balancerRan)
void	postMoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers, String targetGroup)
void	postMoveServersAndTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers, Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	postMoveTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	postRemoveRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String name)
void	postRemoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers)
void	preAddRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String name)
void	preBalanceRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String groupName)
void	preMoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers, String targetGroup)
void	preMoveServersAndTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers, Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	preMoveTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.TableName> tables, String targetGroup)
void	preRemoveRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, String name)
void	preRemoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx, Set<org.apache.hadoop.hbase.net.Address> servers)
void	resetFlags()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

getServices, start, stop

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.MasterObserver

postAbortProcedure, postAddReplicationPeer, postAssign, postBalance, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedCreateTableAction, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsAction, postCompletedModifyTableAction, postCompletedModifyTableAction, postCompletedSplitRegionAction, postCompletedTruncateTableAction, postCreateNamespace, postCreateTable, postDecommissionRegionServers, postDeleteNamespace, postDeleteSnapshot, postDeleteTable, postDisableReplicationPeer, postDisableTable, postEnableReplicationPeer, postEnableTable, postGetClusterMetrics, postGetLocks, postGetNamespaceDescriptor, postGetProcedures, postGetReplicationPeerConfig, postGetTableDescriptors, postGetTableNames, postGetUserPermissions, postGrant, postHasUserPermissions, postIsRpcThrottleEnabled, postListDecommissionedRegionServers, postListNamespaceDescriptors, postListReplicationPeers, postListSnapshot, postLockHeartbeat, postMergeRegions, postMergeRegionsCommitAction, postModifyNamespace, postModifyNamespace, postModifyTable, postModifyTable, postMove, postRecommissionRegionServer, postRegionOffline, postRemoveReplicationPeer, postRequestLock, postRestoreSnapshot, postRevoke, postRollBackMergeRegionsAction, postRollBackSplitRegionAction, postSetNamespaceQuota, postSetRegionServerQuota, postSetSplitOrMergeEnabled, postSetTableQuota, postSetUserQuota, postSetUserQuota, postSetUserQuota, postSnapshot, postStartMaster, postSwitchExceedThrottleQuota, postSwitchRpcThrottle, postTableFlush, postTruncateTable, postUnassign, postUpdateReplicationPeerConfig, preAbortProcedure, preAddReplicationPeer, preAssign, preBalance, preBalanceSwitch, preClearDeadServers, preCloneSnapshot, preCreateNamespace, preCreateTable, preCreateTableAction, preCreateTableRegionsInfos, preDecommissionRegionServers, preDeleteNamespace, preDeleteSnapshot, preDeleteTable, preDeleteTableAction, preDisableReplicationPeer, preDisableTable, preDisableTableAction, preEnableReplicationPeer, preEnableTable, preEnableTableAction, preGetClusterMetrics, preGetLocks, preGetNamespaceDescriptor, preGetProcedures, preGetReplicationPeerConfig, preGetTableDescriptors, preGetTableNames, preGetUserPermissions, preGrant, preHasUserPermissions, preIsRpcThrottleEnabled, preListDecommissionedRegionServers, preListNamespaceDescriptors, preListReplicationPeers, preListSnapshot, preLockHeartbeat, preMasterInitialization, preMergeRegions, preMergeRegionsAction, preMergeRegionsCommitAction, preModifyNamespace, preModifyNamespace, preModifyTable, preModifyTable, preModifyTableAction, preModifyTableAction, preMove, preRecommissionRegionServer, preRegionOffline, preRemoveReplicationPeer, preRequestLock, preRestoreSnapshot, preRevoke, preSetNamespaceQuota, preSetRegionServerQuota, preSetSplitOrMergeEnabled, preSetTableQuota, preSetUserQuota, preSetUserQuota, preSetUserQuota, preShutdown, preSnapshot, preSplitRegion, preSplitRegionAction, preSplitRegionAfterMETAAction, preSplitRegionBeforeMETAAction, preStopMaster, preSwitchExceedThrottleQuota, preSwitchRpcThrottle, preTableFlush, preTruncateTable, preTruncateTableAction, preUnassign, preUpdateReplicationPeerConfig

Field Detail

preBalanceRSGroupCalled

boolean preBalanceRSGroupCalled

postBalanceRSGroupCalled

boolean postBalanceRSGroupCalled

preMoveServersCalled

boolean preMoveServersCalled

postMoveServersCalled

boolean postMoveServersCalled

preMoveTablesCalled

boolean preMoveTablesCalled

postMoveTablesCalled

boolean postMoveTablesCalled

preAddRSGroupCalled

boolean preAddRSGroupCalled

postAddRSGroupCalled

boolean postAddRSGroupCalled

preRemoveRSGroupCalled

boolean preRemoveRSGroupCalled

postRemoveRSGroupCalled

boolean postRemoveRSGroupCalled

preRemoveServersCalled

boolean preRemoveServersCalled

postRemoveServersCalled

boolean postRemoveServersCalled

preMoveServersAndTables

boolean preMoveServersAndTables

postMoveServersAndTables

boolean postMoveServersAndTables

Constructor Detail

CPMasterObserver

public CPMasterObserver()

Method Detail

resetFlags

public void resetFlags()

getMasterObserver

public Optional<org.apache.hadoop.hbase.coprocessor.MasterObserver> getMasterObserver()

Specified by:

getMasterObserver in interface org.apache.hadoop.hbase.coprocessor.MasterCoprocessor

preMoveServersAndTables

public void preMoveServersAndTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                                    Set<org.apache.hadoop.hbase.net.Address> servers,
                                    Set<org.apache.hadoop.hbase.TableName> tables,
                                    String targetGroup)
                             throws IOException

Specified by:

preMoveServersAndTables in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postMoveServersAndTables

public void postMoveServersAndTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                                     Set<org.apache.hadoop.hbase.net.Address> servers,
                                     Set<org.apache.hadoop.hbase.TableName> tables,
                                     String targetGroup)
                              throws IOException

Specified by:

postMoveServersAndTables in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preRemoveServers

public void preRemoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                             Set<org.apache.hadoop.hbase.net.Address> servers)
                      throws IOException

Specified by:

preRemoveServers in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postRemoveServers

public void postRemoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                              Set<org.apache.hadoop.hbase.net.Address> servers)
                       throws IOException

Specified by:

postRemoveServers in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preRemoveRSGroup

public void preRemoveRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                             String name)
                      throws IOException

Specified by:

preRemoveRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postRemoveRSGroup

public void postRemoveRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                              String name)
                       throws IOException

Specified by:

postRemoveRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preAddRSGroup

public void preAddRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                          String name)
                   throws IOException

Specified by:

preAddRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postAddRSGroup

public void postAddRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                           String name)
                    throws IOException

Specified by:

postAddRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preMoveTables

public void preMoveTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                          Set<org.apache.hadoop.hbase.TableName> tables,
                          String targetGroup)
                   throws IOException

Specified by:

preMoveTables in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postMoveTables

public void postMoveTables(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                           Set<org.apache.hadoop.hbase.TableName> tables,
                           String targetGroup)
                    throws IOException

Specified by:

postMoveTables in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preMoveServers

public void preMoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                           Set<org.apache.hadoop.hbase.net.Address> servers,
                           String targetGroup)
                    throws IOException

Specified by:

preMoveServers in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postMoveServers

public void postMoveServers(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                            Set<org.apache.hadoop.hbase.net.Address> servers,
                            String targetGroup)
                     throws IOException

Specified by:

postMoveServers in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

preBalanceRSGroup

public void preBalanceRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                              String groupName)
                       throws IOException

Specified by:

preBalanceRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException

postBalanceRSGroup

public void postBalanceRSGroup(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment> ctx,
                               String groupName,
                               boolean balancerRan)
                        throws IOException

Specified by:

postBalanceRSGroup in interface org.apache.hadoop.hbase.coprocessor.MasterObserver

Throws:

IOException