public class LogRollRegionServerProcedureManager extends RegionServerProcedureManager
HRegionServer
.
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 subprocedure, 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
Modifier and Type | Class and Description |
---|---|
class |
LogRollRegionServerProcedureManager.BackupSubprocedureBuilder
Build the actual backup procedure runner that will do all the 'hard' work
|
Modifier and Type | Field and Description |
---|---|
static int |
BACKUP_REQUEST_THREADS_DEFAULT
# of threads for backup work on the rs.
|
static java.lang.String |
BACKUP_REQUEST_THREADS_KEY
Conf key for number of request threads to start backup on regionservers
|
static java.lang.String |
BACKUP_REQUEST_WAKE_MILLIS_KEY
Conf key for millis between checks to see if backup work completed or if there are errors
|
static long |
BACKUP_TIMEOUT_MILLIS_DEFAULT |
static java.lang.String |
BACKUP_TIMEOUT_MILLIS_KEY |
Constructor and Description |
---|
LogRollRegionServerProcedureManager()
Create a default backup procedure manager
|
Modifier and Type | Method and Description |
---|---|
Subprocedure |
buildSubprocedure(byte[] data)
If in a running state, creates the specified subprocedure for handling a backup procedure.
|
java.lang.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
|
equals, hashCode
public static final java.lang.String BACKUP_REQUEST_THREADS_KEY
public static final int BACKUP_REQUEST_THREADS_DEFAULT
public static final java.lang.String BACKUP_TIMEOUT_MILLIS_KEY
public static final long BACKUP_TIMEOUT_MILLIS_DEFAULT
public static final java.lang.String BACKUP_REQUEST_WAKE_MILLIS_KEY
public LogRollRegionServerProcedureManager()
public void start()
start
in class RegionServerProcedureManager
public void stop(boolean force) throws java.io.IOException
stop
in class RegionServerProcedureManager
force
- forcefully stop all running tasksjava.io.IOException
- exceptionpublic Subprocedure buildSubprocedure(byte[] data)
public void initialize(RegionServerServices rss) throws java.io.IOException
RegionServerProcedureManager
initialize
in class RegionServerProcedureManager
rss
- Region Server service interfacejava.io.IOException
public java.lang.String getProcedureSignature()
ProcedureManager
getProcedureSignature
in class ProcedureManager