org.apache.hadoop.hbase.procedure2.store

Class NoopProcedureStore

java.lang.Object

org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase

org.apache.hadoop.hbase.procedure2.store.NoopProcedureStore

All Implemented Interfaces:

ProcedureStore

public class NoopProcedureStore
extends ProcedureStoreBase

An In-Memory store that does not keep track of the procedures inserted.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.procedure2.store.ProcedureStore

ProcedureStore.ProcedureIterator, ProcedureStore.ProcedureLoader, ProcedureStore.ProcedureStoreListener

Constructor Summary

Constructors

Constructor and Description
NoopProcedureStore()

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(long procId) The specified procId was removed from the executor, due to completion, abort or failure.
int	getNumThreads()
void	insert(Procedure proc, Procedure[] subprocs) When a procedure is submitted to the executor insert(proc, null) will be called.
void	load(ProcedureStore.ProcedureLoader loader) Load the Procedures in the store.
void	recoverLease() Acquire the lease for the procedure store.
void	start(int numThreads) Start/Open the procedure store
void	stop(boolean abort) Stop/Close the procedure store
void	update(Procedure proc) The specified procedure was executed, and the new state should be written to the store.

Methods inherited from class org.apache.hadoop.hbase.procedure2.store.ProcedureStoreBase

isRunning, registerListener, sendAbortProcessSignal, sendPostSyncSignal, setRunning, unregisterListener

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopProcedureStore

public NoopProcedureStore()

Method Detail

start

public void start(int numThreads)
           throws IOException

Description copied from interface: ProcedureStore

Start/Open the procedure store

Throws:

IOException

stop

public void stop(boolean abort)

Description copied from interface: ProcedureStore

Stop/Close the procedure store

Parameters:

abort - true if the stop is an abort

recoverLease

public void recoverLease()
                  throws IOException

Description copied from interface: ProcedureStore

Acquire the lease for the procedure store.

Throws:

IOException

getNumThreads

public int getNumThreads()

Returns:

the number of threads/slots passed to start()

load

public void load(ProcedureStore.ProcedureLoader loader)
          throws IOException

Description copied from interface: ProcedureStore

Load the Procedures in the store.

Parameters:

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

Throws:

IOException

insert

public void insert(Procedure proc,
          Procedure[] subprocs)

Description copied from interface: ProcedureStore

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.

Parameters:

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

subprocs - the newly created child of the proc.

update

public void update(Procedure proc)

Description copied from interface: ProcedureStore

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

Parameters:

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

delete

public void delete(long procId)

Description copied from interface: ProcedureStore

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.

Parameters:

procId - the ID of the procedure to remove.