Uses of Class
org.apache.hadoop.hbase.procedure2.Procedure

Packages that use Procedure

Package	Description
org.apache.hadoop.hbase.master
org.apache.hadoop.hbase.master.assignment
org.apache.hadoop.hbase.master.locking
org.apache.hadoop.hbase.master.procedure
org.apache.hadoop.hbase.master.replication
org.apache.hadoop.hbase.procedure2
org.apache.hadoop.hbase.procedure2.store
org.apache.hadoop.hbase.procedure2.store.region
org.apache.hadoop.hbase.procedure2.store.wal
org.apache.hadoop.hbase.procedure2.trace
org.apache.hadoop.hbase.regionserver.storefiletracker
org.apache.hadoop.hbase.rsgroup

Uses of Procedure in org.apache.hadoop.hbase.master

Methods in org.apache.hadoop.hbase.master that return types with arguments of type Procedure

Modifier and Type	Method	Description
(package private) List<Procedure>	SplitWALManager.createSplitWALProcedures(List<org.apache.hadoop.fs.FileStatus> splittingWALs, ServerName crashedServer)
List<Procedure<?>>	HMaster.getProcedures()
List<Procedure<?>>	MasterServices.getProcedures()	Get procedures
List<Procedure>	SplitWALManager.splitWALs(ServerName crashedServer, boolean splitMeta)

Methods in org.apache.hadoop.hbase.master with parameters of type Procedure

Modifier and Type	Method	Description
ServerName	SplitWALManager.acquireSplitWALWorker(Procedure<?> procedure)	Acquire a split WAL worker
private long	ClusterSchemaServiceImpl.submitProcedure(Procedure<MasterProcedureEnv> procedure, NonceKey nonceKey)
void	WorkerAssigner.suspend(Procedure<?> proc)

Method parameters in org.apache.hadoop.hbase.master with type arguments of type Procedure

Modifier and Type	Method	Description
void	MasterCoprocessorHost.postGetProcedures(List<Procedure<?>> procInfoList)

Uses of Procedure in org.apache.hadoop.hbase.master.assignment

Subclasses of Procedure in org.apache.hadoop.hbase.master.assignment

Modifier and Type	Class	Description
private static class	AssignmentManager.DeadServerMetricRegionChore
private static class	AssignmentManager.RegionInTransitionChore
class	AssignProcedure	Deprecated. Do not use any more.
class	CloseRegionProcedure	The remote procedure used to close a region.
class	GCMergedRegionsProcedure	Deprecated. 2.3.0 Use GCMultipleMergedRegionsProcedure.
class	GCMultipleMergedRegionsProcedure	GC regions that have been Merged.
class	GCRegionProcedure	GC a Region that is no longer in use.
class	MergeTableRegionsProcedure	The procedure to Merge regions in a table.
class	MoveRegionProcedure	Deprecated. Do not use any more.
class	OpenRegionProcedure	The remote procedure used to open a region.
class	RegionRemoteProcedureBase	The base class for the remote procedures used to open/close a region.
class	RegionTransitionProcedure	Deprecated. Do not use any more.
class	SplitTableRegionProcedure	The procedure to split a region in a table.
class	TransitRegionStateProcedure	The procedure to deal with the state transition of a region.
class	UnassignProcedure	Deprecated. Do not use any more.

Methods in org.apache.hadoop.hbase.master.assignment that return Procedure

Modifier and Type	Method	Description
protected Procedure<MasterProcedureEnv>[]	RegionRemoteProcedureBase.execute(MasterProcedureEnv env)
protected Procedure[]	RegionTransitionProcedure.execute(MasterProcedureEnv env)	Deprecated.
protected Procedure[]	TransitRegionStateProcedure.execute(MasterProcedureEnv env)

Methods in org.apache.hadoop.hbase.master.assignment with parameters of type Procedure

Modifier and Type	Method	Description
boolean	RegionStateNode.isLockedBy(Procedure<?> proc)
void	RegionStateNode.lock(Procedure<?> proc, Runnable wakeUp)
(package private) void	RegionStateNodeLock.lock(Procedure<?> proc, Runnable wakeUp)	Lock by a procedure.
boolean	RegionStateNode.tryLock(Procedure<?> proc)
(package private) boolean	RegionStateNodeLock.tryLock(Procedure<?> proc)	TryLock by a procedure.
void	RegionStateNode.unlock(Procedure<?> proc)
(package private) void	RegionStateNodeLock.unlock(Procedure<?> proc)	Unlock by a procedure.
boolean	AssignmentManager.waitMetaAssigned(Procedure<?> proc, RegionInfo regionInfo)	Notice that this event does not mean the AM has already finished region state rebuilding.
boolean	AssignmentManager.waitMetaLoaded(Procedure<?> proc)	Wait until AM finishes the meta loading, i.e, the region states rebuilding.

Uses of Procedure in org.apache.hadoop.hbase.master.locking

Subclasses of Procedure in org.apache.hadoop.hbase.master.locking

Modifier and Type	Class	Description
final class	LockProcedure	Procedure to allow blessed clients and external admin tools to take our internal Schema locks used by the procedure framework isolating procedures doing creates/deletes etc.

Methods in org.apache.hadoop.hbase.master.locking that return Procedure

