@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 |
|---|---|
ProcedureCoordinatorRpcs |
getProcedureCoordinatorRpcs(String procType,
String coordNode)
Method to retrieve
ProcedureCoordinatorRpcs |
ProcedureMemberRpcs |
getProcedureMemberRpcs(String procType)
Method to retrieve
ProcedureMemberRpcs |
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 CoordinatedStateManagerpublic ProcedureCoordinatorRpcs getProcedureCoordinatorRpcs(String procType, String coordNode) throws IOException
CoordinatedStateManagerProcedureCoordinatorRpcsgetProcedureCoordinatorRpcs in interface CoordinatedStateManagerIOExceptionpublic ProcedureMemberRpcs getProcedureMemberRpcs(String procType) throws org.apache.zookeeper.KeeperException
CoordinatedStateManagerProcedureMemberRpcsgetProcedureMemberRpcs in interface CoordinatedStateManagerorg.apache.zookeeper.KeeperExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.