| 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 |
ProcedureCoordinatorRpcs.resetMembers(Procedure procName)
Notify Members to reset the distributed state for procedure
|
void |
ZKProcedureCoordinatorRpcs.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.
|
void |
ZKProcedureCoordinatorRpcs.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 procedure
|
void |
ZKProcedureCoordinatorRpcs.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 |
ZKProcedureCoordinatorRpcs.sendGlobalBarrierReached(Procedure proc,
List<String> nodeNames) |
(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–2019 The Apache Software Foundation. All rights reserved.