@InterfaceAudience.LimitedPrivate(value="Configuration") public class ZkCoordinatedStateManager extends BaseCoordinatedStateManager
CoordinatedStateManager.| Modifier and Type | Field and Description |
|---|---|
protected CloseRegionCoordination |
closeRegionCoordination |
private static org.apache.commons.logging.Log |
LOG |
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.
|
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, stopprivate static final org.apache.commons.logging.Log LOG
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)
CoordinatedStateManagerinitialize in interface CoordinatedStateManagerinitialize in class BaseCoordinatedStateManagerserver - server instance to run within.public Server getServer()
getServer in interface CoordinatedStateManagergetServer in class BaseCoordinatedStateManagerpublic TableStateManager getTableStateManager() throws InterruptedException, CoordinatedStateException
CoordinatedStateManagergetTableStateManager in interface CoordinatedStateManagergetTableStateManager in class BaseCoordinatedStateManagerInterruptedException - if operation is interruptedCoordinatedStateException - if error happens in underlying coordination mechanismpublic SplitLogWorkerCoordination getSplitLogWorkerCoordination()
BaseCoordinatedStateManagergetSplitLogWorkerCoordination in class BaseCoordinatedStateManagerpublic SplitLogManagerCoordination getSplitLogManagerCoordination()
BaseCoordinatedStateManagergetSplitLogManagerCoordination in class BaseCoordinatedStateManagerpublic SplitTransactionCoordination getSplitTransactionCoordination()
BaseCoordinatedStateManagergetSplitTransactionCoordination in class BaseCoordinatedStateManagerpublic CloseRegionCoordination getCloseRegionCoordination()
BaseCoordinatedStateManagergetCloseRegionCoordination in class BaseCoordinatedStateManagerpublic OpenRegionCoordination getOpenRegionCoordination()
BaseCoordinatedStateManagergetOpenRegionCoordination in class BaseCoordinatedStateManagerpublic RegionMergeCoordination getRegionMergeCoordination()
BaseCoordinatedStateManagergetRegionMergeCoordination in class BaseCoordinatedStateManagerCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.