org.apache.hadoop.hbase.procedure2.store

接口 ProcedureStore

所有已知实现类:

NoopProcedureStore, ProcedureStoreBase, WALProcedureStore

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public interface ProcedureStore

The ProcedureStore is used by the executor to persist the state of each procedure execution. This allows to resume the execution of pending/in-progress procedures in case of machine failure or service shutdown.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	ProcedureStore.ProcedureIterator An Iterator over a collection of Procedure
static interface	ProcedureStore.ProcedureLoader Interface passed to the ProcedureStore.load() method to handle the store-load events.
static interface	ProcedureStore.ProcedureStoreListener Store listener interface.

方法概要

限定符和类型	方法和说明
void	delete(long procId) The specified procId was removed from the executor, due to completion, abort or failure.
void	delete(long[] procIds, int offset, int count) The specified procIds were removed from the executor, due to completion, abort or failure.
void	delete(Procedure parentProc, long[] subProcIds) The parent procedure completed.
int	getNumThreads()
void	insert(Procedure[] procs) Serialize a set of new procedures.
void	insert(Procedure proc, Procedure[] subprocs) When a procedure is submitted to the executor insert(proc, null) will be called.
boolean	isRunning()
void	load(ProcedureStore.ProcedureLoader loader) Load the Procedures in the store.
void	recoverLease() Acquire the lease for the procedure store.
void	registerListener(ProcedureStore.ProcedureStoreListener listener) Add the listener to the notification list.
int	setRunningProcedureCount(int count) Set the number of procedure running.
void	start(int numThreads) Start/Open the procedure store
void	stop(boolean abort) Stop/Close the procedure store
boolean	unregisterListener(ProcedureStore.ProcedureStoreListener listener) Remove the listener from the notification list.
void	update(Procedure proc) The specified procedure was executed, and the new state should be written to the store.

方法详细资料

registerListener

void registerListener(ProcedureStore.ProcedureStoreListener listener)

Add the listener to the notification list.

参数:

listener - The AssignmentListener to register

unregisterListener

boolean unregisterListener(ProcedureStore.ProcedureStoreListener listener)

Remove the listener from the notification list.

参数:

listener - The AssignmentListener to unregister

返回:

true if the listner was in the list and it was removed, otherwise false.

start

void start(int numThreads)
    throws IOException

Start/Open the procedure store

参数:

numThreads -

抛出:

IOException

stop

void stop(boolean abort)

Stop/Close the procedure store

参数:

abort - true if the stop is an abort

isRunning

boolean isRunning()

返回:

true if the store is running, otherwise false.

getNumThreads

int getNumThreads()

返回:

the number of threads/slots passed to start()

setRunningProcedureCount

int setRunningProcedureCount(int count)

Set the number of procedure running. This can be used, for example, by the store to know how long to wait before a sync.

返回:

how many procedures are running (may not be same as count).

recoverLease

void recoverLease()
           throws IOException

Acquire the lease for the procedure store.

抛出:

IOException

load

void load(ProcedureStore.ProcedureLoader loader)
   throws IOException

Load the Procedures in the store.

参数:

loader - the ProcedureLoader that will handle the store-load events

抛出:

IOException

insert

void insert(Procedure proc,
            Procedure[] subprocs)

When a procedure is submitted to the executor insert(proc, null) will be called. 'proc' has a 'RUNNABLE' state and the initial information required to start up. When a procedure is executed and it returns children insert(proc, subprocs) will be called. 'proc' has a 'WAITING' state and an update state. 'subprocs' are the children in 'RUNNABLE' state with the initial information.

参数:

proc - the procedure to serialize and write to the store.

subprocs - the newly created child of the proc.

insert

void insert(Procedure[] procs)

Serialize a set of new procedures. These procedures are freshly submitted to the executor and each procedure has a 'RUNNABLE' state and the initial information required to start up.

参数:

procs - the procedures to serialize and write to the store.

update

void update(Procedure proc)

The specified procedure was executed, and the new state should be written to the store.

参数:

proc - the procedure to serialize and write to the store.

delete

void delete(long procId)

The specified procId was removed from the executor, due to completion, abort or failure. The store implementor should remove all the information about the specified procId.

参数:

procId - the ID of the procedure to remove.

delete

void delete(Procedure parentProc,
            long[] subProcIds)

The parent procedure completed. Update the state and mark all the child deleted.

参数:

parentProc - the parent procedure to serialize and write to the store.

subProcIds - the IDs of the sub-procedure to remove.

delete

void delete(long[] procIds,
            int offset,
            int count)

The specified procIds were removed from the executor, due to completion, abort or failure. The store implementor should remove all the information about the specified procIds.

参数:

procIds - the IDs of the procedures to remove.

offset - the array offset from where to start to delete

count - the number of IDs to delete