Package 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

@LimitedPrivate("Configuration")
public class MasterFlushTableProcedureManager
extends MasterProcedureManager

Field Summary

Fields

Modifier and Type	Field	Description
private ProcedureCoordinator	coordinator
private static final int	FLUSH_PROC_POOL_THREADS_DEFAULT
private static final String	FLUSH_PROC_POOL_THREADS_KEY
static final String	FLUSH_PROCEDURE_ENABLED
static final boolean	FLUSH_PROCEDURE_ENABLED_DEFAULT
static final String	FLUSH_TABLE_PROCEDURE_SIGNATURE
private static final int	FLUSH_TIMEOUT_MILLIS_DEFAULT
private static final String	FLUSH_TIMEOUT_MILLIS_KEY
private static final int	FLUSH_WAKE_MILLIS_DEFAULT
private static final String	FLUSH_WAKE_MILLIS_KEY
private static final org.slf4j.Logger	LOG
private MasterServices	master
private Map<TableName,Procedure>	procMap
private boolean	stopped

Constructor Summary

Constructors

Constructor	Description
MasterFlushTableProcedureManager()

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.
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

FLUSH_TABLE_PROCEDURE_SIGNATURE

public static final String FLUSH_TABLE_PROCEDURE_SIGNATURE

See Also:

• Constant Field Values

FLUSH_PROCEDURE_ENABLED

public static final String FLUSH_PROCEDURE_ENABLED

See Also:

• Constant Field Values

FLUSH_PROCEDURE_ENABLED_DEFAULT

public static final boolean FLUSH_PROCEDURE_ENABLED_DEFAULT

See Also:

• Constant Field Values

FLUSH_TIMEOUT_MILLIS_KEY

private static final String FLUSH_TIMEOUT_MILLIS_KEY

See Also:

• Constant Field Values

FLUSH_TIMEOUT_MILLIS_DEFAULT

private static final int FLUSH_TIMEOUT_MILLIS_DEFAULT

See Also:

• Constant Field Values

FLUSH_WAKE_MILLIS_KEY

private static final String FLUSH_WAKE_MILLIS_KEY

See Also:

• Constant Field Values

FLUSH_WAKE_MILLIS_DEFAULT

private static final int FLUSH_WAKE_MILLIS_DEFAULT

See Also:

• Constant Field Values

FLUSH_PROC_POOL_THREADS_KEY

private static final String FLUSH_PROC_POOL_THREADS_KEY

See Also:

• Constant Field Values

FLUSH_PROC_POOL_THREADS_DEFAULT

private static final int FLUSH_PROC_POOL_THREADS_DEFAULT

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

master

private MasterServices master

coordinator

private ProcedureCoordinator coordinator

procMap

private Map<TableName,Procedure> procMap

stopped

private boolean stopped

Constructor Details

MasterFlushTableProcedureManager

public MasterFlushTableProcedureManager()

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 org.apache.zookeeper.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:

org.apache.zookeeper.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

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.

isProcedureDone

public boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.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