org.apache.hadoop.hbase.procedure

Class SimpleRSProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.RegionServerProcedureManager

org.apache.hadoop.hbase.procedure.SimpleRSProcedureManager

public class SimpleRSProcedureManager
extends RegionServerProcedureManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SimpleRSProcedureManager.SimleSubprocedureBuilder Build the actual procedure runner that will do all the 'hard' work
class	SimpleRSProcedureManager.SimpleSubprocedure
class	SimpleRSProcedureManager.SimpleSubprocedurePool

Constructor Summary

Constructors

Constructor and Description
SimpleRSProcedureManager()

Method Summary

Modifier and Type	Method and Description
Subprocedure	buildSubprocedure(String name) If in a running state, creates the specified subprocedure for handling a procedure.
String	getProcedureSignature() Return the unique signature of the procedure.
void	initialize(RegionServerServices rss) Initialize a globally barriered procedure for region servers.
void	start() Start accepting procedure requests.
void	stop(boolean force) Close this and all running procedure tasks

Methods inherited from class org.apache.hadoop.hbase.procedure.ProcedureManager

equals, hashCode

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleRSProcedureManager

public SimpleRSProcedureManager()

Method Detail

initialize

public void initialize(RegionServerServices rss)
                throws KeeperException

Description copied from class: RegionServerProcedureManager

Initialize a globally barriered procedure for region servers.

Specified by:

initialize in class RegionServerProcedureManager

Parameters:

rss - Region Server service interface

Throws:

KeeperException

start

public void start()

Description copied from class: RegionServerProcedureManager

Start accepting procedure requests.

Specified by:

start in class RegionServerProcedureManager

stop

public void stop(boolean force)
          throws IOException

Description copied from class: RegionServerProcedureManager

Close this and all running procedure tasks

Specified by:

stop in class RegionServerProcedureManager

Parameters:

force - forcefully stop all running tasks

Throws:

IOException

getProcedureSignature

public String getProcedureSignature()

Description copied from class: ProcedureManager

Return the unique signature of the procedure. This signature uniquely identifies the procedure. By default, this signature is the string used in the procedure controller (i.e., the root ZK node name for the procedure)

Specified by:

getProcedureSignature in class ProcedureManager

buildSubprocedure

public Subprocedure buildSubprocedure(String name)

If in a running state, creates the specified subprocedure for handling a procedure.

Returns:

Subprocedure to submit to the ProcedureMemeber.