Package org.apache.hadoop.hbase.backup.regionserver

Class LogRollRegionServerProcedureManager

java.lang.Object

org.apache.hadoop.hbase.procedure.ProcedureManager

org.apache.hadoop.hbase.procedure.RegionServerProcedureManager

org.apache.hadoop.hbase.backup.regionserver.LogRollRegionServerProcedureManager

@Private
public class LogRollRegionServerProcedureManager
extends RegionServerProcedureManager

This manager class handles the work dealing with distributed WAL roll request.

This provides the mechanism necessary to kick off a backup specific Subprocedure that is responsible by this region server. If any failures occur with the sub-procedure, the manager's procedure member notifies the procedure coordinator to abort all others.

On startup, requires start() to be called.

On shutdown, requires org.apache.hadoop.hbase.procedure.ProcedureMember.close() to be called

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LogRollRegionServerProcedureManager.BackupSubprocedureBuilder	Build the actual backup procedure runner that will do all the 'hard' work

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BACKUP_REQUEST_THREADS_DEFAULT	# of threads for backup work on the rs.
static final String	BACKUP_REQUEST_THREADS_KEY	Conf key for number of request threads to start backup on region servers
private static final long	BACKUP_REQUEST_WAKE_MILLIS_DEFAULT	Default amount of time to check for errors while regions finish backup work
static final String	BACKUP_REQUEST_WAKE_MILLIS_KEY	Conf key for millis between checks to see if backup work completed or if there are errors
static final long	BACKUP_TIMEOUT_MILLIS_DEFAULT
static final String	BACKUP_TIMEOUT_MILLIS_KEY
private static final org.slf4j.Logger	LOG
private ProcedureMember	member
private ProcedureMemberRpcs	memberRpcs
private RegionServerServices	rss
private boolean	started

Constructor Summary

Constructors

Constructor	Description
LogRollRegionServerProcedureManager()	Create a default backup procedure manager

Method Summary

Modifier and Type	Method	Description
Subprocedure	buildSubprocedure(byte[] data)	If in a running state, creates the specified subprocedure for handling a backup procedure.
String	getProcedureSignature()	Return the unique signature of the procedure.
void	initialize(RegionServerServices rss)	Initialize a globally barriered procedure for region servers.
void	start()	Start accepting backup procedure requests.
void	stop(boolean force)	Close this and all running backup procedure tasks

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

BACKUP_REQUEST_THREADS_KEY

public static final String BACKUP_REQUEST_THREADS_KEY

Conf key for number of request threads to start backup on region servers

See Also:

• Constant Field Values

BACKUP_REQUEST_THREADS_DEFAULT

public static final int BACKUP_REQUEST_THREADS_DEFAULT

# of threads for backup work on the rs.

See Also:

• Constant Field Values

BACKUP_TIMEOUT_MILLIS_KEY

public static final String BACKUP_TIMEOUT_MILLIS_KEY

See Also:

• Constant Field Values

BACKUP_TIMEOUT_MILLIS_DEFAULT

public static final long BACKUP_TIMEOUT_MILLIS_DEFAULT

See Also:

• Constant Field Values

BACKUP_REQUEST_WAKE_MILLIS_KEY

public static final String BACKUP_REQUEST_WAKE_MILLIS_KEY

Conf key for millis between checks to see if backup work completed or if there are errors

See Also:

• Constant Field Values

BACKUP_REQUEST_WAKE_MILLIS_DEFAULT

private static final long BACKUP_REQUEST_WAKE_MILLIS_DEFAULT

Default amount of time to check for errors while regions finish backup work

See Also:

• Constant Field Values

rss

private RegionServerServices rss

memberRpcs

private ProcedureMemberRpcs memberRpcs

member

private ProcedureMember member

started

private boolean started

Constructor Details

LogRollRegionServerProcedureManager

public LogRollRegionServerProcedureManager()

Create a default backup procedure manager

Method Details

start

public void start()

Start accepting backup procedure requests.

Specified by:

start in class RegionServerProcedureManager

stop

public void stop(boolean force)
          throws IOException

Close this and all running backup procedure tasks

Specified by:

stop in class RegionServerProcedureManager

Parameters:

force - forcefully stop all running tasks

Throws:

IOException - exception

buildSubprocedure

public Subprocedure buildSubprocedure(byte[] data)

If in a running state, creates the specified subprocedure for handling a backup procedure.

Returns:

Subprocedure to submit to the ProcedureMember.

initialize

public void initialize(RegionServerServices rss)
                throws org.apache.zookeeper.KeeperException

Description copied from class: RegionServerProcedureManager

Initialize a globally barriered procedure for region servers.

Specified by:

initialize in class RegionServerProcedureManager

Parameters:

rss - Region Server service interface

Throws:

org.apache.zookeeper.KeeperException

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