@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()
CoordinatedStateManager
getSplitLogWorkerCoordination
in interface CoordinatedStateManager
public SplitLogManagerCoordination getSplitLogManagerCoordination()
CoordinatedStateManager
getSplitLogManagerCoordination
in interface CoordinatedStateManager
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.