@InterfaceAudience.Private public class LogRollRegionServerProcedureManager extends RegionServerProcedureManager
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
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 String |
BACKUP_REQUEST_THREADS_KEY
Conf key for number of request threads to start backup on region servers
|
private static long |
BACKUP_REQUEST_WAKE_MILLIS_DEFAULT
Default amount of time to check for errors while regions finish backup work
|
static 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 String |
BACKUP_TIMEOUT_MILLIS_KEY |
private static org.slf4j.Logger |
LOG |
private ProcedureMember |
member |
private ProcedureMemberRpcs |
memberRpcs |
private RegionServerServices |
rss |
private boolean |
started |
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.
|
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
private static final org.slf4j.Logger LOG
public static final String BACKUP_REQUEST_THREADS_KEY
public static final int BACKUP_REQUEST_THREADS_DEFAULT
public static final String BACKUP_TIMEOUT_MILLIS_KEY
public static final long BACKUP_TIMEOUT_MILLIS_DEFAULT
public static final String BACKUP_REQUEST_WAKE_MILLIS_KEY
private static final long BACKUP_REQUEST_WAKE_MILLIS_DEFAULT
private RegionServerServices rss
private ProcedureMemberRpcs memberRpcs
private ProcedureMember member
private boolean started
public LogRollRegionServerProcedureManager()
public void start()
start
in class RegionServerProcedureManager
public void stop(boolean force) throws IOException
stop
in class RegionServerProcedureManager
force
- forcefully stop all running tasksIOException
- exceptionpublic Subprocedure buildSubprocedure(byte[] data)
public void initialize(RegionServerServices rss) throws org.apache.zookeeper.KeeperException
RegionServerProcedureManager
initialize
in class RegionServerProcedureManager
rss
- Region Server service interfaceorg.apache.zookeeper.KeeperException
public String getProcedureSignature()
ProcedureManager
getProcedureSignature
in class ProcedureManager
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.