Modifier and Type	Method	Description
protected Procedure<MasterProcedureEnv>[]	LockProcedure.execute(MasterProcedureEnv env)

Uses of Procedure in org.apache.hadoop.hbase.master.procedure

Subclasses of Procedure in org.apache.hadoop.hbase.master.procedure

Modifier and Type	Class	Description
class	AbstractCloseTableRegionsProcedure<TState extends Enum<?>>	Base class for unassigning table regions.
class	AbstractStateMachineNamespaceProcedure<TState>	Base class for all the Namespace procedures that want to use a StateMachineProcedure.
class	AbstractStateMachineRegionProcedure<TState>	Base class for all the Region procedures that want to use a StateMachine.
class	AbstractStateMachineTableProcedure<TState>	Base class for all the Table procedures that want to use a StateMachineProcedure.
class	CloneSnapshotProcedure
class	CloseExcessRegionReplicasProcedure	Procedure for close excess region replicas.
class	CloseTableRegionsProcedure	Procedure for closing all regions for a table.
class	CreateNamespaceProcedure	The procedure to create a new namespace.
class	CreateTableProcedure
class	DeleteNamespaceProcedure	The procedure to remove a namespace.
class	DeleteTableProcedure
class	DisableTableProcedure
class	EnableTableProcedure
class	FlushRegionProcedure
class	FlushTableProcedure
class	HBCKServerCrashProcedure	Acts like the super class in all cases except when no Regions found in the current Master in-memory context.
class	InitMetaProcedure	This procedure is used to initialize meta table for a new hbase deploy.
class	MigrateNamespaceTableProcedure	Migrate the namespace data to meta table's namespace family while upgrading
class	ModifyNamespaceProcedure	The procedure to add a namespace to an existing table.
class	ModifyTableDescriptorProcedure	The procedure will only update the table descriptor without reopening all the regions.
class	ModifyTableProcedure
class	RecoverMetaProcedure	Deprecated. Do not use any more, leave it here only for compatible.
class	ReopenTableRegionsProcedure	Used for reopening the regions for a table.
class	RestoreSnapshotProcedure
class	ServerCrashProcedure	Handle crashed server.
class	ServerRemoteProcedure
class	SnapshotProcedure	A procedure used to take snapshot on tables.
class	SnapshotRegionProcedure	A remote procedure which is used to send region snapshot request to region server.
class	SnapshotVerifyProcedure	A remote procedure which is used to send verify snapshot request to region server.
class	SplitWALProcedure	The procedure is to split a WAL.
class	SplitWALRemoteProcedure	A remote procedure which is used to send split WAL request to region server.
class	SwitchRpcThrottleProcedure	The procedure to switch rpc throttle
class	SwitchRpcThrottleRemoteProcedure	The procedure to switch rpc throttle on region server
class	TruncateRegionProcedure
class	TruncateTableProcedure

Fields in org.apache.hadoop.hbase.master.procedure declared as Procedure

Modifier and Type	Field	Description
private Procedure<?>	TableProcedureWaitingQueue.enqueuedProc
private final Procedure<?>	ProcedureSyncWait.ProcedureFuture.proc

Fields in org.apache.hadoop.hbase.master.procedure with type parameters of type Procedure

Modifier and Type	Field	Description
private final Function<Long,Procedure<?>>	MasterProcedureScheduler.procedureRetriever
private final Function<Long,Procedure<?>>	SchemaLocking.procedureRetriever
private final Function<Long,Procedure<?>>	TableProcedureWaitingQueue.procedureRetriever
private final Queue<Procedure<?>>	TableProcedureWaitingQueue.queue

Methods in org.apache.hadoop.hbase.master.procedure that return Procedure

Modifier and Type	Method	Description
private Procedure<MasterProcedureEnv>[]	SnapshotProcedure.createRemoteSnapshotProcedures(MasterProcedureEnv env)
private Procedure[]	ServerCrashProcedure.createSplittingWalProcedures(MasterProcedureEnv env, boolean splitMeta)
protected Procedure	MasterProcedureScheduler.dequeue()
private <T extends Comparable<T>> Procedure<?>	MasterProcedureScheduler.doPoll(FairQueue<T> fairq)
protected Procedure<MasterProcedureEnv>[]	FlushRegionProcedure.execute(MasterProcedureEnv env)
protected Procedure<MasterProcedureEnv>[]	ServerRemoteProcedure.execute(MasterProcedureEnv env)
protected Procedure<MasterProcedureEnv>[]	SnapshotRegionProcedure.execute(MasterProcedureEnv env)
protected Procedure<MasterProcedureEnv>[]	SnapshotVerifyProcedure.execute(MasterProcedureEnv env)
Procedure<?>	Queue.peek()
Procedure<?>	Queue.poll()

Methods in org.apache.hadoop.hbase.master.procedure that return types with arguments of type Procedure

Modifier and Type	Method	Description
(package private) Optional<Procedure<?>>	TableProcedureWaitingQueue.procedureCompleted(Procedure<?> proc)	Return the next procedure which can be enqueued to ProcedureScheduler.

Methods in org.apache.hadoop.hbase.master.procedure with parameters of type Procedure

