org.apache.bookkeeper.client

Class LedgerHandleAdv

java.lang.Object

org.apache.bookkeeper.client.LedgerHandle

org.apache.bookkeeper.client.LedgerHandleAdv

All Implemented Interfaces:

AutoCloseable

public class LedgerHandleAdv
extends LedgerHandle

Ledger Advanced handle extends LedgerHandle to provide API to add entries with user supplied entryIds. Through this interface Ledger Length may not be accurate wile the ledger being written.

Field Summary

Fields inherited from class org.apache.bookkeeper.client.LedgerHandle

INVALID_ENTRY_ID

Method Summary

Methods

Modifier and Type	Method and Description
long	addEntry(long entryId, byte[] data) Add entry synchronously to an open ledger.
long	addEntry(long entryId, byte[] data, int offset, int length) Add entry synchronously to an open ledger.
void	asyncAddEntry(long entryId, byte[] data, AsyncCallback.AddCallback cb, Object ctx) Add entry asynchronously to an open ledger.
void	asyncAddEntry(long entryId, byte[] data, int offset, int length, AsyncCallback.AddCallback cb, Object ctx) Add entry asynchronously to an open ledger, using an offset and range.

Methods inherited from class org.apache.bookkeeper.client.LedgerHandle

addEntry, addEntry, asyncAddEntry, asyncAddEntry, asyncClose, asyncReadEntries, asyncReadLastConfirmed, asyncTryReadLastConfirmed, close, getId, getLastAddConfirmed, getLastAddPushed, getLedgerKey, getLength, isClosed, readEntries, readLastConfirmed, tryReadLastConfirmed

Methods inherited from class java.lang.Object

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

Method Detail

addEntry

public long addEntry(long entryId,
            byte[] data)
              throws InterruptedException,
                     BKException

Add entry synchronously to an open ledger.

Overrides:

addEntry in class LedgerHandle

Parameters:

entryId - entryId of the entry to add

data - array of bytes to be written to the ledger

Returns:

entryId that is just created.

Throws:

InterruptedException

BKException

addEntry

public long addEntry(long entryId,
            byte[] data,
            int offset,
            int length)
              throws InterruptedException,
                     BKException

Add entry synchronously to an open ledger.

Overrides:

addEntry in class LedgerHandle

Parameters:

entryId - entryId of the entry to add

data - array of bytes to be written to the ledger

offset - offset from which to take bytes from data

length - number of bytes to take from data

Returns:

The entryId of newly inserted entry.

Throws:

InterruptedException

BKException

asyncAddEntry

public void asyncAddEntry(long entryId,
                 byte[] data,
                 AsyncCallback.AddCallback cb,
                 Object ctx)
                   throws BKException

Add entry asynchronously to an open ledger.

Overrides:

asyncAddEntry in class LedgerHandle

Parameters:

entryId - entryId of the entry to add

data - array of bytes to be written

cb - object implementing callbackinterface

ctx - some control object

Throws:

BKException

asyncAddEntry

public void asyncAddEntry(long entryId,
                 byte[] data,
                 int offset,
                 int length,
                 AsyncCallback.AddCallback cb,
                 Object ctx)

Add entry asynchronously to an open ledger, using an offset and range.

Overrides:

asyncAddEntry in class LedgerHandle

Parameters:

entryId - entryId of the entry to add

data - array of bytes to be written

offset - offset from which to take bytes from data

length - number of bytes to take from data

cb - object implementing callbackinterface

ctx - some control object

Throws:

ArrayIndexOutOfBoundsException - if offset or length is negative or offset and length sum to a value higher than the length of data.