Uses of Class
org.apache.hadoop.hbase.procedure.Procedure
-
Uses of Procedure in org.apache.hadoop.hbase.procedure
Modifier and TypeFieldDescriptionprivate final ConcurrentMap<String,
Procedure> ProcedureCoordinator.procedures
Modifier and TypeMethodDescription(package private) Procedure
ProcedureCoordinator.createProcedure
(ForeignExceptionDispatcher fed, String procName, byte[] procArgs, List<String> expectedMembers) Exposed for hooking with unit tests.ProcedureCoordinator.getProcedure
(String name) Returns the procedure.ProcedureCoordinator.startProcedure
(ForeignExceptionDispatcher fed, String procName, byte[] procArgs, List<String> expectedMembers) Kick off the named procedure Currently only one procedure with the same type and name is allowed to run at a time.Modifier and TypeMethodDescriptionvoid
ProcedureCoordinatorRpcs.resetMembers
(Procedure procName) Notify Members to reset the distributed state for procedurefinal void
ZKProcedureCoordinator.resetMembers
(Procedure proc) Delete znodes that are no longer in use.void
ProcedureCoordinatorRpcs.sendAbortToMembers
(Procedure procName, ForeignException cause) Notify the members that the coordinator has aborted the procedure and that it should release barrier resources.final void
ZKProcedureCoordinator.sendAbortToMembers
(Procedure proc, ForeignException ee) This is the abort message being sent by the coordinator to member TODO this code isn't actually used but can be used to issue a cancellation from the coordinator.void
ProcedureCoordinatorRpcs.sendGlobalBarrierAcquire
(Procedure procName, byte[] info, List<String> members) Notify the members to acquire barrier for the procedurefinal void
ZKProcedureCoordinator.sendGlobalBarrierAcquire
(Procedure proc, byte[] info, List<String> nodeNames) The "acquire" phase.void
ProcedureCoordinatorRpcs.sendGlobalBarrierReached
(Procedure procName, List<String> members) Notify members that all members have acquired their parts of the barrier and that they can now execute under the global barrier.void
ZKProcedureCoordinator.sendGlobalBarrierReached
(Procedure proc, List<String> nodeNames) (package private) boolean
ProcedureCoordinator.submitProcedure
(Procedure proc) Submit an procedure to kick off its dependent subprocedures. -
Uses of Procedure in org.apache.hadoop.hbase.procedure.flush