org.apache.hadoop.hbase.backup.master

Class LogRollMasterProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.MasterProcedureManager

org.apache.hadoop.hbase.backup.master.LogRollMasterProcedureManager

All Implemented Interfaces:

Stoppable

public class LogRollMasterProcedureManager
extends MasterProcedureManager

Field Summary

Fields

Modifier and Type	Field and Description
static int	BACKUP_POOL_THREAD_NUMBER_DEFAULT
static java.lang.String	BACKUP_POOL_THREAD_NUMBER_KEY
static int	BACKUP_TIMEOUT_MILLIS_DEFAULT
static java.lang.String	BACKUP_TIMEOUT_MILLIS_KEY
static int	BACKUP_WAKE_MILLIS_DEFAULT
static java.lang.String	BACKUP_WAKE_MILLIS_KEY
static java.lang.String	ROLLLOG_PROCEDURE_NAME
static java.lang.String	ROLLLOG_PROCEDURE_SIGNATURE

Constructor Summary

Constructors

Constructor and Description
LogRollMasterProcedureManager()

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

ROLLLOG_PROCEDURE_SIGNATURE

public static final java.lang.String ROLLLOG_PROCEDURE_SIGNATURE

See Also:

Constant Field Values

ROLLLOG_PROCEDURE_NAME

public static final java.lang.String ROLLLOG_PROCEDURE_NAME

See Also:

Constant Field Values

BACKUP_WAKE_MILLIS_KEY

public static final java.lang.String BACKUP_WAKE_MILLIS_KEY

See Also:

Constant Field Values

BACKUP_TIMEOUT_MILLIS_KEY

public static final java.lang.String BACKUP_TIMEOUT_MILLIS_KEY

See Also:

Constant Field Values

BACKUP_POOL_THREAD_NUMBER_KEY

public static final java.lang.String BACKUP_POOL_THREAD_NUMBER_KEY

See Also:

Constant Field Values

BACKUP_WAKE_MILLIS_DEFAULT

public static final int BACKUP_WAKE_MILLIS_DEFAULT

See Also:

Constant Field Values

BACKUP_TIMEOUT_MILLIS_DEFAULT

public static final int BACKUP_TIMEOUT_MILLIS_DEFAULT

See Also:

Constant Field Values

BACKUP_POOL_THREAD_NUMBER_DEFAULT

public static final int BACKUP_POOL_THREAD_NUMBER_DEFAULT

See Also:

Constant Field Values

Constructor Detail

LogRollMasterProcedureManager

public LogRollMasterProcedureManager()

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