Package org.apache.bookkeeper.shims.zk

Class ZooKeeperServerShimImpl

java.lang.Object

org.apache.bookkeeper.shims.zk.ZooKeeperServerShimImpl

All Implemented Interfaces:

ZooKeeperServerShim

class ZooKeeperServerShimImpl
extends java.lang.Object
implements ZooKeeperServerShim

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.apache.zookeeper.server.NIOServerCnxnFactory	serverFactory
(package private) org.apache.zookeeper.server.ZooKeeperServer	zks

Constructor Summary

Constructors

Constructor	Description
ZooKeeperServerShimImpl()

Method Summary

Modifier and Type	Method	Description
void	initialize(java.io.File snapDir, java.io.File logDir, int zkPort, int maxCC)	Initialize zookeeper server.
void	start()	Start the zookeeper server.
void	stop()	Stop the zookeeper server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

zks

org.apache.zookeeper.server.ZooKeeperServer zks

serverFactory

org.apache.zookeeper.server.NIOServerCnxnFactory serverFactory

Constructor Detail

ZooKeeperServerShimImpl

ZooKeeperServerShimImpl()

Method Detail

initialize

public void initialize(java.io.File snapDir,
                       java.io.File logDir,
                       int zkPort,
                       int maxCC)
                throws java.io.IOException

Description copied from interface: ZooKeeperServerShim

Initialize zookeeper server.

Specified by:

initialize in interface ZooKeeperServerShim

Parameters:

snapDir - Snapshot Dir.

logDir - Log Dir.

zkPort - ZooKeeper Port.

maxCC - Max Concurrency for Client.

Throws:

java.io.IOException - when failed to initialize zookeeper server.

start

public void start()
           throws java.io.IOException

Description copied from interface: ZooKeeperServerShim

Start the zookeeper server.

Specified by:

start in interface ZooKeeperServerShim

Throws:

java.io.IOException - when failed to start zookeeper server.

stop

public void stop()

Description copied from interface: ZooKeeperServerShim

Stop the zookeeper server.

Specified by:

stop in interface ZooKeeperServerShim