Package 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

@Private
public class LogRollMasterProcedureManager
extends MasterProcedureManager

Master procedure manager for coordinated cluster-wide WAL roll operation, which is run during backup operation, see MasterProcedureManager and RegionServerProcedureManager

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BACKUP_POOL_THREAD_NUMBER_DEFAULT
static final String	BACKUP_POOL_THREAD_NUMBER_KEY
static final int	BACKUP_TIMEOUT_MILLIS_DEFAULT
static final String	BACKUP_TIMEOUT_MILLIS_KEY
static final int	BACKUP_WAKE_MILLIS_DEFAULT
static final String	BACKUP_WAKE_MILLIS_KEY
private ProcedureCoordinator	coordinator
private boolean	done
private static final org.slf4j.Logger	LOG
private MasterServices	master
static final String	ROLLLOG_PROCEDURE_NAME
static final String	ROLLLOG_PROCEDURE_SIGNATURE

Constructor Summary

Constructors

Constructor	Description
LogRollMasterProcedureManager()

Method Summary

Modifier and Type	Method	Description
void	checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)	Check for required permissions before executing the procedure.
void	execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)	Execute a distributed procedure on cluster
String	getProcedureSignature()	Return the unique signature of the procedure.
void	initialize(MasterServices master, MetricsMaster metricsMaster)	Initialize a globally barriered procedure for master.
private boolean	isBackupEnabled()
boolean	isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)	Check if the procedure is finished successfully
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
void	stop(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 Details

LOG

private static final org.slf4j.Logger LOG

ROLLLOG_PROCEDURE_SIGNATURE

public static final String ROLLLOG_PROCEDURE_SIGNATURE

See Also:

• Constant Field Values

ROLLLOG_PROCEDURE_NAME

public static final String ROLLLOG_PROCEDURE_NAME

See Also:

• Constant Field Values

BACKUP_WAKE_MILLIS_KEY

public static final String BACKUP_WAKE_MILLIS_KEY

See Also:

• Constant Field Values

BACKUP_TIMEOUT_MILLIS_KEY

public static final String BACKUP_TIMEOUT_MILLIS_KEY

See Also:

• Constant Field Values

BACKUP_POOL_THREAD_NUMBER_KEY

public static final 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

master

private MasterServices master

coordinator

private ProcedureCoordinator coordinator

done

private boolean done

Constructor Details

LogRollMasterProcedureManager

public LogRollMasterProcedureManager()

Method Details

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Description copied from interface: Stoppable

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

initialize

public void initialize(MasterServices master,
 MetricsMaster metricsMaster)
                throws 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:

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

execProcedure

public void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)
                   throws IOException

Description copied from class: MasterProcedureManager

Execute a distributed procedure on cluster

Overrides:

execProcedure in class MasterProcedureManager

Parameters:

desc - Procedure description

Throws:

IOException

checkPermissions

public void checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc,
 AccessChecker accessChecker,
 User user)
                      throws IOException

Description copied from class: MasterProcedureManager

Check for required permissions before executing the procedure.

Specified by:

checkPermissions in class MasterProcedureManager

Throws:

IOException - if permissions requirements are not met.

isBackupEnabled

private boolean isBackupEnabled()

isProcedureDone

public boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)

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