public class SimpleMasterProcedureManager extends MasterProcedureManager
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SIMPLE_DATA |
static java.lang.String |
SIMPLE_SIGNATURE |
Constructor and Description |
---|
SimpleMasterProcedureManager() |
Modifier and Type | Method and Description |
---|---|
byte[] |
execProcedureWithRet(HBaseProtos.ProcedureDescription desc)
Execute a distributed procedure on cluster with return data.
|
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.
|
execProcedure
equals, hashCode
public static final java.lang.String SIMPLE_SIGNATURE
public static final java.lang.String SIMPLE_DATA
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 byte[] execProcedureWithRet(HBaseProtos.ProcedureDescription desc) throws java.io.IOException
MasterProcedureManager
execProcedureWithRet
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