@InterfaceAudience.LimitedPrivate(value="Configuration") public class ZkCoordinatedStateManager extends BaseCoordinatedStateManager
CoordinatedStateManager
.Modifier and Type | Field and Description |
---|---|
protected CloseRegionCoordination |
closeRegionCoordination |
protected OpenRegionCoordination |
openRegionCoordination |
protected RegionMergeCoordination |
regionMergeCoordination |
protected Server |
server |
protected SplitLogManagerCoordination |
splitLogManagerCoordination |
protected SplitLogWorkerCoordination |
splitLogWorkerCoordination |
protected SplitTransactionCoordination |
splitTransactionCoordination |
protected ZooKeeperWatcher |
watcher |
Constructor and Description |
---|
ZkCoordinatedStateManager() |
Modifier and Type | Method and Description |
---|---|
CloseRegionCoordination |
getCloseRegionCoordination()
Method to retrieve coordination for closing region operations.
|
OpenRegionCoordination |
getOpenRegionCoordination()
Method to retrieve coordination for opening region operations.
|
ProcedureCoordinatorRpcs |
getProcedureCoordinatorRpcs(java.lang.String procType,
java.lang.String coordNode)
Method to retrieve
ProcedureCoordinatorRpcs |
ProcedureMemberRpcs |
getProcedureMemberRpcs(java.lang.String procType)
Method to retrieve
org.apache.hadoop.hbase.procedure.ProcedureMemberRpc |
RegionMergeCoordination |
getRegionMergeCoordination()
Method to retrieve coordination for region merge transaction
|
Server |
getServer() |
SplitLogManagerCoordination |
getSplitLogManagerCoordination()
Method to retrieve coordination for split log manager
|
SplitLogWorkerCoordination |
getSplitLogWorkerCoordination()
Method to retrieve coordination for split log worker
|
SplitTransactionCoordination |
getSplitTransactionCoordination()
Method to retrieve coordination for split transaction.
|
TableStateManager |
getTableStateManager()
Returns implementation of TableStateManager.
|
void |
initialize(Server server)
Initialize coordinated state management service.
|
start, stop
protected Server server
protected ZooKeeperWatcher watcher
protected SplitTransactionCoordination splitTransactionCoordination
protected CloseRegionCoordination closeRegionCoordination
protected SplitLogWorkerCoordination splitLogWorkerCoordination
protected SplitLogManagerCoordination splitLogManagerCoordination
protected OpenRegionCoordination openRegionCoordination
protected RegionMergeCoordination regionMergeCoordination
public void initialize(Server server)
CoordinatedStateManager
initialize
in interface CoordinatedStateManager
initialize
in class BaseCoordinatedStateManager
server
- server instance to run within.public Server getServer()
getServer
in interface CoordinatedStateManager
getServer
in class BaseCoordinatedStateManager
public TableStateManager getTableStateManager() throws java.lang.InterruptedException, CoordinatedStateException
CoordinatedStateManager
getTableStateManager
in interface CoordinatedStateManager
getTableStateManager
in class BaseCoordinatedStateManager
java.lang.InterruptedException
- if operation is interruptedCoordinatedStateException
- if error happens in underlying coordination mechanismpublic SplitLogWorkerCoordination getSplitLogWorkerCoordination()
BaseCoordinatedStateManager
getSplitLogWorkerCoordination
in class BaseCoordinatedStateManager
public SplitLogManagerCoordination getSplitLogManagerCoordination()
BaseCoordinatedStateManager
getSplitLogManagerCoordination
in class BaseCoordinatedStateManager
public SplitTransactionCoordination getSplitTransactionCoordination()
BaseCoordinatedStateManager
getSplitTransactionCoordination
in class BaseCoordinatedStateManager
public CloseRegionCoordination getCloseRegionCoordination()
BaseCoordinatedStateManager
getCloseRegionCoordination
in class BaseCoordinatedStateManager
public OpenRegionCoordination getOpenRegionCoordination()
BaseCoordinatedStateManager
getOpenRegionCoordination
in class BaseCoordinatedStateManager
public RegionMergeCoordination getRegionMergeCoordination()
BaseCoordinatedStateManager
getRegionMergeCoordination
in class BaseCoordinatedStateManager
public ProcedureCoordinatorRpcs getProcedureCoordinatorRpcs(java.lang.String procType, java.lang.String coordNode) throws java.io.IOException
BaseCoordinatedStateManager
ProcedureCoordinatorRpcs
getProcedureCoordinatorRpcs
in class BaseCoordinatedStateManager
java.io.IOException
public ProcedureMemberRpcs getProcedureMemberRpcs(java.lang.String procType) throws java.io.IOException
BaseCoordinatedStateManager
org.apache.hadoop.hbase.procedure.ProcedureMemberRpc
getProcedureMemberRpcs
in class BaseCoordinatedStateManager
java.io.IOException