Modifier and Type	Method	Description
void	Queue.add(Procedure<?> proc, boolean addToFront)
void	MasterProcedureScheduler.completionCleanup(Procedure proc)
protected void	ProcedurePrepareLatch.CompatibilityLatch.countDown(Procedure proc)
protected abstract void	ProcedurePrepareLatch.countDown(Procedure proc)
protected void	ProcedurePrepareLatch.NoopLatch.countDown(Procedure proc)
static String	ProcedureDescriber.describe(Procedure<?> proc)
static String	ProcedureDescriber.describeParameters(Procedure<?> proc)
private <T extends Comparable<T>> void	MasterProcedureScheduler.doAdd(FairQueue<T> fairq, Queue<T> queue, Procedure<?> proc, boolean addFront)
protected void	MasterProcedureScheduler.enqueue(Procedure proc, boolean addFront)
private static String	MasterProcedureScheduler.getGlobalId(Procedure<?> proc)
private static String	MasterProcedureScheduler.getPeerId(Procedure<?> proc)
private static ServerName	MasterProcedureScheduler.getServerName(Procedure<?> proc)
private static TableName	MasterProcedureScheduler.getTableName(Procedure<?> proc)
private static boolean	MasterProcedureScheduler.isGlobalProcedure(Procedure<?> proc)
private <T extends Comparable<T>> boolean	MasterProcedureScheduler.isLockReady(Procedure<?> proc, Queue<T> rq)
private static boolean	MasterProcedureScheduler.isMetaProcedure(Procedure<?> proc)
private static boolean	MasterProcedureScheduler.isPeerProcedure(Procedure<?> proc)
private static boolean	MasterProcedureScheduler.isServerProcedure(Procedure<?> proc)
private boolean	TableProcedureWaitingQueue.isSubProcedure(Procedure<?> proc)
private static boolean	MasterProcedureScheduler.isTableProcedure(Procedure<?> proc)
(package private) boolean	MasterProcedureScheduler.markTableAsDeleted(TableName table, Procedure<?> procedure)	Tries to remove the queue and the table-lock of the specified table.
private static Object	ProcedureDescriber.parametersToObject(Procedure<?> proc)
(package private) Optional<Procedure<?>>	TableProcedureWaitingQueue.procedureCompleted(Procedure<?> proc)	Return the next procedure which can be enqueued to ProcedureScheduler.
(package private) boolean	TableProcedureWaitingQueue.procedureSubmitted(Procedure<?> proc)	Return whether we can enqueue this procedure to ProcedureScheduler.
static void	ProcedurePrepareLatch.releaseLatch(ProcedurePrepareLatch latch, Procedure proc)
(package private) boolean	GlobalQueue.requireExclusiveLock(Procedure<?> proc)
(package private) boolean	MetaQueue.requireExclusiveLock(Procedure<?> proc)	Deprecated.
boolean	PeerQueue.requireExclusiveLock(Procedure<?> proc)
(package private) abstract boolean	Queue.requireExclusiveLock(Procedure<?> proc)
boolean	ServerQueue.requireExclusiveLock(Procedure<?> proc)
boolean	TableQueue.requireExclusiveLock(Procedure<?> proc)
static byte[]	ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
protected long	MasterProcedureUtil.NonceProcedureRunnable.submitProcedure(Procedure<MasterProcedureEnv> proc)
static Future<byte[]>	ProcedureSyncWait.submitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
private void	MasterProcedureScheduler.tryCleanupGlobalQueue(String globalId, Procedure<?> procedure)
private void	MasterProcedureScheduler.tryCleanupPeerQueue(String peerId, Procedure<?> procedure)
private void	MasterProcedureScheduler.tryCleanupServerQueue(ServerName serverName, Procedure<?> proc)
static IOException	MasterProcedureUtil.unwrapRemoteIOException(Procedure<?> proc)	This is a version of unwrapRemoteIOException that can do DoNotRetryIOE.
static byte[]	ProcedureSyncWait.waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)
static byte[]	ProcedureSyncWait.waitForProcedureToCompleteIOE(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)
boolean	MasterProcedureScheduler.waitGlobalExclusiveLock(Procedure<?> procedure, String globalId)	Try to acquire the share lock on global.
boolean	MasterProcedureEnv.waitInitialized(Procedure<?> proc)
boolean	MasterProcedureScheduler.waitMetaExclusiveLock(Procedure<?> procedure)	Deprecated. only used for RecoverMetaProcedure.
boolean	MasterProcedureScheduler.waitNamespaceExclusiveLock(Procedure<?> procedure, String namespace)	Suspend the procedure if the specified namespace is already locked.
boolean	MasterProcedureScheduler.waitPeerExclusiveLock(Procedure<?> procedure, String peerId)	Try to acquire the exclusive lock on the specified peer.
boolean	MasterProcedureScheduler.waitRegion(Procedure<?> procedure, RegionInfo regionInfo)	Suspend the procedure if the specified region is already locked.
boolean	MasterProcedureScheduler.waitRegions(Procedure<?> procedure, TableName table, RegionInfo... regionInfos)	Suspend the procedure if the specified set of regions are already locked.
boolean	MasterProcedureScheduler.waitServerExclusiveLock(Procedure<?> procedure, ServerName serverName)	Try to acquire the exclusive lock on the specified server.
boolean	MasterProcedureScheduler.waitTableExclusiveLock(Procedure<?> procedure, TableName table)	Suspend the procedure if the specified table is already locked.
private TableQueue	MasterProcedureScheduler.waitTableQueueSharedLock(Procedure<?> procedure, TableName table)
boolean	MasterProcedureScheduler.waitTableSharedLock(Procedure<?> procedure, TableName table)	Suspend the procedure if the specified table is already locked.
void	MasterProcedureScheduler.wakeGlobalExclusiveLock(Procedure<?> procedure, String globalId)	Wake the procedures waiting for global.
void	MasterProcedureScheduler.wakeMetaExclusiveLock(Procedure<?> procedure)	Deprecated. only used for RecoverMetaProcedure.
void	MasterProcedureScheduler.wakeNamespaceExclusiveLock(Procedure<?> procedure, String namespace)	Wake the procedures waiting for the specified namespace
void	MasterProcedureScheduler.wakePeerExclusiveLock(Procedure<?> procedure, String peerId)	Wake the procedures waiting for the specified peer
void	MasterProcedureScheduler.wakeRegion(Procedure<?> procedure, RegionInfo regionInfo)	Wake the procedures waiting for the specified region
void	MasterProcedureScheduler.wakeRegions(Procedure<?> procedure, TableName table, RegionInfo... regionInfos)	Wake the procedures waiting for the specified regions
void	MasterProcedureScheduler.wakeServerExclusiveLock(Procedure<?> procedure, ServerName serverName)	Wake the procedures waiting for the specified server
void	MasterProcedureScheduler.wakeTableExclusiveLock(Procedure<?> procedure, TableName table)	Wake the procedures waiting for the specified table
void	MasterProcedureScheduler.wakeTableSharedLock(Procedure<?> procedure, TableName table)	Wake the procedures waiting for the specified table
void	MasterProcedureScheduler.yield(Procedure proc)

