Modifier and Type | Class and Description |
---|---|
class |
FullTableBackupProcedure |
class |
IncrementalTableBackupProcedure |
Modifier and Type | Class and Description |
---|---|
class |
AddColumnFamilyProcedure
The procedure to add a column family to an existing table.
|
class |
CreateTableProcedure |
class |
DeleteColumnFamilyProcedure
The procedure to delete a column family from an existing table.
|
class |
DeleteTableProcedure |
class |
DisableTableProcedure |
class |
EnableTableProcedure |
class |
ModifyColumnFamilyProcedure
The procedure to modify a column family from an existing table.
|
class |
ModifyTableProcedure |
static class |
TestCreateTableProcedure.FaultyCreateTableProcedure |
static class |
TestMasterProcedureQueue.TestTableProcedure |
class |
TruncateTableProcedure |
Modifier and Type | Method and Description |
---|---|
protected Procedure[] |
TestMasterProcedureQueue.TestTableProcedure.execute(java.lang.Void env) |
Modifier and Type | Method and Description |
---|---|
void |
MasterProcedureQueue.addBack(Procedure proc) |
void |
MasterProcedureQueue.addFront(Procedure proc) |
void |
MasterProcedureQueue.completionCleanup(Procedure proc) |
protected abstract void |
ProcedurePrepareLatch.countDown(Procedure proc) |
protected void |
ProcedurePrepareLatch.CompatibilityLatch.countDown(Procedure proc) |
protected static void |
ProcedurePrepareLatch.releaseLatch(ProcedurePrepareLatch latch,
Procedure proc) |
static byte[] |
ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure proc) |
protected long |
MasterProcedureUtil.NonceProcedureRunnable.submitProcedure(Procedure proc) |
void |
MasterProcedureQueue.yield(Procedure proc) |
Modifier and Type | Method and Description |
---|---|
static Procedure |
Procedure.convert(ProcedureProtos.Procedure proto)
Helper to convert the protobuf procedure.
|
protected Procedure[] |
Procedure.doExecute(TEnvironment env)
Internal method called by the ProcedureExecutor that starts the
user-level code execute().
|
protected Procedure[] |
SequentialProcedure.doExecute(TEnvironment env) |
protected abstract Procedure[] |
Procedure.execute(TEnvironment env)
The main code of the procedure.
|
protected Procedure[] |
StateMachineProcedure.execute(TEnvironment env) |
protected Procedure[] |
TestProcedureNonce.TestSingleStepProcedure.execute(org.apache.hadoop.hbase.procedure2.TestProcedureNonce.TestProcEnv env) |
protected Procedure[] |
TestProcedureReplayOrder.TestSingleStepProcedure.execute(org.apache.hadoop.hbase.procedure2.TestProcedureReplayOrder.TestProcedureEnv env) |
protected Procedure[] |
TestProcedureReplayOrder.TestTwoStepProcedure.execute(org.apache.hadoop.hbase.procedure2.TestProcedureReplayOrder.TestProcedureEnv env) |
protected Procedure[] |
ProcedureTestingUtility.TestProcedure.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureExecution.TestSequentialProcedure.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureExecution.TestFaultyRollback.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureExecution.TestWaitingProcedure.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureExecution.TestWaitingProcedure.TestWaitChild.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureRecovery.TestSingleStepProcedure.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureRecovery.BaseTestStepProcedure.execute(java.lang.Void env) |
Procedure[] |
TestProcedureRecovery.TestMultiStepProcedure.execute(java.lang.Void env) |
protected Procedure[] |
TestProcedureRecovery.TestMultiStepProcedure.Step1Procedure.execute(java.lang.Void env) |
Procedure |
ProcedureExecutor.getProcedure(long procId) |
protected static Procedure |
Procedure.newInstance(java.lang.String className) |
Modifier and Type | Method and Description |
---|---|
Pair<ProcedureInfo,Procedure> |
ProcedureExecutor.getResultOrProcedure(long procId) |
Modifier and Type | Method and Description |
---|---|
void |
ProcedureRunnableSet.addBack(Procedure proc)
Inserts the specified element at the end of this queue.
|
void |
ProcedureSimpleRunQueue.addBack(Procedure proc) |
void |
ProcedureRunnableSet.addFront(Procedure proc)
Inserts the specified element at the front of this queue.
|
void |
ProcedureSimpleRunQueue.addFront(Procedure proc) |
int |
Procedure.compareTo(Procedure other) |
void |
ProcedureRunnableSet.completionCleanup(Procedure proc)
The procedure in execution completed.
|
void |
ProcedureSimpleRunQueue.completionCleanup(Procedure proc) |
static ProcedureProtos.Procedure |
Procedure.convert(Procedure proc)
Helper to convert the procedure to protobuf.
|
static ProcedureInfo |
Procedure.createProcedureInfo(Procedure proc,
NonceKey nonceKey)
Helper to create the ProcedureInfo from Procedure.
|
protected static java.lang.Long |
Procedure.getRootProcedureId(java.util.Map<java.lang.Long,Procedure> procedures,
Procedure proc) |
static <TEnv> long |
ProcedureTestingUtility.submitAndWait(ProcedureExecutor<TEnv> procExecutor,
Procedure proc) |
static <TEnv> long |
ProcedureTestingUtility.submitAndWait(ProcedureExecutor<TEnv> procExecutor,
Procedure proc,
long nonceGroup,
long nonce) |
long |
ProcedureExecutor.submitProcedure(Procedure proc)
Add a new root-procedure to the executor.
|
static <TEnv> long |
ProcedureTestingUtility.submitProcedure(ProcedureExecutor<TEnv> procExecutor,
Procedure proc,
long nonceGroup,
long nonce) |
long |
ProcedureExecutor.submitProcedure(Procedure proc,
NonceKey nonceKey)
Add a new root-procedure to the executor.
|
protected static void |
Procedure.validateClass(Procedure proc) |
void |
ProcedureRunnableSet.yield(Procedure proc)
The procedure can't run at the moment.
|
void |
ProcedureSimpleRunQueue.yield(Procedure proc) |
Modifier and Type | Method and Description |
---|---|
protected static java.lang.Long |
Procedure.getRootProcedureId(java.util.Map<java.lang.Long,Procedure> procedures,
Procedure proc) |
Constructor and Description |
---|
TestSequentialProcedure(java.lang.String name,
java.util.List<java.lang.String> state,
Procedure... subProcs) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<Procedure> |
ProcedureStore.load()
Load the Procedures in the store.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcedureStore.insert(Procedure proc,
Procedure[] subprocs)
When a procedure is submitted to the executor insert(proc, null) will be called.
|
void |
ProcedureStore.insert(Procedure proc,
Procedure[] subprocs)
When a procedure is submitted to the executor insert(proc, null) will be called.
|
void |
ProcedureStore.update(Procedure proc)
The specified procedure was executed,
and the new state should be written to the store.
|
Modifier and Type | Class and Description |
---|---|
static class |
TestWALProcedureStore.TestSequentialProcedure |
Modifier and Type | Method and Description |
---|---|
protected Procedure[] |
TestWALProcedureStore.TestSequentialProcedure.execute(java.lang.Void env) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<Procedure> |
ProcedureWALFormatReader.getProcedures() |
java.util.Iterator<Procedure> |
WALProcedureStore.load() |
static java.util.Iterator<Procedure> |
ProcedureWALFormat.load(java.util.Iterator<ProcedureWALFile> logs,
ProcedureStoreTracker tracker,
org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALFormat.Loader loader) |
Modifier and Type | Method and Description |
---|---|
void |
WALProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
void |
WALProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
void |
WALProcedureStore.update(Procedure proc) |
static void |
ProcedureWALFormat.writeEntry(ByteSlot slot,
ProcedureProtos.ProcedureWALEntry.Type type,
Procedure proc,
Procedure[] subprocs) |
static void |
ProcedureWALFormat.writeEntry(ByteSlot slot,
ProcedureProtos.ProcedureWALEntry.Type type,
Procedure proc,
Procedure[] subprocs) |
static void |
ProcedureWALFormat.writeInsert(ByteSlot slot,
Procedure proc) |
static void |
ProcedureWALFormat.writeInsert(ByteSlot slot,
Procedure proc,
Procedure[] subprocs) |
static void |
ProcedureWALFormat.writeInsert(ByteSlot slot,
Procedure proc,
Procedure[] subprocs) |
static void |
ProcedureWALFormat.writeUpdate(ByteSlot slot,
Procedure proc) |