org.apache.bookkeeper.streaming
Class LedgerOutputStream

java.lang.Object
  extended by java.io.OutputStream
      extended by org.apache.bookkeeper.streaming.LedgerOutputStream
All Implemented Interfaces:
Closeable, Flushable

public class LedgerOutputStream
extends OutputStream

this class provides a streaming api to get an output stream from a ledger handle and write to it as a stream of bytes. This is built on top of ledgerhandle api and uses a buffer to cache the data written to it and writes out the entry to the ledger.


Constructor Summary
LedgerOutputStream(LedgerHandle lh)
          construct a outputstream from a ledger handle
LedgerOutputStream(LedgerHandle lh, int size)
          construct a outputstream from a ledger handle
 
Method Summary
 void close()
           
 void flush()
           
 void write(byte[] b)
           
 void write(byte[] b, int off, int len)
           
 void write(int b)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LedgerOutputStream

public LedgerOutputStream(LedgerHandle lh)
construct a outputstream from a ledger handle

Parameters:
lh - ledger handle

LedgerOutputStream

public LedgerOutputStream(LedgerHandle lh,
                          int size)
construct a outputstream from a ledger handle

Parameters:
lh - the ledger handle
size - the size of the buffer
Method Detail

close

public void close()
Specified by:
close in interface Closeable
Overrides:
close in class OutputStream

flush

public void flush()
Specified by:
flush in interface Flushable
Overrides:
flush in class OutputStream

write

public void write(byte[] b)
Overrides:
write in class OutputStream

write

public void write(byte[] b,
                  int off,
                  int len)
Overrides:
write in class OutputStream

write

public void write(int b)
           throws IOException
Specified by:
write in class OutputStream
Throws:
IOException