Modifier and Type | Method and Description |
---|---|
void |
TableStateManager.checkAndRemoveTableState(TableName tableName,
ZooKeeperProtos.Table.State states,
boolean deletePermanentState)
If the table is found in the given state the in-memory state is removed.
|
java.util.Set<TableName> |
TableStateManager.getTablesInStates(ZooKeeperProtos.Table.State... states) |
TableStateManager |
CoordinatedStateManager.getTableStateManager()
Returns implementation of TableStateManager.
|
void |
TableStateManager.setDeletedTable(TableName tableName)
Mark table as deleted.
|
void |
TableStateManager.setTableState(TableName tableName,
ZooKeeperProtos.Table.State state)
Sets the table into desired state.
|
boolean |
TableStateManager.setTableStateIfInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Sets the specified table into the newState, but only if the table is already in
one of the possibleCurrentStates (otherwise no operation is performed).
|
boolean |
TableStateManager.setTableStateIfNotInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Sets the specified table into the newState, but only if the table is NOT in
one of the possibleCurrentStates (otherwise no operation is performed).
|
Modifier and Type | Method and Description |
---|---|
abstract TableStateManager |
BaseCoordinatedStateManager.getTableStateManager() |
TableStateManager |
ZkCoordinatedStateManager.getTableStateManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
HMaster.normalizeRegions()
Perform normalization of cluster (invoked by
RegionNormalizerChore ). |
void |
TestAssignmentManager.testAssignmentEventIgnoredIfNotExpected()
Test assignment related ZK events are ignored by AM if the region is not known
by AM to be in transition.
|
void |
TestAssignmentManager.testAssignmentOfRegionInSSHAndInFailedOpenState() |
void |
TestAssignmentManager.testAssignmentOfRegionRITWithOffline() |
void |
TestAssignmentManager.testBalance()
Tests AssignmentManager balance function.
|
void |
TestAssignmentManager.testBalanceOnMasterFailoverScenarioWithClosedNode() |
void |
TestAssignmentManager.testBalanceOnMasterFailoverScenarioWithOfflineNode() |
void |
TestAssignmentManager.testBalanceOnMasterFailoverScenarioWithOpenedNode()
Test a balance going on at same time as a master failover
|
void |
TestAssignmentManager.testProcessDeadServersAndRegionsInTransitionShouldNotFailWithNPE()
Tests the processDeadServersAndRegionsInTransition should not fail with NPE
when it failed to get the children.
|
void |
TestAssignmentManager.testRegionInOpeningStateOnDeadRSWhileMasterFailover()
Test the scenario when the master is in failover and trying to process a
region which is in Opening state on a dead RS.
|
void |
TestAssignmentManager.testRegionPlanIsUpdatedWhenRegionFailsToOpen()
TestCase verifies that the regionPlan is updated whenever a region fails to open
and the master tries to process RS_ZK_FAILED_OPEN state.(HBASE-5546).
|
void |
TestAssignmentManager.testShutdownHandler()
Run a simple server shutdown handler.
|
void |
TestAssignmentManager.testShutdownHandlerWithRestartedServer()
Run a simple server shutdown handler after the same server restarts.
|
void |
TestAssignmentManager.testSSHTimesOutOpeningRegionTransition()
When a region is in transition, if the region server opening the region goes down,
the region assignment takes a long time normally (waiting for timeout monitor to trigger assign).
|
void |
TestAssignmentManager.testSSHWhenDisableTableInProgress()
To test closed region handler to remove rit and delete corresponding znode
if region in pending close or closing while processing shutdown of a region
server.(HBASE-5927).
|
void |
TestAssignmentManager.testUnassignWithSplitAtSameTime() |
Constructor and Description |
---|
AssignmentManager(Server server,
ServerManager serverManager,
LoadBalancer balancer,
ExecutorService service,
MetricsMaster metricsMaster,
TableLockManager tableLockManager)
Constructs a new assignment manager.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteTableHandler.handleTableOperation(java.util.List<HRegionInfo> regions) |
protected abstract void |
TableEventHandler.handleTableOperation(java.util.List<HRegionInfo> regions) |
protected void |
TruncateTableHandler.handleTableOperation(java.util.List<HRegionInfo> regions) |
protected void |
DeleteTableHandler.removeTableData(java.util.List<HRegionInfo> regions)
Removes the table from hbase:meta and archives the HDFS files.
|
protected void |
DeleteTableHandler.waitRegionInTransition(java.util.List<HRegionInfo> regions) |
Modifier and Type | Method and Description |
---|---|
protected static void |
ProcedureSyncWait.waitRegionInTransition(MasterProcedureEnv env,
java.util.List<HRegionInfo> regions) |
Modifier and Type | Method and Description |
---|---|
void |
ZKTableStateManager.checkAndRemoveTableState(TableName tableName,
ZooKeeperProtos.Table.State states,
boolean deletePermanentState)
If the table is found in the given state the in-memory state is removed.
|
java.util.Set<TableName> |
ZKTableStateManager.getTablesInStates(ZooKeeperProtos.Table.State... states)
Gets a list of all the tables set as disabling in zookeeper.
|
void |
ZKTableStateManager.setDeletedTable(TableName tableName)
Deletes the table in zookeeper.
|
void |
ZKTableStateManager.setTableState(TableName tableName,
ZooKeeperProtos.Table.State state)
Sets table state in ZK.
|
boolean |
ZKTableStateManager.setTableStateIfInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Checks and sets table state in ZK.
|
boolean |
ZKTableStateManager.setTableStateIfNotInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Checks and sets table state in ZK.
|