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.procedure2 | |
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 |
BaseMasterObserver.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 |
TestMasterObserver.CPMasterObserver.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 |
---|---|
static HRegionInfo[] |
MasterProcedureTestingUtility.createTable(ProcedureExecutor<MasterProcedureEnv> procExec,
TableName tableName,
byte[][] splitKeys,
java.lang.String... family) |
static byte[] |
ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure proc) |
static <TState> void |
MasterProcedureTestingUtility.testRecoveryAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId,
int numSteps,
TState[] states) |
static <TState> void |
MasterProcedureTestingUtility.testRollbackAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId,
int lastStep,
TState[] states) |
static <TState> void |
MasterProcedureTestingUtility.testRollbackAndDoubleExecutionAfterPONR(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId,
int lastStep,
TState[] states) |
static <TState> void |
MasterProcedureTestingUtility.testRollbackRetriableFailure(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId,
int lastStep,
TState[] states) |
static byte[] |
ProcedureSyncWait.waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec,
long procId) |
Constructor and Description |
---|
InjectAbortOnLoadListener(ProcedureExecutor<MasterProcedureEnv> procExec) |
Modifier and Type | Method and Description |
---|---|
static <TEnv> void |
ProcedureTestingUtility.assertProcNotFailed(ProcedureExecutor<TEnv> procExecutor,
long procId) |
static <TEnv> void |
ProcedureTestingUtility.assertProcNotYetCompleted(ProcedureExecutor<TEnv> procExecutor,
long procId) |
static <TEnv> void |
ProcedureTestingUtility.restart(ProcedureExecutor<TEnv> procExecutor) |
static <TEnv> void |
ProcedureTestingUtility.restart(ProcedureExecutor<TEnv> procExecutor,
java.lang.Runnable beforeStartAction) |
static <TEnv> void |
ProcedureTestingUtility.setKillAndToggleBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
boolean value) |
static <TEnv> void |
ProcedureTestingUtility.setKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
boolean value) |
static <TEnv> void |
ProcedureTestingUtility.setToggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor,
boolean value) |
static <TEnv> long |
ProcedureTestingUtility.submitAndWait(ProcedureExecutor<TEnv> procExecutor,
Procedure proc) |
static <TEnv> long |
ProcedureTestingUtility.submitAndWait(ProcedureExecutor<TEnv> procExecutor,
Procedure proc,
long nonceGroup,
long nonce) |
static <TEnv> long |
ProcedureTestingUtility.submitProcedure(ProcedureExecutor<TEnv> procExecutor,
Procedure proc,
long nonceGroup,
long nonce) |
static <TEnv> void |
ProcedureTestingUtility.toggleKillBeforeStoreUpdate(ProcedureExecutor<TEnv> procExecutor) |
static <TEnv> void |
ProcedureTestingUtility.waitNoProcedureRunning(ProcedureExecutor<TEnv> procExecutor) |
static <TEnv> void |
ProcedureTestingUtility.waitProcedure(ProcedureExecutor<TEnv> procExecutor,
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) |