Package org.apache.bookkeeper.shims.zk
Class ZooKeeperServerShimImpl
java.lang.Object
org.apache.bookkeeper.shims.zk.ZooKeeperServerShimImpl
- All Implemented Interfaces:
ZooKeeperServerShim
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) org.apache.zookeeper.server.NIOServerCnxnFactory(package private) org.apache.zookeeper.server.ZooKeeperServer -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidinitialize(File snapDir, File logDir, int zkPort, int maxCC) Initialize zookeeper server.voidstart()Start the zookeeper server.voidstop()Stop the zookeeper server.
-
Field Details
-
zks
org.apache.zookeeper.server.ZooKeeperServer zks -
serverFactory
org.apache.zookeeper.server.NIOServerCnxnFactory serverFactory
-
-
Constructor Details
-
ZooKeeperServerShimImpl
ZooKeeperServerShimImpl()
-
-
Method Details
-
initialize
Description copied from interface:ZooKeeperServerShimInitialize zookeeper server.- Specified by:
initializein interfaceZooKeeperServerShim- Parameters:
snapDir- Snapshot Dir.logDir- Log Dir.zkPort- ZooKeeper Port.maxCC- Max Concurrency for Client.- Throws:
IOException- when failed to initialize zookeeper server.
-
start
Description copied from interface:ZooKeeperServerShimStart the zookeeper server.- Specified by:
startin interfaceZooKeeperServerShim- Throws:
IOException- when failed to start zookeeper server.
-
stop
public void stop()Description copied from interface:ZooKeeperServerShimStop the zookeeper server.- Specified by:
stopin interfaceZooKeeperServerShim
-