Constructors in org.apache.hadoop.hbase.master.procedure with parameters of type Procedure

Modifier	Constructor	Description
	ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc)

Constructor parameters in org.apache.hadoop.hbase.master.procedure with type arguments of type Procedure

Modifier	Constructor	Description
	MasterProcedureScheduler(Function<Long,Procedure<?>> procedureRetriever)
	SchemaLocking(Function<Long,Procedure<?>> procedureRetriever)
(package private)	TableProcedureWaitingQueue(Function<Long,Procedure<?>> procedureRetriever)

Uses of Procedure in org.apache.hadoop.hbase.master.replication

Subclasses of Procedure in org.apache.hadoop.hbase.master.replication

Modifier and Type	Class	Description
class	AbstractPeerNoLockProcedure<TState>	Base class for replication peer related procedures which do not need to hold locks(for most of the sub procedures).
class	AbstractPeerProcedure<TState>	The base class for all replication peer related procedure.
class	AddPeerProcedure	The procedure for adding a new replication peer.
class	AssignReplicationQueuesProcedure
class	ClaimReplicationQueueRemoteProcedure
class	ClaimReplicationQueuesProcedure	Deprecated. Use AssignReplicationQueuesProcedure instead, kept only for keeping compatibility.
class	DisablePeerProcedure	The procedure for disabling a replication peer.
class	EnablePeerProcedure	The procedure for enabling a replication peer.
class	MigrateReplicationQueueFromZkToTableProcedure	A procedure for migrating replication queue data from zookeeper to hbase:replication table.
class	ModifyPeerProcedure	The base class for all replication peer related procedure except sync replication state transition.
class	RecoverStandbyProcedure	The procedure for replaying all the remote wals for transitting a sync replication peer from STANDBY to DOWNGRADE_ACTIVE.
class	RefreshPeerProcedure
class	RemovePeerProcedure	The procedure for removing a replication peer.
class	SyncReplicationReplayWALProcedure	The procedure for replaying a set of remote wals.
class	SyncReplicationReplayWALRemoteProcedure	A remote procedure which is used to send replaying remote wal work to region server.
class	TransitPeerSyncReplicationStateProcedure	The procedure for transit current sync replication state for a synchronous replication peer.
class	UpdatePeerConfigProcedure	The procedure for updating the config for a replication peer.

Methods in org.apache.hadoop.hbase.master.replication that return Procedure

Modifier and Type	Method	Description
protected Procedure<MasterProcedureEnv>[]	ClaimReplicationQueueRemoteProcedure.execute(MasterProcedureEnv env)
protected Procedure<MasterProcedureEnv>[]	ClaimReplicationQueuesProcedure.execute(MasterProcedureEnv env)	Deprecated.

Methods in org.apache.hadoop.hbase.master.replication with parameters of type Procedure

Modifier and Type	Method	Description
ServerName	SyncReplicationReplayWALManager.acquirePeerWorker(String peerId, Procedure<?> proc)	Get a worker for replaying remote wal for a give peer.
void	SyncReplicationReplayWALManager.UsedReplayWorkersForPeer.suspend(Procedure<?> proc)

Uses of Procedure in org.apache.hadoop.hbase.procedure2

Subclasses of Procedure in org.apache.hadoop.hbase.procedure2

