@InterfaceAudience.LimitedPrivate(value="Configuration") public class MasterFlushTableProcedureManager extends MasterProcedureManager
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FLUSH_TABLE_PROCEDURE_SIGNATURE |
Constructor and Description |
---|
MasterFlushTableProcedureManager() |
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 FLUSH_TABLE_PROCEDURE_SIGNATURE
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