| Package | Description |
|---|---|
| org.apache.hadoop.hbase.master.procedure | |
| org.apache.hadoop.hbase.procedure2 | |
| org.apache.hadoop.hbase.procedure2.store | |
| org.apache.hadoop.hbase.procedure2.store.wal |
| 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 |
class |
ServerCrashProcedure
Handle crashed server.
|
class |
TruncateTableProcedure |
| Modifier and Type | Field and Description |
|---|---|
private ArrayDeque<Procedure> |
MasterProcedureScheduler.QueueImpl.runnables |
| Modifier and Type | Method and Description |
|---|---|
private <T extends Comparable<T>> |
MasterProcedureScheduler.doPoll(MasterProcedureScheduler.FairQueue<T> fairq) |
Procedure |
MasterProcedureScheduler.QueueInterface.peek() |
Procedure |
MasterProcedureScheduler.QueueImpl.peek() |
Procedure |
MasterProcedureScheduler.poll() |
Procedure |
MasterProcedureScheduler.QueueInterface.poll() |
Procedure |
MasterProcedureScheduler.QueueImpl.poll() |
(package private) Procedure |
MasterProcedureScheduler.poll(long waitNsec) |
| Modifier and Type | Method and Description |
|---|---|
void |
MasterProcedureScheduler.QueueInterface.add(Procedure proc,
boolean addFront) |
void |
MasterProcedureScheduler.QueueImpl.add(Procedure proc,
boolean addToFront) |
void |
MasterProcedureScheduler.addBack(Procedure proc) |
protected void |
MasterProcedureScheduler.QueueImpl.addBack(Procedure proc) |
void |
MasterProcedureScheduler.addFront(Procedure proc) |
protected void |
MasterProcedureScheduler.QueueImpl.addFront(Procedure proc) |
private boolean |
MasterProcedureScheduler.TableQueue.canAbortPendingOperations(Procedure proc) |
void |
MasterProcedureScheduler.completionCleanup(Procedure proc) |
protected abstract void |
ProcedurePrepareLatch.countDown(Procedure proc) |
protected void |
ProcedurePrepareLatch.NoopLatch.countDown(Procedure proc) |
protected void |
ProcedurePrepareLatch.CompatibilityLatch.countDown(Procedure proc) |
private <T extends Comparable<T>> |
MasterProcedureScheduler.doAdd(MasterProcedureScheduler.FairQueue<T> fairq,
MasterProcedureScheduler.Queue<T> queue,
Procedure proc,
boolean addFront) |
private void |
MasterProcedureScheduler.doAdd(Procedure proc,
boolean addFront) |
private static ServerName |
MasterProcedureScheduler.getServerName(Procedure proc) |
private static TableName |
MasterProcedureScheduler.getTableName(Procedure proc) |
private static boolean |
MasterProcedureScheduler.isServerProcedure(Procedure proc) |
private static boolean |
MasterProcedureScheduler.isTableProcedure(Procedure proc) |
protected static void |
ProcedurePrepareLatch.releaseLatch(ProcedurePrepareLatch latch,
Procedure proc) |
void |
MasterProcedureScheduler.releaseServerExclusiveLock(Procedure procedure,
ServerName serverName)
Release the exclusive lock
|
void |
MasterProcedureScheduler.releaseServerSharedLock(Procedure procedure,
ServerName serverName)
Release the shared lock taken
|
void |
MasterProcedureScheduler.releaseTableExclusiveLock(Procedure procedure,
TableName table)
Release the exclusive lock taken with tryAcquireTableWrite()
|
void |
MasterProcedureScheduler.releaseTableSharedLock(Procedure procedure,
TableName table)
Release the shared lock taken with tryAcquireTableRead()
|
boolean |
MasterProcedureScheduler.ServerQueue.requireExclusiveLock(Procedure proc) |
boolean |
MasterProcedureScheduler.TableQueue.requireExclusiveLock(Procedure proc) |
boolean |
MasterProcedureScheduler.QueueInterface.requireExclusiveLock(Procedure proc) |
static byte[] |
ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure proc) |
protected long |
MasterProcedureUtil.NonceProcedureRunnable.submitProcedure(Procedure proc) |
boolean |
MasterProcedureScheduler.tryAcquireServerExclusiveLock(Procedure procedure,
ServerName serverName)
Try to acquire the exclusive lock on the specified server.
|
boolean |
MasterProcedureScheduler.tryAcquireServerSharedLock(Procedure procedure,
ServerName serverName)
Try to acquire the shared lock on the specified server.
|
boolean |
MasterProcedureScheduler.tryAcquireTableExclusiveLock(Procedure procedure,
TableName table)
Try to acquire the exclusive lock on the specified table.
|
private MasterProcedureScheduler.TableQueue |
MasterProcedureScheduler.tryAcquireTableQueueSharedLock(Procedure procedure,
TableName table) |
boolean |
MasterProcedureScheduler.tryAcquireTableSharedLock(Procedure procedure,
TableName table)
Try to acquire the shared lock on the specified table.
|
boolean |
MasterProcedureScheduler.waitEvent(MasterProcedureScheduler.ProcedureEvent event,
Procedure procedure) |
boolean |
MasterProcedureScheduler.waitEvent(MasterProcedureScheduler.ProcedureEvent event,
Procedure procedure,
boolean suspendQueue) |
boolean |
MasterProcedureEnv.waitInitialized(Procedure proc) |
boolean |
MasterProcedureEnv.waitServerCrashProcessingEnabled(Procedure proc) |
void |
MasterProcedureScheduler.yield(Procedure proc) |
| Modifier and Type | Class and Description |
|---|---|
class |
OnePhaseProcedure<TEnvironment> |
private static class |
ProcedureExecutor.CompletedProcedureCleaner<TEnvironment>
Internal cleaner that removes the completed procedure results after a TTL.
|
class |
SequentialProcedure<TEnvironment>
A SequentialProcedure describes one step in a procedure chain.
|
class |
StateMachineProcedure<TEnvironment,TState>
Procedure described by a series of steps.
|
class |
TwoPhaseProcedure<TEnvironment> |
| Modifier and Type | Field and Description |
|---|---|
private ConcurrentHashMap<Long,Procedure> |
ProcedureExecutor.procedures
Helper map to lookup the live procedures by ID.
|
private Deque<Procedure> |
ProcedureSimpleRunQueue.runnables |
private ArrayList<Procedure> |
RootProcedureState.subprocedures |
private TimeoutBlockingQueue<Procedure> |
ProcedureExecutor.waitingTimeout
Timeout Queue that contains Procedures in a WAITING_TIMEOUT state
or periodic procedures.
|
| Modifier and Type | Method and Description |
|---|---|
static Procedure |
Procedure.convert(org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.Procedure proto)
Helper to convert the protobuf procedure.
|
protected Procedure[] |
SequentialProcedure.doExecute(TEnvironment env) |
protected Procedure[] |
Procedure.doExecute(TEnvironment env)
Internal method called by the ProcedureExecutor that starts the
user-level code execute().
|
protected Procedure[] |
ProcedureExecutor.CompletedProcedureCleaner.execute(TEnvironment env) |
protected Procedure[] |
StateMachineProcedure.execute(TEnvironment env) |
protected abstract Procedure[] |
Procedure.execute(TEnvironment env)
The main code of the procedure.
|
Procedure |
ProcedureExecutor.getProcedure(long procId) |
protected static Procedure |
Procedure.newInstance(String className) |
Procedure |
ProcedureRunnableSet.poll()
Fetch one Procedure from the queue
|
Procedure |
ProcedureSimpleRunQueue.poll() |
| Modifier and Type | Method and Description |
|---|---|
Pair<ProcedureInfo,Procedure> |
ProcedureExecutor.getResultOrProcedure(long procId) |
protected List<Procedure> |
RootProcedureState.getSubprocedures() |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
RootProcedureState.acquire(Procedure proc)
Called by the ProcedureExecutor to mark the procedure step as running.
|
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) |
protected void |
RootProcedureState.addRollbackStep(Procedure proc)
Called by the ProcedureExecutor after the procedure step is completed,
to add the step to the rollback list (or procedure stack)
|
int |
Procedure.compareTo(Procedure other) |
void |
ProcedureRunnableSet.completionCleanup(Procedure proc)
The procedure in execution completed.
|
void |
ProcedureSimpleRunQueue.completionCleanup(Procedure proc) |
static org.apache.hadoop.hbase.protobuf.generated.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.
|
private void |
ProcedureExecutor.execLoop(Procedure proc) |
private void |
ProcedureExecutor.execProcedure(RootProcedureState procStack,
Procedure procedure)
Executes the specified procedure
- calls the doExecute() of the procedure
- if the procedure execution didn't fail (e.g.
|
private boolean |
ProcedureExecutor.executeRollback(Procedure proc)
Execute the rollback of the procedure step.
|
protected static Long |
Procedure.getRootProcedureId(Map<Long,Procedure> procedures,
Procedure proc) |
private Long |
ProcedureExecutor.getRootProcedureId(Procedure proc) |
long |
ProcedureExecutor.ProcedureTimeoutRetriever.getTimeout(Procedure proc) |
TimeUnit |
ProcedureExecutor.ProcedureTimeoutRetriever.getTimeUnit(Procedure proc) |
private void |
ProcedureExecutor.handleInterruptedException(Procedure proc,
InterruptedException e) |
protected void |
RootProcedureState.loadStack(Procedure proc)
Called on store load by the ProcedureExecutor to load part of the stack.
|
private void |
ProcedureExecutor.procedureFinished(Procedure proc) |
protected void |
RootProcedureState.release(Procedure proc)
Called by the ProcedureExecutor to mark the procedure step as finished.
|
long |
ProcedureExecutor.submitProcedure(Procedure proc)
>>>>>>> ce33cf2...
|
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 Long |
Procedure.getRootProcedureId(Map<Long,Procedure> procedures,
Procedure proc) |
| Modifier and Type | Method and Description |
|---|---|
Procedure |
ProcedureStore.ProcedureIterator.nextAsProcedure()
Returns the next procedure in the iteration.
|
| 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 |
NoopProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
void |
NoopProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
void |
ProcedureStore.update(Procedure proc)
The specified procedure was executed,
and the new state should be written to the store.
|
void |
NoopProcedureStore.update(Procedure proc) |
| Modifier and Type | Field and Description |
|---|---|
protected Procedure |
ProcedureWALFormatReader.Entry.procedure |
| Modifier and Type | Method and Description |
|---|---|
Procedure |
ProcedureWALFormatReader.Entry.convert() |
Procedure |
ProcedureWALFormatReader.EntryIterator.nextAsProcedure() |
| Modifier and Type | Method and Description |
|---|---|
void |
WALProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
void |
WALProcedureStore.insert(Procedure proc,
Procedure[] subprocs) |
private void |
ProcedureWALPrettyPrinter.printProcedure(Procedure<?> proc) |
void |
WALProcedureStore.update(Procedure proc) |
static void |
ProcedureWALFormat.writeEntry(ByteSlot slot,
org.apache.hadoop.hbase.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type,
Procedure proc,
Procedure[] subprocs) |
static void |
ProcedureWALFormat.writeEntry(ByteSlot slot,
org.apache.hadoop.hbase.protobuf.generated.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) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.