Package org.apache.bookkeeper.util

Class LocalBookKeeper

java.lang.Object

org.apache.bookkeeper.util.LocalBookKeeper

All Implemented Interfaces:

AutoCloseable

public class LocalBookKeeper
extends Object
implements AutoCloseable

Local Bookkeeper.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ByteBufAllocatorWithOomHandler	allocator
static final int	CONNECTION_TIMEOUT
(package private) List<File>	dirsToCleanUp
(package private) String	dirSuffix
(package private) List<org.apache.bookkeeper.util.LocalBookKeeper.LocalBookie>	localBookies
(package private) File	localBookiesConfigDir
protected static final org.slf4j.Logger	LOG
(package private) int	numberOfBookies
(package private) boolean	stopOnExit
(package private) String	zkHost
(package private) int	zkPort
(package private) ZooKeeperServerShim	zks

Constructor Summary

Constructors

Constructor	Description
LocalBookKeeper(int numberOfBookies, ServerConfiguration baseConf, String localBookiesConfigDirName, boolean stopOnExit, String dirSuffix, String zkHost, int zkPort)

Method Summary

Modifier and Type	Method	Description
void	addBookie()
void	close()
static LocalBookKeeper	getLocalBookies(String zkHost, int zkPort, int numBookies, boolean shouldStartZK, ServerConfiguration conf)
static void	main(String[] args)
void	removeBookie()
static ZooKeeperServerShim	runZookeeper(int maxCC, int zookeeperPort)
static ZooKeeperServerShim	runZookeeper(int maxCC, int zookeeperPort, File zkDir)
void	shutdownBookies()
void	start()
static boolean	waitForServerUp(String hp, long timeout)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final org.slf4j.Logger LOG

CONNECTION_TIMEOUT

public static final int CONNECTION_TIMEOUT

See Also:

• Constant Field Values

numberOfBookies

int numberOfBookies

localBookies

List<org.apache.bookkeeper.util.LocalBookKeeper.LocalBookie> localBookies

zks

ZooKeeperServerShim zks

zkHost

String zkHost

zkPort

int zkPort

dirSuffix

String dirSuffix

allocator

ByteBufAllocatorWithOomHandler allocator

localBookiesConfigDir

File localBookiesConfigDir

dirsToCleanUp

List<File> dirsToCleanUp

stopOnExit

boolean stopOnExit

Constructor Details

LocalBookKeeper

public LocalBookKeeper(int numberOfBookies,
 ServerConfiguration baseConf,
 String localBookiesConfigDirName,
 boolean stopOnExit,
 String dirSuffix,
 String zkHost,
 int zkPort)

Method Details

runZookeeper

public static ZooKeeperServerShim runZookeeper(int maxCC,
 int zookeeperPort)
                                        throws IOException

Parameters:

maxCC - Max Concurrency of Client

zookeeperPort - ZooKeeper Server Port

Throws:

IOException

runZookeeper

public static ZooKeeperServerShim runZookeeper(int maxCC,
 int zookeeperPort,
 File zkDir)
                                        throws IOException

Throws:

IOException

getLocalBookies

public static LocalBookKeeper getLocalBookies(String zkHost,
 int zkPort,
 int numBookies,
 boolean shouldStartZK,
 ServerConfiguration conf)
                                       throws Exception

Throws:

Exception

main

public static void main(String[] args)

waitForServerUp

public static boolean waitForServerUp(String hp,
 long timeout)

start

public void start()
           throws Exception

Throws:

Exception

addBookie

public void addBookie()
               throws Exception

Throws:

Exception

removeBookie

public void removeBookie()
                  throws Exception

Throws:

Exception

shutdownBookies

public void shutdownBookies()
                     throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception