@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()
CoordinatedStateManager
getSplitLogWorkerCoordination
in interface CoordinatedStateManager
public SplitLogManagerCoordination getSplitLogManagerCoordination()
CoordinatedStateManager
getSplitLogManagerCoordination
in interface CoordinatedStateManager
public ProcedureCoordinatorRpcs getProcedureCoordinatorRpcs(String procType, String coordNode) throws IOException
CoordinatedStateManager
ProcedureCoordinatorRpcs
getProcedureCoordinatorRpcs
in interface CoordinatedStateManager
IOException
public ProcedureMemberRpcs getProcedureMemberRpcs(String procType) throws org.apache.zookeeper.KeeperException
CoordinatedStateManager
ProcedureMemberRpcs
getProcedureMemberRpcs
in interface CoordinatedStateManager
org.apache.zookeeper.KeeperException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.