Modifier and Type	Class	Description
(package private) class	CompletedProcedureCleaner<TEnvironment>	Internal cleaner that removes the completed procedure results after a TTL.
class	FailedProcedure<TEnvironment>
class	OnePhaseProcedure<TEnvironment>
class	ProcedureInMemoryChore<TEnvironment>	Special procedure used as a chore.
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>

Fields in org.apache.hadoop.hbase.procedure2 declared as Procedure

Modifier and Type	Field	Description
private Procedure<TEnvironment>	ProcedureExecutor.WorkerThread.activeProcedure
private Procedure<?>	LockAndQueue.exclusiveLockOwnerProcedure
private final Procedure<?>	LockedResource.exclusiveLockOwnerProcedure
private final Procedure<TEnvironment>	CompletedProcedureRetainer.procedure

Fields in org.apache.hadoop.hbase.procedure2 with type parameters of type Procedure

Modifier and Type	Field	Description
private final Function<Long,Procedure<?>>	LockAndQueue.procedureRetriever
private final ConcurrentHashMap<Long,Procedure<TEnvironment>>	ProcedureExecutor.procedures	Helper map to lookup the live procedures by ID.
private List<Procedure<TEnvironment>>	StateMachineProcedure.subProcList
private Set<Procedure<TEnvironment>>	RootProcedureState.subprocs
private ArrayList<Procedure<TEnvironment>>	RootProcedureState.subprocStack
private final List<Procedure<?>>	LockedResource.waitingProcedures

Methods in org.apache.hadoop.hbase.procedure2 with type parameters of type Procedure

Modifier and Type	Method	Description
protected <T extends Procedure<TEnvironment>> void	StateMachineProcedure.addChildProcedure(T... subProcedure)	Add a child procedure to execute
<T extends Procedure<TEnvironment>> T	ProcedureExecutor.getProcedure(Class<T> clazz, long procId)

Methods in org.apache.hadoop.hbase.procedure2 that return Procedure

Modifier and Type	Method	Description
static Procedure<?>	ProcedureUtil.convertToProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure proto)	Helper to convert the protobuf procedure.
protected abstract Procedure	AbstractProcedureScheduler.dequeue()	Fetch one Procedure from the queue NOTE: this method is called with the sched lock held.
protected Procedure	SimpleProcedureScheduler.dequeue()
protected Procedure<TEnvironment>[]	Procedure.doExecute(TEnvironment env)	Internal method called by the ProcedureExecutor that starts the user-level code execute().
protected Procedure[]	SequentialProcedure.doExecute(TEnvironment env)
protected Procedure<TEnvironment>[]	FailedProcedure.execute(TEnvironment env)
protected abstract Procedure<TEnvironment>[]	Procedure.execute(TEnvironment env)	The main code of the procedure.
protected Procedure<TEnvironment>[]	ProcedureInMemoryChore.execute(TEnvironment env)
protected Procedure[]	StateMachineProcedure.execute(TEnvironment env)
Procedure<?>	LockAndQueue.getExclusiveLockOwnerProcedure()
Procedure<?>	LockedResource.getExclusiveLockOwnerProcedure()
Procedure<?>	LockStatus.getExclusiveLockOwnerProcedure()	Get the procedure which holds the exclusive lock.
Procedure<TEnvironment>	CompletedProcedureRetainer.getProcedure()
Procedure<TEnvironment>	ProcedureExecutor.getProcedure(long procId)
Procedure<TEnvironment>	ProcedureExecutor.getResult(long procId)
Procedure<TEnvironment>	ProcedureExecutor.getResultOrProcedure(long procId)
private Procedure<TEnvironment>[]	ProcedureExecutor.initializeChildren(RootProcedureState<TEnvironment> procStack, Procedure<TEnvironment> procedure, Procedure<TEnvironment>[] subprocs)
private static Procedure<?>	ProcedureUtil.newProcedure(String className)
Procedure	AbstractProcedureScheduler.poll()
Procedure	AbstractProcedureScheduler.poll(long nanos)
Procedure	AbstractProcedureScheduler.poll(long timeout, TimeUnit unit)
Procedure	ProcedureScheduler.poll()	Fetch one Procedure from the queue
Procedure	ProcedureScheduler.poll(long timeout, TimeUnit unit)	Fetch one Procedure from the queue
private Procedure<TEnvironment>	ProcedureExecutor.prepareProcedure(Procedure<TEnvironment> proc)
Procedure<?>	LockAndQueue.removeFirst()

Methods in org.apache.hadoop.hbase.procedure2 that return types with arguments of type Procedure

Modifier and Type	Method	Description
Stream<Procedure>	LockAndQueue.filterWaitingQueue(Predicate<Procedure> predicate)
Collection<Procedure<TEnvironment>>	ProcedureExecutor.getActiveProceduresNoCopy()	Should only be used when starting up, where the procedure workers have not been started.
List<Procedure<TEnvironment>>	ProcedureExecutor.getProcedures()	Get procedures.
protected List<Procedure<TEnvironment>>	RootProcedureState.getSubproceduresStack()
protected Collection<Procedure<TEnvironment>>	RootProcedureState.getSubprocs()
List<Procedure<?>>	LockedResource.getWaitingProcedures()

Methods in org.apache.hadoop.hbase.procedure2 with parameters of type Procedure

