Uses of Class
org.apache.hadoop.hbase.procedure.Procedure
Packages that use Procedure
-
Uses of Procedure in org.apache.hadoop.hbase.procedure
Fields in org.apache.hadoop.hbase.procedure with type parameters of type ProcedureModifier and TypeFieldDescriptionprivate final ConcurrentMap<String,Procedure> ProcedureCoordinator.proceduresMethods in org.apache.hadoop.hbase.procedure that return ProcedureModifier and TypeMethodDescription(package private) ProcedureProcedureCoordinator.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.Methods in org.apache.hadoop.hbase.procedure with parameters of type ProcedureModifier and TypeMethodDescriptionvoidProcedureCoordinatorRpcs.resetMembers(Procedure procName) Notify Members to reset the distributed state for procedurefinal voidZKProcedureCoordinator.resetMembers(Procedure proc) Delete znodes that are no longer in use.voidProcedureCoordinatorRpcs.sendAbortToMembers(Procedure procName, ForeignException cause) Notify the members that the coordinator has aborted the procedure and that it should release barrier resources.final voidZKProcedureCoordinator.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.voidProcedureCoordinatorRpcs.sendGlobalBarrierAcquire(Procedure procName, byte[] info, List<String> members) Notify the members to acquire barrier for the procedurefinal voidZKProcedureCoordinator.sendGlobalBarrierAcquire(Procedure proc, byte[] info, List<String> nodeNames) The "acquire" phase.voidProcedureCoordinatorRpcs.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.voidZKProcedureCoordinator.sendGlobalBarrierReached(Procedure proc, List<String> nodeNames) (package private) booleanProcedureCoordinator.submitProcedure(Procedure proc) Submit an procedure to kick off its dependent subprocedures. -
Uses of Procedure in org.apache.hadoop.hbase.procedure.flush
Fields in org.apache.hadoop.hbase.procedure.flush with type parameters of type Procedure