Class MasterFlushTableProcedureManager
java.lang.Object
org.apache.hadoop.hbase.procedure.ProcedureManager
org.apache.hadoop.hbase.procedure.MasterProcedureManager
org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager
- All Implemented Interfaces:
Stoppable
@LimitedPrivate("Configuration")
public class MasterFlushTableProcedureManager
extends MasterProcedureManager
-
Field Summary
Modifier and TypeFieldDescriptionprivate ProcedureCoordinator
private static final int
private static final String
static final String
static final boolean
static final String
private static final int
private static final String
private static final int
private static final String
private static final org.slf4j.Logger
private MasterServices
private boolean
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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 clusterReturn 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.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc) Check if the procedure is finished successfullyboolean
Returns True ifStoppable.stop(String)
has been closed.void
Stop this service.Methods inherited from class org.apache.hadoop.hbase.procedure.MasterProcedureManager
execProcedureWithRet
Methods inherited from class org.apache.hadoop.hbase.procedure.ProcedureManager
equals, hashCode
-
Field Details
-
FLUSH_TABLE_PROCEDURE_SIGNATURE
- See Also:
-
FLUSH_PROCEDURE_ENABLED
- See Also:
-
FLUSH_PROCEDURE_ENABLED_DEFAULT
- See Also:
-
FLUSH_TIMEOUT_MILLIS_KEY
- See Also:
-
FLUSH_TIMEOUT_MILLIS_DEFAULT
- See Also:
-
FLUSH_WAKE_MILLIS_KEY
- See Also:
-
FLUSH_WAKE_MILLIS_DEFAULT
- See Also:
-
FLUSH_PROC_POOL_THREADS_KEY
- See Also:
-
FLUSH_PROC_POOL_THREADS_DEFAULT
- See Also:
-
LOG
-
master
-
coordinator
-
procMap
-
stopped
-
-
Constructor Details
-
MasterFlushTableProcedureManager
public MasterFlushTableProcedureManager()
-
-
Method Details
-
stop
Description copied from interface:Stoppable
Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.- Parameters:
why
- Why we're stopping.
-
isStopped
Description copied from interface:Stoppable
Returns True ifStoppable.stop(String)
has been closed. -
initialize
public void initialize(MasterServices master, MetricsMaster metricsMaster) throws org.apache.zookeeper.KeeperException, IOException, UnsupportedOperationException Description copied from class:MasterProcedureManager
Initialize a globally barriered procedure for master.- Specified by:
initialize
in classMasterProcedureManager
- Parameters:
master
- Master service interface- Throws:
org.apache.zookeeper.KeeperException
IOException
UnsupportedOperationException
-
getProcedureSignature
Description copied from class:ProcedureManager
Return the unique signature of the procedure. This signature uniquely identifies the procedure. By default, this signature is the string used in the procedure controller (i.e., the root ZK node name for the procedure)- Specified by:
getProcedureSignature
in classProcedureManager
-
execProcedure
public void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc) throws IOException Description copied from class:MasterProcedureManager
Execute a distributed procedure on cluster- Overrides:
execProcedure
in classMasterProcedureManager
- Parameters:
desc
- Procedure description- Throws:
IOException
-
checkPermissions
public void checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user) throws IOException Description copied from class:MasterProcedureManager
Check for required permissions before executing the procedure.- Specified by:
checkPermissions
in classMasterProcedureManager
- Throws:
IOException
- if permissions requirements are not met.
-
isProcedureDone
public boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc) throws IOException Description copied from class:MasterProcedureManager
Check if the procedure is finished successfully- Specified by:
isProcedureDone
in classMasterProcedureManager
- Parameters:
desc
- Procedure description- Returns:
- true if the specified procedure is finished successfully
- Throws:
IOException
-