| /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()
|