@InterfaceAudience.LimitedPrivate(value="Configuration") public class MasterFlushTableProcedureManager extends MasterProcedureManager
Modifier and Type | Field and Description |
---|---|
static String |
FLUSH_TABLE_PROCEDURE_SIGNATURE |
Constructor and Description |
---|
MasterFlushTableProcedureManager() |
Modifier and Type | Method and Description |
---|---|
void |
execProcedure(org.apache.hadoop.hbase.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.
|
boolean |
isProcedureDone(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ProcedureDescription desc)
Check if the procedure is finished successfully
|
boolean |
isStopped() |
void |
stop(String why)
Stop this service.
|
execProcedureWithRet
equals, hashCode
public static final String FLUSH_TABLE_PROCEDURE_SIGNATURE
public void stop(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 org.apache.zookeeper.KeeperException, IOException, UnsupportedOperationException
MasterProcedureManager
initialize
in class MasterProcedureManager
master
- Master service interfaceorg.apache.zookeeper.KeeperException
IOException
UnsupportedOperationException
public String getProcedureSignature()
ProcedureManager
getProcedureSignature
in class ProcedureManager
public void execProcedure(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ProcedureDescription desc) throws IOException
MasterProcedureManager
execProcedure
in class MasterProcedureManager
desc
- Procedure descriptionIOException
public boolean isProcedureDone(org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ProcedureDescription desc) throws IOException
MasterProcedureManager
isProcedureDone
in class MasterProcedureManager
desc
- Procedure descriptionIOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.