org.apache.bookkeeper.streaming
Class LedgerOutputStream
java.lang.Object
java.io.OutputStream
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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 handlesize
- the size of the buffer
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