@InterfaceAudience.Private public class LogRollMasterProcedureManager extends MasterProcedureManager
MasterProcedureManager
and RegionServerProcedureManager
Modifier and Type | Field and Description |
---|---|
static int |
BACKUP_POOL_THREAD_NUMBER_DEFAULT |
static String |
BACKUP_POOL_THREAD_NUMBER_KEY |
static int |
BACKUP_TIMEOUT_MILLIS_DEFAULT |
static String |
BACKUP_TIMEOUT_MILLIS_KEY |
static int |
BACKUP_WAKE_MILLIS_DEFAULT |
static String |
BACKUP_WAKE_MILLIS_KEY |
private ProcedureCoordinator |
coordinator |
private boolean |
done |
private static org.slf4j.Logger |
LOG |
private MasterServices |
master |
static String |
ROLLLOG_PROCEDURE_NAME |
static String |
ROLLLOG_PROCEDURE_SIGNATURE |
Constructor and Description |
---|
LogRollMasterProcedureManager() |
Modifier and Type | Method and 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.
|
private boolean |
isBackupEnabled() |
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.
|
execProcedureWithRet
equals, hashCode
private static final org.slf4j.Logger LOG
public static final String ROLLLOG_PROCEDURE_SIGNATURE
public static final String ROLLLOG_PROCEDURE_NAME
public static final String BACKUP_WAKE_MILLIS_KEY
public static final String BACKUP_TIMEOUT_MILLIS_KEY
public static final 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
private MasterServices master
private ProcedureCoordinator coordinator
private boolean done
public LogRollMasterProcedureManager()
public void stop(String why)
Stoppable
why
- Why we're stopping.public boolean isStopped()
Stoppable
Stoppable.stop(String)
has been closed.public void initialize(MasterServices master, MetricsMaster metricsMaster) throws IOException, UnsupportedOperationException
MasterProcedureManager
initialize
in class MasterProcedureManager
master
- Master service interfaceIOException
UnsupportedOperationException
public String getProcedureSignature()
ProcedureManager
getProcedureSignature
in class ProcedureManager
public void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc) throws IOException
MasterProcedureManager
execProcedure
in class MasterProcedureManager
desc
- Procedure descriptionIOException
public void checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user) throws IOException
MasterProcedureManager
checkPermissions
in class MasterProcedureManager
IOException
- if permissions requirements are not met.private boolean isBackupEnabled()
public boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc)
MasterProcedureManager
isProcedureDone
in class MasterProcedureManager
desc
- Procedure descriptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.