public class LogRollMasterProcedureManager extends MasterProcedureManager
Modifier and Type | Field and Description |
---|---|
static int |
BACKUP_POOL_THREAD_NUMBER_DEFAULT |
static java.lang.String |
BACKUP_POOL_THREAD_NUMBER_KEY |
static int |
BACKUP_TIMEOUT_MILLIS_DEFAULT |
static java.lang.String |
BACKUP_TIMEOUT_MILLIS_KEY |
static int |
BACKUP_WAKE_MILLIS_DEFAULT |
static java.lang.String |
BACKUP_WAKE_MILLIS_KEY |
static java.lang.String |
ROLLLOG_PROCEDURE_NAME |
static java.lang.String |
ROLLLOG_PROCEDURE_SIGNATURE |
Constructor and Description |
---|
LogRollMasterProcedureManager() |
Modifier and Type | Method and Description |
---|---|
void |
execProcedure(HBaseProtos.ProcedureDescription desc)
Execute a distributed procedure on cluster
|
java.lang.String |
getProcedureSignature()
Return the unique signature of the procedure.
|
void |
initialize(MasterServices master,
MetricsMaster metricsMaster)
Initialize a globally barriered procedure for master.
|
boolean |
isProcedureDone(HBaseProtos.ProcedureDescription desc)
Check if the procedure is finished successfully
|
boolean |
isStopped() |
void |
stop(java.lang.String why)
Stop this service.
|
execProcedureWithRet
equals, hashCode
public static final java.lang.String ROLLLOG_PROCEDURE_SIGNATURE
public static final java.lang.String ROLLLOG_PROCEDURE_NAME
public static final java.lang.String BACKUP_WAKE_MILLIS_KEY
public static final java.lang.String BACKUP_TIMEOUT_MILLIS_KEY
public static final java.lang.String BACKUP_POOL_THREAD_NUMBER_KEY
public static final int BACKUP_WAKE_MILLIS_DEFAULT
public static final int BACKUP_TIMEOUT_MILLIS_DEFAULT
public static final int BACKUP_POOL_THREAD_NUMBER_DEFAULT
public void stop(java.lang.String why)
Stoppable
why
- Why we're stopping.public boolean isStopped()
Stoppable.stop(String)
has been closed.public void initialize(MasterServices master, MetricsMaster metricsMaster) throws KeeperException, java.io.IOException, java.lang.UnsupportedOperationException
MasterProcedureManager
initialize
in class MasterProcedureManager
master
- Master service interfaceKeeperException
java.io.IOException
java.lang.UnsupportedOperationException
public java.lang.String getProcedureSignature()
ProcedureManager
getProcedureSignature
in class ProcedureManager
public void execProcedure(HBaseProtos.ProcedureDescription desc) throws java.io.IOException
MasterProcedureManager
execProcedure
in class MasterProcedureManager
desc
- Procedure descriptionjava.io.IOException
public boolean isProcedureDone(HBaseProtos.ProcedureDescription desc) throws java.io.IOException
MasterProcedureManager
isProcedureDone
in class MasterProcedureManager
desc
- Procedure descriptionjava.io.IOException