Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.procedure | |
org.apache.hadoop.hbase.security.access |
Modifier and Type | Method and Description |
---|---|
void |
MasterObserver.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId)
Called before a abortProcedure request has been processed.
|
void |
BaseMasterObserver.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
void |
BaseMasterAndRegionObserver.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
Modifier and Type | Method and Description |
---|---|
ProcedureExecutor<MasterProcedureEnv> |
MasterServices.getMasterProcedureExecutor() |
ProcedureExecutor<MasterProcedureEnv> |
HMaster.getMasterProcedureExecutor() |
Modifier and Type | Method and Description |
---|---|
boolean |
MasterCoprocessorHost.preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
Modifier and Type | Method and Description |
---|---|
boolean |
TruncateTableProcedure.abort(MasterProcedureEnv env) |
boolean |
ModifyTableProcedure.abort(MasterProcedureEnv env) |
boolean |
ModifyColumnFamilyProcedure.abort(MasterProcedureEnv env) |
boolean |
EnableTableProcedure.abort(MasterProcedureEnv env) |
boolean |
DisableTableProcedure.abort(MasterProcedureEnv env) |
boolean |
DeleteTableProcedure.abort(MasterProcedureEnv env) |
boolean |
DeleteColumnFamilyProcedure.abort(MasterProcedureEnv env) |
boolean |
CreateTableProcedure.abort(MasterProcedureEnv env) |
boolean |
AddColumnFamilyProcedure.abort(MasterProcedureEnv env) |
protected boolean |
TruncateTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ModifyTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ModifyColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
EnableTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DisableTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DeleteTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DeleteColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
CreateTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
AddColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected static void |
CreateTableProcedure.addRegionsToMeta(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
List<HRegionInfo> regionInfos)
Add the specified set of regions to the hbase:meta table.
|
protected static List<HRegionInfo> |
CreateTableProcedure.addTableToMeta(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
List<HRegionInfo> regions) |
protected static void |
CreateTableProcedure.assignRegions(MasterProcedureEnv env,
TableName tableName,
List<HRegionInfo> regions) |
static void |
MasterDDLOperationHelper.checkTableModifiable(MasterProcedureEnv env,
TableName tableName)
Check whether a table is modifiable - exists and either offline or online with config set
|
protected static List<HRegionInfo> |
CreateTableProcedure.createFsLayout(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
List<HRegionInfo> newRegions) |
protected static List<HRegionInfo> |
CreateTableProcedure.createFsLayout(MasterProcedureEnv env,
HTableDescriptor hTableDescriptor,
List<HRegionInfo> newRegions,
CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler) |
List<HRegionInfo> |
CreateTableProcedure.CreateHdfsRegions.createHdfsRegions(MasterProcedureEnv env,
org.apache.hadoop.fs.Path tableRootDir,
TableName tableName,
List<HRegionInfo> newRegions) |
protected static void |
DeleteTableProcedure.deleteAssignmentState(MasterProcedureEnv env,
TableName tableName) |
static void |
MasterDDLOperationHelper.deleteColumnFamilyFromFileSystem(MasterProcedureEnv env,
TableName tableName,
List<HRegionInfo> regionInfoList,
byte[] familyName)
Remove the column family from the file system
|
protected static void |
DeleteTableProcedure.deleteFromFs(MasterProcedureEnv env,
TableName tableName,
List<HRegionInfo> regions,
boolean archive) |
protected static void |
DeleteTableProcedure.deleteFromMeta(MasterProcedureEnv env,
TableName tableName,
List<HRegionInfo> regions) |
protected static void |
DeleteTableProcedure.deleteTableDescriptorCache(MasterProcedureEnv env,
TableName tableName) |
protected static void |
DeleteTableProcedure.deleteTableStates(MasterProcedureEnv env,
TableName tableName) |
protected StateMachineProcedure.Flow |
AddColumnFamilyProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.AddColumnFamilyState state) |
protected StateMachineProcedure.Flow |
CreateTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.CreateTableState state) |
protected StateMachineProcedure.Flow |
DeleteColumnFamilyProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.DeleteColumnFamilyState state) |
protected StateMachineProcedure.Flow |
DeleteTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.DeleteTableState state) |
protected StateMachineProcedure.Flow |
DisableTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.DisableTableState state) |
protected StateMachineProcedure.Flow |
EnableTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.EnableTableState state) |
protected StateMachineProcedure.Flow |
ModifyColumnFamilyProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.ModifyColumnFamilyState state) |
protected StateMachineProcedure.Flow |
ModifyTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.ModifyTableState state) |
protected StateMachineProcedure.Flow |
TruncateTableProcedure.executeFromState(MasterProcedureEnv env,
MasterProcedureProtos.TruncateTableState state) |
protected static MasterQuotaManager |
ProcedureSyncWait.getMasterQuotaManager(MasterProcedureEnv env) |
protected static List<HRegionInfo> |
ProcedureSyncWait.getRegionsFromMeta(MasterProcedureEnv env,
TableName tableName) |
static boolean |
MasterDDLOperationHelper.isOnlineSchemaChangeAllowed(MasterProcedureEnv env)
Check whether online schema change is allowed from config
|
protected static org.apache.hadoop.hbase.master.procedure.DisableTableProcedure.MarkRegionOfflineOpResult |
DisableTableProcedure.markRegionsOffline(MasterProcedureEnv env,
TableName tableName,
Boolean retryRequired)
Mark regions of the table offline with retries
|
protected static void |
EnableTableProcedure.markRegionsOnline(MasterProcedureEnv env,
TableName tableName,
Boolean retryRequired)
Mark offline regions of the table online with retry
|
protected void |
DisableTableProcedure.postDisable(MasterProcedureEnv env,
MasterProcedureProtos.DisableTableState state)
Action after disabling table.
|
protected void |
DisableTableProcedure.preDisable(MasterProcedureEnv env,
MasterProcedureProtos.DisableTableState state)
Action before disabling table.
|
protected void |
TruncateTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ModifyTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ModifyColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
EnableTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DisableTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DeleteTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DeleteColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
CreateTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
AddColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
static boolean |
MasterDDLOperationHelper.reOpenAllRegions(MasterProcedureEnv env,
TableName tableName,
List<HRegionInfo> regionInfoList)
Reopen all regions from a table after a schema change operation.
|
protected void |
AddColumnFamilyProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.AddColumnFamilyState state) |
protected void |
CreateTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.CreateTableState state) |
protected void |
DeleteColumnFamilyProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.DeleteColumnFamilyState state) |
protected void |
DeleteTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.DeleteTableState state) |
protected void |
DisableTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.DisableTableState state) |
protected void |
EnableTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.EnableTableState state) |
protected void |
ModifyColumnFamilyProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.ModifyColumnFamilyState state) |
protected void |
ModifyTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.ModifyTableState state) |
protected void |
TruncateTableProcedure.rollbackState(MasterProcedureEnv env,
MasterProcedureProtos.TruncateTableState state) |
protected static void |
DisableTableProcedure.setTableStateToDisabled(MasterProcedureEnv env,
TableName tableName)
Mark table state to Disabled
|
protected static void |
DisableTableProcedure.setTableStateToDisabling(MasterProcedureEnv env,
TableName tableName)
Mark table state to Disabling
|
protected static void |
EnableTableProcedure.setTableStateToEnabled(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabled
|
protected static void |
EnableTableProcedure.setTableStateToEnabling(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabling
|
protected static void |
CreateTableProcedure.updateTableDescCache(MasterProcedureEnv env,
TableName tableName) |
static <T> T |
ProcedureSyncWait.waitFor(MasterProcedureEnv env,
long waitTime,
long waitingTimeForEvents,
String purpose,
ProcedureSyncWait.Predicate<T> predicate) |
static <T> T |
ProcedureSyncWait.waitFor(MasterProcedureEnv env,
String purpose,
ProcedureSyncWait.Predicate<T> predicate) |
protected static void |
ProcedureSyncWait.waitMetaRegions(MasterProcedureEnv env) |
protected static void |
ProcedureSyncWait.waitRegionInTransition(MasterProcedureEnv env,
List<HRegionInfo> regions) |
protected static void |
ProcedureSyncWait.waitRegionServers(MasterProcedureEnv env) |
Modifier and Type | Method and Description |
---|---|
static byte[] |
ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure proc) |
static byte[] |
ProcedureSyncWait.waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.