@InterfaceAudience.LimitedPrivate(value="Configuration") public class ZkCoordinatedStateManager extends Object implements CoordinatedStateManager
CoordinatedStateManager.| Modifier and Type | Field and Description |
|---|---|
protected SplitLogManagerCoordination |
splitLogManagerCoordination |
protected SplitLogWorkerCoordination |
splitLogWorkerCoordination |
protected ZKWatcher |
watcher |
| Constructor and Description |
|---|
ZkCoordinatedStateManager(Server server) |
| Modifier and Type | Method and Description |
|---|---|
SplitLogManagerCoordination |
getSplitLogManagerCoordination()
Method to retrieve coordination for split log manager
|
SplitLogWorkerCoordination |
getSplitLogWorkerCoordination()
Method to retrieve coordination for split log worker
|
protected SplitLogWorkerCoordination splitLogWorkerCoordination
protected SplitLogManagerCoordination splitLogManagerCoordination
public ZkCoordinatedStateManager(Server server)
public SplitLogWorkerCoordination getSplitLogWorkerCoordination()
CoordinatedStateManagergetSplitLogWorkerCoordination in interface CoordinatedStateManagerpublic SplitLogManagerCoordination getSplitLogManagerCoordination()
CoordinatedStateManagergetSplitLogManagerCoordination in interface CoordinatedStateManagerCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.