Package org.apache.hadoop.hbase.master.procedure

Class TableProcedureWaitingQueue

java.lang.Object

org.apache.hadoop.hbase.master.procedure.TableProcedureWaitingQueue

@Private
class TableProcedureWaitingQueue
extends Object

To prevent multiple Create/Modify/Disable/Enable table procedures run at the same time, we will keep table procedure in this queue first before actually enqueuing it to MasterProcedureScheduler's tableQueue. See HBASE-28683 for more details

Field Summary

Fields

Modifier and Type	Field	Description
private Procedure<?>	enqueuedProc
private final Function<Long,Procedure<?>>	procedureRetriever
private final Queue<Procedure<?>>	queue

Constructor Summary

Constructors

Constructor	Description
TableProcedureWaitingQueue(Function<Long,Procedure<?>> procedureRetriever)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	isEmpty()
private boolean	isSubProcedure(Procedure<?> proc)
(package private) Optional<Procedure<?>>	procedureCompleted(Procedure<?> proc)	Return the next procedure which can be enqueued to ProcedureScheduler.
(package private) boolean	procedureSubmitted(Procedure<?> proc)	Return whether we can enqueue this procedure to ProcedureScheduler.
String	toString()
(package private) int	waitingSize()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

procedureRetriever

private final Function<Long,Procedure<?>> procedureRetriever

enqueuedProc

private Procedure<?> enqueuedProc

queue

private final Queue<Procedure<?>> queue

Constructor Details

TableProcedureWaitingQueue

TableProcedureWaitingQueue(Function<Long,Procedure<?>> procedureRetriever)

Method Details

isSubProcedure

private boolean isSubProcedure(Procedure<?> proc)

procedureSubmitted

boolean procedureSubmitted(Procedure<?> proc)

Return whether we can enqueue this procedure to ProcedureScheduler.

If returns true, you should enqueue this procedure, otherwise you just need to do nothing, as we will queue it in the waitingQueue, and you will finally get it again by calling procedureCompleted(Procedure) method in the future.

procedureCompleted

Optional<Procedure<?>> procedureCompleted(Procedure<?> proc)

Return the next procedure which can be enqueued to ProcedureScheduler.

isEmpty

boolean isEmpty()

waitingSize

int waitingSize()

toString

public String toString()

Overrides:

toString in class Object