Modifier and Type	Method	Description
protected boolean	RootProcedureState.acquire(Procedure<TEnvironment> proc)	Called by the ProcedureExecutor to mark the procedure step as running.
private Procedure.LockState	ProcedureExecutor.acquireLock(Procedure<TEnvironment> proc)
void	TimeoutExecutorThread.add(Procedure<TEnvironment> procedure)
void	AbstractProcedureScheduler.addBack(Procedure procedure)
void	AbstractProcedureScheduler.addBack(Procedure procedure, boolean notify)
void	ProcedureScheduler.addBack(Procedure proc)	Inserts the specified element at the end of this queue.
void	ProcedureScheduler.addBack(Procedure proc, boolean notify)	Inserts the specified element at the end of this queue.
protected <T extends Procedure<TEnvironment>> void	StateMachineProcedure.addChildProcedure(T... subProcedure)	Add a child procedure to execute
void	AbstractProcedureScheduler.addFront(Procedure procedure)
void	AbstractProcedureScheduler.addFront(Procedure procedure, boolean notify)
void	ProcedureScheduler.addFront(Procedure proc)	Inserts the specified element at the front of this queue.
void	ProcedureScheduler.addFront(Procedure proc, boolean notify)	Inserts the specified element at the front of this queue.
void	LockAndQueue.addLast(Procedure<?> proc)
protected boolean	RootProcedureState.addRollbackStep(Procedure<TEnvironment> proc)	Called by the ProcedureExecutor after the procedure step is completed, to add the step to the rollback list (or procedure stack).
protected void	RootProcedureState.addSubProcedure(Procedure<TEnvironment> proc)
static boolean	ProcedureFutureUtil.checkFuture(Procedure<?> proc, Supplier<CompletableFuture<Void>> getFuture, Consumer<CompletableFuture<Void>> setFuture, Runnable actionAfterDone)
private void	ProcedureExecutor.cleanupAfterRollbackOneStep(Procedure<TEnvironment> proc)
int	Procedure.compareTo(Procedure<TEnvironment> other)
void	ProcedureScheduler.completionCleanup(Procedure proc)	The procedure in execution completed.
void	SimpleProcedureScheduler.completionCleanup(Procedure proc)
static org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.Procedure	ProcedureUtil.convertToProtoProcedure(Procedure<?> proc)	Helper to convert the procedure to protobuf.
private void	ProcedureExecutor.countDownChildren(RootProcedureState<TEnvironment> procStack, Procedure<TEnvironment> procedure)
protected abstract void	AbstractProcedureScheduler.enqueue(Procedure procedure, boolean addFront)	Add the procedure to the queue.
protected void	SimpleProcedureScheduler.enqueue(Procedure procedure, boolean addFront)
private void	ProcedureExecutor.execCompletionCleanup(Procedure<TEnvironment> proc)
private void	ProcedureExecutor.execProcedure(RootProcedureState<TEnvironment> procStack, Procedure<TEnvironment> procedure)	Executes procedure Calls the doExecute() of the procedure If the procedure execution didn't fail (i.e.
private Procedure.LockState	ProcedureExecutor.executeNormalRollback(Procedure<TEnvironment> rootProc, RootProcedureState<TEnvironment> procStack)
private void	ProcedureExecutor.executeProcedure(Procedure<TEnvironment> proc)
private Procedure.LockState	ProcedureExecutor.executeRollback(Procedure<TEnvironment> proc)	Execute the rollback of the procedure step.
protected void	TimeoutExecutorThread.executeTimedoutProcedure(Procedure<TEnvironment> proc)
private void	ProcedureExecutor.executeUnexpectedRollback(Procedure<TEnvironment> rootProc, RootProcedureState<TEnvironment> procStack)
protected static <T> Long	Procedure.getRootProcedureId(Map<Long,Procedure<T>> procedures, Procedure<T> proc)	Helper to lookup the root Procedure ID given a specified procedure.
(package private) Long	ProcedureExecutor.getRootProcedureId(Procedure<TEnvironment> proc)
private void	ProcedureExecutor.handleInterruptedException(Procedure<TEnvironment> proc, InterruptedException e)
boolean	LockAndQueue.hasLockAccess(Procedure<?> proc)
boolean	LockStatus.hasLockAccess(Procedure<?> proc)	Return true if the procedure itself holds the exclusive lock, or any ancestors of the give procedure hold the exclusive lock.
static boolean	Procedure.haveSameParent(Procedure<?> a, Procedure<?> b)
private Procedure<TEnvironment>[]	ProcedureExecutor.initializeChildren(RootProcedureState<TEnvironment> procStack, Procedure<TEnvironment> procedure, Procedure<TEnvironment>[] subprocs)
private boolean	ProcedureExecutor.isRootFinished(Procedure<?> proc)
protected void	RootProcedureState.loadStack(Procedure<TEnvironment> proc)	Called on store load by the ProcedureExecutor to load part of the stack.
private Procedure<TEnvironment>	ProcedureExecutor.prepareProcedure(Procedure<TEnvironment> proc)
protected void	AbstractProcedureScheduler.push(Procedure procedure, boolean addFront, boolean notify)
private long	ProcedureExecutor.pushProcedure(Procedure<TEnvironment> proc)
protected void	RootProcedureState.release(Procedure<TEnvironment> proc)	Called by the ProcedureExecutor to mark the procedure step as finished.
boolean	LockAndQueue.releaseExclusiveLock(Procedure<?> proc)	Returns whether we should wake the procedures waiting on the lock here.
private void	ProcedureExecutor.releaseLock(Procedure<TEnvironment> proc, boolean force)
boolean	TimeoutExecutorThread.remove(Procedure<TEnvironment> procedure)
private void	ProcedureExecutor.restoreLock(Procedure<TEnvironment> proc, Set<Long> restored)
private void	ProcedureExecutor.rootProcedureFinished(Procedure<TEnvironment> proc)
private void	ProcedureExecutor.submitChildrenProcedures(Procedure<TEnvironment>[] subprocs)
long	ProcedureExecutor.submitProcedure(Procedure<TEnvironment> proc)	Add a new root-procedure to the executor.
long	ProcedureExecutor.submitProcedure(Procedure<TEnvironment> proc, NonceKey nonceKey)	Add a new root-procedure to the executor.
void	ProcedureExecutor.submitProcedures(Procedure<TEnvironment>[] procs)	Add a set of new root-procedure to the executor.
static void	ProcedureFutureUtil.suspend(Procedure<?> proc)
static void	ProcedureFutureUtil.suspendIfNecessary(Procedure<?> proc, Consumer<CompletableFuture<Void>> setFuture, CompletableFuture<Void> future, MasterProcedureEnv env, Runnable actionAfterDone)
boolean	ProcedureEvent.suspendIfNotReady(Procedure proc)	Returns true if event is not ready and adds procedure to suspended queue, else returns false.
boolean	LockAndQueue.tryExclusiveLock(Procedure<?> proc)
boolean	LockAndQueue.trySharedLock(Procedure<?> proc)	Returns whether we have succesfully acquired the shared lock.
private void	ProcedureExecutor.updateStoreOnExec(RootProcedureState<TEnvironment> procStack, Procedure<TEnvironment> procedure, Procedure<TEnvironment>[] subprocs)
(package private) static void	ProcedureUtil.validateClass(Procedure<?> proc)
protected void	AbstractProcedureScheduler.waitProcedure(LockAndQueue lockAndQueue, Procedure proc)
boolean	ProcedureEvent.wakeIfSuspended(AbstractProcedureScheduler procedureScheduler, Procedure<?> proc)	Wakes up the suspended procedures only if the given proc is waiting on this event.
protected void	AbstractProcedureScheduler.wakeProcedure(Procedure procedure)
static void	ProcedureFutureUtil.wakeUp(Procedure<?> proc, MasterProcedureEnv env)
void	ProcedureScheduler.yield(Procedure proc)	The procedure can't run at the moment.
void	SimpleProcedureScheduler.yield(Procedure proc)
private void	ProcedureExecutor.yieldProcedure(Procedure<TEnvironment> proc)

