| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.procedure | |
| org.apache.hadoop.hbase.procedure.flush | 
| Modifier and Type | Field and Description | 
|---|---|
| private ConcurrentMap<String,Procedure> | ProcedureCoordinator. procedures | 
| Modifier and Type | Method and Description | 
|---|---|
| (package private) Procedure | ProcedureCoordinator. createProcedure(ForeignExceptionDispatcher fed,
               String procName,
               byte[] procArgs,
               List<String> expectedMembers)Exposed for hooking with unit tests. | 
| Procedure | ProcedureCoordinator. getProcedure(String name)Returns the procedure. | 
| 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 Type | Method and Description | 
|---|---|
| void | ZKProcedureCoordinator. resetMembers(Procedure proc)Delete znodes that are no longer in use. | 
| void | ProcedureCoordinatorRpcs. resetMembers(Procedure procName)Notify Members to reset the distributed state for procedure | 
| 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. sendAbortToMembers(Procedure procName,
                  ForeignException cause)Notify the members that the coordinator has aborted the procedure and that it should release
 barrier resources. | 
| void | ZKProcedureCoordinator. sendGlobalBarrierAcquire(Procedure proc,
                        byte[] info,
                        List<String> nodeNames)The "acquire" phase. | 
| void | ProcedureCoordinatorRpcs. sendGlobalBarrierAcquire(Procedure procName,
                        byte[] info,
                        List<String> members)Notify the members to acquire barrier for the procedure | 
| void | ZKProcedureCoordinator. sendGlobalBarrierReached(Procedure proc,
                        List<String> nodeNames) | 
| 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. | 
| (package private) boolean | ProcedureCoordinator. submitProcedure(Procedure proc)Submit an procedure to kick off its dependent subprocedures. | 
| Modifier and Type | Field and Description | 
|---|---|
| private Map<TableName,Procedure> | MasterFlushTableProcedureManager. procMap | 
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.