org.apache.hadoop.hbase.procedure2

Class ProcedureExecutor<TEnvironment>

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TEnvironment>

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class ProcedureExecutor<TEnvironment>
extends Object

Thread Pool that executes the submitted procedures. The executor has a ProcedureStore associated. Each operation is logged and on restart the pending procedures are resumed. Unless the Procedure code throws an error (e.g. invalid user input) the procedure will complete (at some point in time), On restart the pending procedures are resumed and the once failed will be rolledback. The user can add procedures to the executor via submitProcedure(proc) check for the finished state via isFinished(procId) and get the result via getResult(procId)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ProcedureExecutor.ProcedureExecutorListener
static class	ProcedureExecutor.Testing

Constructor Summary

Constructors

Constructor and Description
ProcedureExecutor(org.apache.hadoop.conf.Configuration conf, TEnvironment environment, ProcedureStore store)
ProcedureExecutor(org.apache.hadoop.conf.Configuration conf, TEnvironment environment, ProcedureStore store, ProcedureRunnableSet runqueue)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	abort(long procId) Send an abort notification the specified procedure.
boolean	abort(long procId, boolean mayInterruptIfRunning) Send an abort notification the specified procedure.
int	getActiveExecutorCount()
TEnvironment	getEnvironment()
int	getNumThreads()
Procedure	getProcedure(long procId)
ProcedureInfo	getResult(long procId)
Pair<ProcedureInfo,Procedure>	getResultOrProcedure(long procId)
Map<Long,ProcedureInfo>	getResults()
protected ProcedureRunnableSet	getRunnableSet()
ProcedureStore	getStore()
boolean	isFinished(long procId) Return true if the procedure is finished.
boolean	isProcedureOwner(long procId, User user) Check if the user is this procedure's owner
boolean	isRunning()
boolean	isStarted(long procId) Return true if the procedure is started.
void	join()
List<ProcedureInfo>	listProcedures() List procedures.
void	registerListener(ProcedureExecutor.ProcedureExecutorListener listener)
void	removeResult(long procId) Mark the specified completed procedure, as ready to remove.
void	start(int numThreads)
void	stop()
long	submitProcedure(Procedure proc) Add a new root-procedure to the executor.
long	submitProcedure(Procedure proc, long nonceGroup, long nonce) Add a new root-procedure to the executor.
boolean	unregisterListener(ProcedureExecutor.ProcedureExecutorListener listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureExecutor

public ProcedureExecutor(org.apache.hadoop.conf.Configuration conf,
                 TEnvironment environment,
                 ProcedureStore store)

ProcedureExecutor

public ProcedureExecutor(org.apache.hadoop.conf.Configuration conf,
                 TEnvironment environment,
                 ProcedureStore store,
                 ProcedureRunnableSet runqueue)

Method Detail

start

public void start(int numThreads)
           throws IOException

Throws:

IOException

stop

public void stop()

join

public void join()

isRunning

public boolean isRunning()

getNumThreads

public int getNumThreads()

Returns:

the number of execution threads.

getActiveExecutorCount

public int getActiveExecutorCount()

getEnvironment

public TEnvironment getEnvironment()

getStore

public ProcedureStore getStore()

registerListener

public void registerListener(ProcedureExecutor.ProcedureExecutorListener listener)

unregisterListener

public boolean unregisterListener(ProcedureExecutor.ProcedureExecutorListener listener)

listProcedures

public List<ProcedureInfo> listProcedures()

List procedures.

Returns:

the procedures in a list

submitProcedure

public long submitProcedure(Procedure proc)

Add a new root-procedure to the executor.

Parameters:

proc - the new procedure to execute.

Returns:

the procedure id, that can be used to monitor the operation

submitProcedure

public long submitProcedure(Procedure proc,
                   long nonceGroup,
                   long nonce)

Add a new root-procedure to the executor.

Parameters:

proc - the new procedure to execute.

nonceGroup -

nonce -

Returns:

the procedure id, that can be used to monitor the operation

getResult

public ProcedureInfo getResult(long procId)

isFinished

public boolean isFinished(long procId)

Return true if the procedure is finished. The state may be "completed successfully" or "failed and rolledback". Use getResult() to check the state or get the result data.

Parameters:

procId - the ID of the procedure to check

Returns:

true if the procedure execution is finished, otherwise false.

isStarted

public boolean isStarted(long procId)

Return true if the procedure is started.

Parameters:

procId - the ID of the procedure to check

Returns:

true if the procedure execution is started, otherwise false.

removeResult

public void removeResult(long procId)

Mark the specified completed procedure, as ready to remove.

Parameters:

procId - the ID of the procedure to remove

abort

public boolean abort(long procId)

Send an abort notification the specified procedure. Depending on the procedure implementation the abort can be considered or ignored.

Parameters:

procId - the procedure to abort

Returns:

true if the procedure exist and has received the abort, otherwise false.

abort

public boolean abort(long procId,
            boolean mayInterruptIfRunning)

Send an abort notification the specified procedure. Depending on the procedure implementation the abort can be considered or ignored.

Parameters:

procId - the procedure to abort

mayInterruptIfRunning - if the proc completed at least one step, should it be aborted?

Returns:

true if the procedure exist and has received the abort, otherwise false.

isProcedureOwner

public boolean isProcedureOwner(long procId,
                       User user)

Check if the user is this procedure's owner

Parameters:

procId - the target procedure

user - the user

Returns:

true if the user is the owner of the procedure, false otherwise or the owner is unknown.

getResults

public Map<Long,ProcedureInfo> getResults()

getProcedure

public Procedure getProcedure(long procId)

getRunnableSet

protected ProcedureRunnableSet getRunnableSet()

getResultOrProcedure

public Pair<ProcedureInfo,Procedure> getResultOrProcedure(long procId)