Method parameters in org.apache.hadoop.hbase.procedure2 with type arguments of type Procedure

Modifier and Type	Method	Description
void	AbstractProcedureScheduler.addFront(Iterator<Procedure> procedureIterator)
void	ProcedureScheduler.addFront(Iterator<Procedure> procedureIterator)	Inserts all elements in the iterator at the front of this queue.
Stream<Procedure>	LockAndQueue.filterWaitingQueue(Predicate<Procedure> predicate)
protected static <T> Long	Procedure.getRootProcedureId(Map<Long,Procedure<T>> procedures, Procedure<T> proc)	Helper to lookup the root Procedure ID given a specified procedure.
private void	ProcedureExecutor.initializeStacks(ProcedureStore.ProcedureIterator procIter, List<Procedure<TEnvironment>> runnableList, List<Procedure<TEnvironment>> failedList, List<Procedure<TEnvironment>> waitingList, List<Procedure<TEnvironment>> waitingTimeoutList)
private void	ProcedureExecutor.processWaitingProcedures(List<Procedure<TEnvironment>> waitingList, List<Procedure<TEnvironment>> runnableList)
private void	ProcedureExecutor.processWaitingTimeoutProcedures(List<Procedure<TEnvironment>> waitingTimeoutList)
private void	ProcedureExecutor.pushProceduresAfterLoad(List<Procedure<TEnvironment>> runnableList, List<Procedure<TEnvironment>> failedList)
private void	ProcedureExecutor.restoreLocks(Deque<Procedure<TEnvironment>> stack, Set<Long> restored)

Constructors in org.apache.hadoop.hbase.procedure2 with parameters of type Procedure

Modifier	Constructor	Description
	CompletedProcedureRetainer(Procedure<TEnvironment> procedure)
	DelayedProcedure(Procedure<TEnvironment> procedure)
	LockedResource(LockedResourceType resourceType, String resourceName, LockType lockType, Procedure<?> exclusiveLockOwnerProcedure, int sharedLockCount, List<Procedure<?>> waitingProcedures)

Constructor parameters in org.apache.hadoop.hbase.procedure2 with type arguments of type Procedure

Modifier	Constructor	Description
	LockAndQueue(Function<Long,Procedure<?>> procedureRetriever)
	LockedResource(LockedResourceType resourceType, String resourceName, LockType lockType, Procedure<?> exclusiveLockOwnerProcedure, int sharedLockCount, List<Procedure<?>> waitingProcedures)

