org.apache.hadoop.hbase.procedure

Class SimpleMasterProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.MasterProcedureManager

org.apache.hadoop.hbase.procedure.SimpleMasterProcedureManager

All Implemented Interfaces:

Stoppable

public class SimpleMasterProcedureManager
extends MasterProcedureManager

Field Summary

Fields

Modifier and Type	Field and Description
static String	SIMPLE_DATA
static String	SIMPLE_SIGNATURE

Constructor Summary

Constructors

Constructor and Description
SimpleMasterProcedureManager()

Method Summary

Modifier and Type	Method and Description
byte[]	execProcedureWithRet(HBaseProtos.ProcedureDescription desc) Execute a distributed procedure on cluster with return data.
String	getProcedureSignature() Return the unique signature of the procedure.
void	initialize(MasterServices master, MetricsMaster metricsMaster) Initialize a globally barriered procedure for master.
boolean	isProcedureDone(HBaseProtos.ProcedureDescription desc) Check if the procedure is finished successfully
boolean	isStopped()
void	stop(String why) Stop this service.

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

execProcedure

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

Field Detail

SIMPLE_SIGNATURE

public static final String SIMPLE_SIGNATURE

See Also:

Constant Field Values

SIMPLE_DATA

public static final String SIMPLE_DATA

See Also:

Constant Field Values

Constructor Detail

SimpleMasterProcedureManager

public SimpleMasterProcedureManager()

Method Detail

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service.

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Returns:

True if Stoppable.stop(String) has been closed.

initialize

public void initialize(MasterServices master,
                       MetricsMaster metricsMaster)
                throws KeeperException,
                       IOException,
                       UnsupportedOperationException

Description copied from class: MasterProcedureManager

Initialize a globally barriered procedure for master.

Specified by:

initialize in class MasterProcedureManager

Parameters:

master - Master service interface

Throws:

KeeperException

IOException

UnsupportedOperationException

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

execProcedureWithRet

public byte[] execProcedureWithRet(HBaseProtos.ProcedureDescription desc)
                            throws IOException

Description copied from class: MasterProcedureManager

Execute a distributed procedure on cluster with return data.

Overrides:

execProcedureWithRet in class MasterProcedureManager

Parameters:

desc - Procedure description

Returns:

data returned from the procedure execution, null if no data

Throws:

IOException

isProcedureDone

public boolean isProcedureDone(HBaseProtos.ProcedureDescription desc)
                        throws IOException

Description copied from class: MasterProcedureManager

Check if the procedure is finished successfully

Specified by:

isProcedureDone in class MasterProcedureManager

Parameters:

desc - Procedure description

Returns:

true if the specified procedure is finished successfully

Throws:

IOException