org.apache.hadoop.hbase.procedure.flush

Class MasterFlushTableProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.MasterProcedureManager

org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager

All Implemented Interfaces:

Stoppable

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class MasterFlushTableProcedureManager
extends MasterProcedureManager

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FLUSH_TABLE_PROCEDURE_SIGNATURE

Constructor Summary

Constructors

Constructor and Description
MasterFlushTableProcedureManager()

Method Summary

Modifier and Type	Method and Description
void	execProcedure(HBaseProtos.ProcedureDescription desc) Execute a distributed procedure on cluster
java.lang.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(java.lang.String why) Stop this service.

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

execProcedureWithRet

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

FLUSH_TABLE_PROCEDURE_SIGNATURE

public static final java.lang.String FLUSH_TABLE_PROCEDURE_SIGNATURE

See Also:

Constant Field Values

Constructor Detail

MasterFlushTableProcedureManager

public MasterFlushTableProcedureManager()

Method Detail

stop

public void stop(java.lang.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,
                       java.io.IOException,
                       java.lang.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

java.io.IOException

java.lang.UnsupportedOperationException

getProcedureSignature

public java.lang.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

execProcedure

public void execProcedure(HBaseProtos.ProcedureDescription desc)
                   throws java.io.IOException

Description copied from class: MasterProcedureManager

Execute a distributed procedure on cluster

Overrides:

execProcedure in class MasterProcedureManager

Parameters:

desc - Procedure description

Throws:

java.io.IOException

isProcedureDone

public boolean isProcedureDone(HBaseProtos.ProcedureDescription desc)
                        throws java.io.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:

java.io.IOException