/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/handler/ |
H A D | EnableTableHandler.java | 101 this.assignmentManager.getTableStateManager().checkAndRemoveTableState(tableName, in prepare() 117 if (!this.assignmentManager.getTableStateManager().setTableStateIfInStates( in prepare() 187 this.assignmentManager.getTableStateManager().setTableState(this.tableName, in handleEnableTable() 252 this.assignmentManager.getTableStateManager().setTableState( in handleEnableTable()
|
H A D | CreateTableHandler.java | 153 assignmentManager.getTableStateManager().setTableState( in checkAndSetEnablingTable() 156 } else if (!assignmentManager.getTableStateManager().setTableStateIfNotInStates( in checkAndSetEnablingTable() 176 assignmentManager.getTableStateManager().checkAndRemoveTableState(tableName, in removeEnablingTable() 293 assignmentManager.getTableStateManager().setTableState(tableName, in handleCreateTable()
|
H A D | DisableTableHandler.java | 95 if (!this.assignmentManager.getTableStateManager().setTableStateIfInStates( in prepare() 160 this.assignmentManager.getTableStateManager().setTableState(this.tableName, in handleDisableTable() 189 if (done) this.assignmentManager.getTableStateManager().setTableState(this.tableName, in handleDisableTable()
|
H A D | ClosedRegionHandler.java | 95 if (this.assignmentManager.getTableStateManager().isTableState(this.regionInfo.getTable(), in process()
|
H A D | TableEventHandler.java | 138 getAssignmentManager().getTableStateManager().isTableState( in process()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/ |
H A D | DisableTableProcedure.java | 296 env.getMasterServices().getAssignmentManager().getTableStateManager(); in prepareDisable() 321 if (env.getMasterServices().getAssignmentManager().getTableStateManager().isTableState( in undoTableStateChange() 353 env.getMasterServices().getAssignmentManager().getTableStateManager().setTableState( in setTableStateToDisabling() 444 env.getMasterServices().getAssignmentManager().getTableStateManager().setTableState( in setTableStateToDisabled()
|
H A D | ServerCrashProcedure.java | 509 && am.getTableStateManager().isTableState(hri.getTable(), in calcRegionsToAssign() 672 boolean tablePresent = assignmentManager.getTableStateManager().isTablePresent(hri.getTable()); in processDeadRegion() 678 boolean disabled = assignmentManager.getTableStateManager().isTableState(hri.getTable(), in processDeadRegion() 690 boolean disabling = assignmentManager.getTableStateManager().isTableState(hri.getTable(), in processDeadRegion()
|
H A D | EnableTableProcedure.java | 318 TableStateManager tsm = env.getMasterServices().getAssignmentManager().getTableStateManager(); in prepareEnable() 355 env.getMasterServices().getAssignmentManager().getTableStateManager().setTableState( in setTableStateToEnabling() 501 env.getMasterServices().getAssignmentManager().getTableStateManager().setTableState( in setTableStateToEnabled()
|
H A D | CreateTableProcedure.java | 296 TableStateManager tsm = env.getMasterServices().getAssignmentManager().getTableStateManager(); in prepareCreate() 449 assignmentManager.getTableStateManager().setTableState(tableName, 456 assignmentManager.getTableStateManager()
|
H A D | ModifyTableProcedure.java | 293 if (env.getMasterServices().getAssignmentManager().getTableStateManager() in prepareModify() 431 if (!env.getMasterServices().getAssignmentManager().getTableStateManager() in reOpenAllRegionsIfTableIsOnline()
|
H A D | MasterDDLOperationHelper.java | 80 if (!env.getMasterServices().getAssignmentManager().getTableStateManager() in checkTableModifiable()
|
H A D | ModifyColumnFamilyProcedure.java | 321 if (!env.getMasterServices().getAssignmentManager().getTableStateManager() in reOpenAllRegionsIfTableIsOnline()
|
H A D | DeleteColumnFamilyProcedure.java | 362 if (!env.getMasterServices().getAssignmentManager().getTableStateManager() in reOpenAllRegionsIfTableIsOnline()
|
H A D | AddColumnFamilyProcedure.java | 341 if (!env.getMasterServices().getAssignmentManager().getTableStateManager() in reOpenAllRegionsIfTableIsOnline()
|
H A D | DeleteTableProcedure.java | 395 am.getTableStateManager().setDeletedTable(tableName); in deleteAssignmentState()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ |
H A D | CoordinatedStateManager.java | 64 TableStateManager getTableStateManager() throws InterruptedException, in getTableStateManager() method
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/ |
H A D | TestMasterRestartAfterDisablingTable.java | 104 .getAssignmentManager().getTableStateManager().isTableState( in testForCheckingIfEnableAndDisableWorksFineAfterSwitch() 120 .getAssignmentManager().getTableStateManager() in testForCheckingIfEnableAndDisableWorksFineAfterSwitch()
|
H A D | TestMaster.java | 86 assertTrue(m.assignmentManager.getTableStateManager().isTableState(TABLENAME, in testMasterOpsWhileSplitting()
|
H A D | TestOpenedRegionHandler.java | 141 when(am.getTableStateManager()).thenReturn(new ZKTableStateManager(zkw)); in testShouldNotCompeleteOpenedRegionSuccessfullyIfVersionMismatches()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/coordination/ |
H A D | BaseCoordinatedStateManager.java | 53 public abstract TableStateManager getTableStateManager() throws InterruptedException, in getTableStateManager() method in BaseCoordinatedStateManager
|
H A D | ZkCoordinatedStateManager.java | 64 public TableStateManager getTableStateManager() throws InterruptedException, in getTableStateManager() method in ZkCoordinatedStateManager
|
H A D | ZkOpenRegionCoordination.java | 311 if (assignmentManager.getTableStateManager().isTableState(regionInfo.getTable(), in commitOpenOnMasterSide()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/ |
H A D | MasterProcedureTestingUtility.java | 186 TableStateManager tsm = master.getAssignmentManager().getTableStateManager(); in validateTableIsEnabled() 192 TableStateManager tsm = master.getAssignmentManager().getTableStateManager(); in validateTableIsDisabled()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ |
H A D | AssignmentManager.java | 297 this.tableStateManager = server.getCoordinatedStateManager().getTableStateManager(); in AssignmentManager() 352 public TableStateManager getTableStateManager() { in getTableStateManager() method in AssignmentManager 1352 boolean disabled = getTableStateManager().isTableState(regionInfo.getTable(), in nodeDeleted() 3039 && !getTableStateManager().isTableState(tableName, in rebuildUserRegions() 3681 if (getTableStateManager().isTableState(hri.getTable(), in onRegionFailedOpen() 3714 if (getTableStateManager().isTableState(hri.getTable(), in onRegionOpen() 3721 if (getTableStateManager().isTableState(hri.getTable(), in onRegionClosed() 3757 if (getTableStateManager().isTableState(p.getTable(), in onRegionSplitReverted() 3784 if (getTableStateManager().isTableState(p.getTable(), in onRegionSplit() 3834 if (getTableStateManager().isTableState(p.getTable(), in onRegionMerge() [all …]
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/ |
H A D | SnapshotManager.java | 576 if (assignmentMgr.getTableStateManager().isTableState(snapshotTable, in takeSnapshot() 583 else if (assignmentMgr.getTableStateManager().isTableState(snapshotTable, in takeSnapshot() 716 if (master.getAssignmentManager().getTableStateManager().isTableState( in restoreSnapshot()
|