| 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.rsgroup | |
| org.apache.hadoop.hbase.security.access |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseMasterAndRegionObserver.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
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) |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecutor<MasterProcedureEnv> |
HMaster.getMasterProcedureExecutor() |
ProcedureExecutor<MasterProcedureEnv> |
MasterServices.getMasterProcedureExecutor() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MasterCoprocessorHost.preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
| Modifier and Type | Method and Description |
|---|---|
protected ProcedureExecutor<MasterProcedureEnv> |
MasterProcedureUtil.NonceProcedureRunnable.getProcedureExecutor() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DeleteTableProcedure.abort(MasterProcedureEnv env) |
boolean |
DeleteNamespaceProcedure.abort(MasterProcedureEnv env) |
boolean |
ModifyColumnFamilyProcedure.abort(MasterProcedureEnv env) |
protected boolean |
ServerCrashProcedure.abort(MasterProcedureEnv env) |
boolean |
TruncateTableProcedure.abort(MasterProcedureEnv env) |
boolean |
CreateNamespaceProcedure.abort(MasterProcedureEnv env) |
boolean |
AddColumnFamilyProcedure.abort(MasterProcedureEnv env) |
boolean |
DeleteColumnFamilyProcedure.abort(MasterProcedureEnv env) |
boolean |
EnableTableProcedure.abort(MasterProcedureEnv env) |
boolean |
ModifyNamespaceProcedure.abort(MasterProcedureEnv env) |
boolean |
DisableTableProcedure.abort(MasterProcedureEnv env) |
boolean |
ModifyTableProcedure.abort(MasterProcedureEnv env) |
boolean |
CreateTableProcedure.abort(MasterProcedureEnv env) |
protected boolean |
DeleteTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DeleteNamespaceProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ModifyColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ServerCrashProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
TruncateTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
CreateNamespaceProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
AddColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DeleteColumnFamilyProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
EnableTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ModifyNamespaceProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
DisableTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
ModifyTableProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
CreateTableProcedure.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 void |
CreateNamespaceProcedure.createDirectory(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Create the namespace directory
|
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 |
DeleteNamespaceProcedure.deleteDirectory(MasterProcedureEnv env,
String namespaceName)
Delete the namespace directories 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 |
DeleteNamespaceProcedure.deleteFromNSTable(MasterProcedureEnv env,
String namespaceName)
delete the row from namespace table
|
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,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.AddColumnFamilyState state) |
protected StateMachineProcedure.Flow |
CreateNamespaceProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.CreateNamespaceState state) |
protected StateMachineProcedure.Flow |
CreateTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.CreateTableState state) |
protected StateMachineProcedure.Flow |
DeleteColumnFamilyProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteColumnFamilyState state) |
protected StateMachineProcedure.Flow |
DeleteNamespaceProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteNamespaceState state) |
protected StateMachineProcedure.Flow |
DeleteTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteTableState state) |
protected StateMachineProcedure.Flow |
DisableTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DisableTableState state) |
protected StateMachineProcedure.Flow |
EnableTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.EnableTableState state) |
protected StateMachineProcedure.Flow |
ModifyColumnFamilyProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyColumnFamilyState state) |
protected StateMachineProcedure.Flow |
ModifyNamespaceProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyNamespaceState state) |
protected StateMachineProcedure.Flow |
ModifyTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyTableState state) |
protected StateMachineProcedure.Flow |
ServerCrashProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ServerCrashState state) |
protected StateMachineProcedure.Flow |
TruncateTableProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.TruncateTableState state) |
protected static MasterQuotaManager |
ProcedureSyncWait.getMasterQuotaManager(MasterProcedureEnv env) |
protected static List<HRegionInfo> |
ProcedureSyncWait.getRegionsFromMeta(MasterProcedureEnv env,
TableName tableName) |
protected static List<HRegionInfo> |
ProcedureSyncWait.getRegionsFromMeta(MasterProcedureEnv env,
TableName tableName,
boolean excludeOfflinedSplitParents,
boolean excludeReplicaRegions) |
protected static void |
CreateNamespaceProcedure.insertIntoNSTable(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Insert the row into ns table
|
static boolean |
MasterDDLOperationHelper.isOnlineSchemaChangeAllowed(MasterProcedureEnv env)
Check whether online schema change is allowed from config
|
protected boolean |
ServerCrashProcedure.isYieldBeforeExecuteFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ServerCrashState state)
For this procedure, yield at end of each successful flow step so that all crashed servers
can make progress rather than do the default which has each procedure running to completion
before we move to the next.
|
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,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DisableTableState state)
Action after disabling table.
|
protected void |
DisableTableProcedure.preDisable(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DisableTableState state)
Action before disabling table.
|
protected void |
DeleteTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DeleteNamespaceProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ModifyColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ServerCrashProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
TruncateTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
CreateNamespaceProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
AddColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DeleteColumnFamilyProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
EnableTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ModifyNamespaceProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
DisableTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ModifyTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
CreateTableProcedure.releaseLock(MasterProcedureEnv env) |
protected static void |
DeleteNamespaceProcedure.removeFromZKNamespaceManager(MasterProcedureEnv env,
String namespaceName)
remove from Zookeeper.
|
protected static void |
DeleteNamespaceProcedure.removeNamespaceQuota(MasterProcedureEnv env,
String namespaceName)
remove quota for the namespace
|
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,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.AddColumnFamilyState state) |
protected void |
CreateNamespaceProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.CreateNamespaceState state) |
protected void |
CreateTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.CreateTableState state) |
protected void |
DeleteColumnFamilyProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteColumnFamilyState state) |
protected void |
DeleteNamespaceProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteNamespaceState state) |
protected void |
DeleteTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DeleteTableState state) |
protected void |
DisableTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.DisableTableState state) |
protected void |
EnableTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.EnableTableState state) |
protected void |
ModifyColumnFamilyProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyColumnFamilyState state) |
protected void |
ModifyNamespaceProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyNamespaceState state) |
protected void |
ModifyTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ModifyTableState state) |
protected void |
ServerCrashProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.ServerCrashState state) |
protected void |
TruncateTableProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.protobuf.generated.MasterProcedureProtos.TruncateTableState state) |
protected static void |
CreateNamespaceProcedure.setNamespaceQuota(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Set quota for the namespace
|
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 boolean |
ServerCrashProcedure.shouldWaitClientAck(MasterProcedureEnv env) |
protected boolean |
CreateNamespaceProcedure.shouldWaitClientAck(MasterProcedureEnv env) |
protected boolean |
CreateTableProcedure.shouldWaitClientAck(MasterProcedureEnv env) |
protected static void |
CreateTableProcedure.updateTableDescCache(MasterProcedureEnv env,
TableName tableName) |
protected static void |
CreateNamespaceProcedure.updateZKNamespaceManager(MasterProcedureEnv env,
NamespaceDescriptor nsDescriptor)
Update Zookeeper.
|
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 |
RSGroupAdminEndpoint.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
| Modifier and Type | Method and Description |
|---|---|
void |
AccessController.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx,
ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.