Uses of Procedure in org.apache.hadoop.hbase.procedure2.store

Fields in org.apache.hadoop.hbase.procedure2.store declared as Procedure

Modifier and Type	Field	Description
private Procedure<?>	ProtoAndProcedure.proc

Methods in org.apache.hadoop.hbase.procedure2.store that return Procedure

Modifier and Type	Method	Description
Procedure<?>	ProtoAndProcedure.getProcedure()
Procedure<?>	InMemoryProcedureIterator.next()
Procedure	ProcedureStore.ProcedureIterator.next()	Returns the next procedure in the iteration.

Methods in org.apache.hadoop.hbase.procedure2.store with parameters of type Procedure

Modifier and Type	Method	Description
void	NoopProcedureStore.delete(Procedure<?> proc, long[] subprocs)
void	ProcedureStore.delete(Procedure<?> parentProc, long[] subProcIds)	The parent procedure completed.
void	NoopProcedureStore.insert(Procedure<?>[] proc)
void	NoopProcedureStore.insert(Procedure<?> proc, Procedure<?>[] subprocs)
void	ProcedureStore.insert(Procedure<?>[] procs)	Serialize a set of new procedures.
void	ProcedureStore.insert(Procedure<?> proc, Procedure<?>[] subprocs)	When a procedure is submitted to the executor insert(proc, null) will be called.
void	NoopProcedureStore.update(Procedure<?> proc)
void	ProcedureStore.update(Procedure<?> proc)	The specified procedure was executed, and the new state should be written to the store.

Uses of Procedure in org.apache.hadoop.hbase.procedure2.store.region

Methods in org.apache.hadoop.hbase.procedure2.store.region with parameters of type Procedure

Modifier and Type	Method	Description
void	RegionProcedureStore.delete(Procedure<?> parentProc, long[] subProcIds)
void	RegionProcedureStore.insert(Procedure<?>[] procs)
void	RegionProcedureStore.insert(Procedure<?> proc, Procedure<?>[] subProcs)
private void	RegionProcedureStore.serializePut(Procedure<?> proc, List<Mutation> mutations, List<byte[]> rowsToLock)
void	RegionProcedureStore.update(Procedure<?> proc)

Method parameters in org.apache.hadoop.hbase.procedure2.store.region with type arguments of type Procedure

Modifier and Type	Method	Description
private void	RegionProcedureStore.checkUnsupportedProcedure(Map<Class<?>,List<Procedure<?>>> procsByType)	In HBASE-20811, we have introduced a new TRSP to assign/unassign/move regions, and it is incompatible with the old AssignProcedure/UnassignProcedure/MoveRegionProcedure.

Uses of Procedure in org.apache.hadoop.hbase.procedure2.store.wal

Methods in org.apache.hadoop.hbase.procedure2.store.wal with parameters of type Procedure

Modifier and Type	Method	Description
void	WALProcedureStore.delete(Procedure<?> proc, long[] subProcIds)	Deprecated.
void	WALProcedureStore.insert(Procedure<?>[] procs)	Deprecated.
void	WALProcedureStore.insert(Procedure<?> proc, Procedure<?>[] subprocs)	Deprecated.
private void	ProcedureWALPrettyPrinter.printProcedure(Procedure<?> proc)	Deprecated.
void	WALProcedureStore.update(Procedure<?> proc)	Deprecated.
static void	ProcedureWALFormat.writeDelete(ByteSlot slot, Procedure<?> proc, long[] subprocs)	Deprecated.
static void	ProcedureWALFormat.writeEntry(ByteSlot slot, org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos.ProcedureWALEntry.Type type, Procedure<?> proc, Procedure<?>[] subprocs)	Deprecated.
static void	ProcedureWALFormat.writeInsert(ByteSlot slot, Procedure<?> proc)	Deprecated.
static void	ProcedureWALFormat.writeInsert(ByteSlot slot, Procedure<?> proc, Procedure<?>[] subprocs)	Deprecated.
static void	ProcedureWALFormat.writeUpdate(ByteSlot slot, Procedure<?> proc)	Deprecated.

Uses of Procedure in org.apache.hadoop.hbase.procedure2.trace

Constructors in org.apache.hadoop.hbase.procedure2.trace with parameters of type Procedure

Modifier	Constructor	Description
	ProcedureSpanBuilder(Procedure<?> proc)

Uses of Procedure in org.apache.hadoop.hbase.regionserver.storefiletracker

Subclasses of Procedure in org.apache.hadoop.hbase.regionserver.storefiletracker

Modifier and Type	Class	Description
class	InitializeStoreFileTrackerProcedure	Procedure for setting StoreFileTracker information to table descriptor.
class	ModifyColumnFamilyStoreFileTrackerProcedure
class	ModifyStoreFileTrackerProcedure	This procedure is used to change the store file tracker implementation.
class	ModifyTableStoreFileTrackerProcedure

Uses of Procedure in org.apache.hadoop.hbase.rsgroup

Subclasses of Procedure in org.apache.hadoop.hbase.rsgroup

Modifier and Type	Class	Description
class	MigrateRSGroupProcedure	Procedure for migrating rs group information to table descriptor.