Package org.apache.hadoop.hbase.procedure2
package org.apache.hadoop.hbase.procedure2
-
ClassDescriptionCompletedProcedureCleaner<TEnvironment>Internal cleaner that removes the completed procedure results after a TTL.CompletedProcedureRetainer<TEnvironment>Hold the reference to a completed root procedure.DelayedProcedure<TEnvironment>Vessel that carries a Procedure and a timeout.FailedProcedure<TEnvironment>Used internally signaling failed queue of a remote procedure operation.Inline Chores (executors internal chores).Locking for mutual exclusion between procedures.Interface to get status of a Lock without getting access to acquire/release lock.Used internally signaling failed queue of a remote procedure operation.Used internally signaling failed queue of a remote procedure operation.Used internally signaling failed queue of a remote procedure operation.OnePhaseProcedure<TEnvironment>Procedure<TEnvironment>Base Procedure class responsible for Procedure Metadata; e.g.Thrown when a procedure is abortedType class.Basic ProcedureEvent that contains an "object", which can be a description or a reference to the resource to wait on, and a queue for suspended procedures.ProcedureExecutor<TEnvironment>Thread Pool that executes the submitted procedures.Class with parameters describing how to fail/die when in testing-context.A helper class for switching procedure out(yielding) while it is doing some time consuming operation, such as updating meta, where we can get a
CompletableFuture
about the operation.ProcedureInMemoryChore<TEnvironment>Special procedure used as a chore.With this interface, the procedure framework provides means to collect following set of metrics per procedure type for all procedures: Count of submitted procedure instances Time histogram for successfully completed procedure instances Count of failed procedure instances Please implement this interface to return appropriate metrics.Keep track of the runnable proceduresHelper to convert to/from ProcedureProtosA serializer (deserializer) for those Procedures which were serialized before this patch.A serializer for our Procedures.Indicate that a procedure wants to be rescheduled.RemoteProcedureDispatcher<TEnv,TRemote extends Comparable<TRemote>> A procedure dispatcher that aggregates and sends after elapsed time or after we hit count threshold.Delayed object that holds a FutureTask.RemoteProcedureDispatcher.RemoteNode<TEnv,TRemote> Account of what procedures are running on remote node.Data structure with reference to remote operation.RemoteProcedureDispatcher.RemoteProcedure<TEnv,TRemote> Remote procedure reference.A RemoteProcedureException is an exception from another thread or process.RootProcedureState<TEnvironment>Internal state of the ProcedureExecutor that describes the state of a "Root Procedure".A general interface for a sub procedure runs at RS side.SequentialProcedure<TEnvironment>A SequentialProcedure describes one step in a procedure chain:Simple scheduler for proceduresStateMachineProcedure<TEnvironment,TState> Procedure described by a series of steps.TimeoutExecutorThread<TEnvironment>Runs task on a period such as check for stuck workers.TwoPhaseProcedure<TEnvironment>