org.apache.bookkeeper.bookie
Class Bookie

java.lang.Object
  extended by java.lang.Thread
      extended by org.apache.bookkeeper.bookie.Bookie
All Implemented Interfaces:
Runnable

public class Bookie
extends Thread

Implements a bookie.


Nested Class Summary
static class Bookie.NoEntryException
           
static class Bookie.NoLedgerException
           
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
static long preAllocSize
           
static ByteBuffer zeros
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
Bookie(File journalDirectory, File[] ledgerDirectories)
           
 
Method Summary
 void addEntry(ByteBuffer entry, WriteCallback cb, Object ctx, byte[] masterKey)
           
static void main(String[] args)
           
 ByteBuffer readEntry(long ledgerId, long entryId)
           
 void run()
           
 void shutdown()
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

preAllocSize

public static final long preAllocSize
See Also:
Constant Field Values

zeros

public static final ByteBuffer zeros
Constructor Detail

Bookie

public Bookie(File journalDirectory,
              File[] ledgerDirectories)
Method Detail

run

public void run()
Specified by:
run in interface Runnable
Overrides:
run in class Thread

shutdown

public void shutdown()
              throws InterruptedException
Throws:
InterruptedException

addEntry

public void addEntry(ByteBuffer entry,
                     WriteCallback cb,
                     Object ctx,
                     byte[] masterKey)
              throws IOException,
                     BookieException
Throws:
IOException
BookieException

readEntry

public ByteBuffer readEntry(long ledgerId,
                            long entryId)
                     throws IOException
Throws:
IOException

main

public static void main(String[] args)
                 throws IOException,
                        InterruptedException,
                        BookieException
Parameters:
args -
Throws:
IOException
InterruptedException
BookieException