Package | Description |
---|---|
org.apache.bookkeeper.client |
Modifier and Type | Method and Description |
---|---|
static BKException |
BKException.create(int code)
Create an exception from an error code
|
Modifier and Type | Method and Description |
---|---|
long |
LedgerHandle.addEntry(byte[] data)
Add entry synchronously to an open ledger.
|
long |
LedgerHandle.addEntry(byte[] data,
int offset,
int length)
Add entry synchronously to an open ledger.
|
long |
LedgerHandleAdv.addEntry(long entryId,
byte[] data)
Add entry synchronously to an open ledger.
|
long |
LedgerHandle.addEntry(long entryId,
byte[] data)
Add entry synchronously to an open ledger.
|
long |
LedgerHandleAdv.addEntry(long entryId,
byte[] data,
int offset,
int length)
Add entry synchronously to an open ledger.
|
long |
LedgerHandle.addEntry(long entryId,
byte[] data,
int offset,
int length)
Add entry synchronously to an open ledger.
|
void |
LedgerHandleAdv.asyncAddEntry(long entryId,
byte[] data,
AsyncCallback.AddCallback cb,
Object ctx)
Add entry asynchronously to an open ledger.
|
void |
LedgerHandle.asyncAddEntry(long entryId,
byte[] data,
AsyncCallback.AddCallback cb,
Object ctx)
Add entry asynchronously to an open ledger.
|
void |
LedgerHandle.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.
|
void |
LedgerHandle.close()
Close this ledger synchronously.
|
void |
BookKeeperAdmin.close()
Gracefully release resources that this client uses.
|
void |
BookKeeper.close()
Shuts down client.
|
LedgerHandle |
BookKeeper.createLedger(BookKeeper.DigestType digestType,
byte[] passwd)
Creates a new ledger.
|
LedgerHandle |
BookKeeper.createLedger(int ensSize,
int qSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedger(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedgerAdv(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
void |
BookKeeper.deleteLedger(long lId)
Synchronous call to delete a ledger.
|
Collection<org.apache.bookkeeper.net.BookieSocketAddress> |
BookKeeperAdmin.getAvailableBookies()
Get a list of the available bookies.
|
boolean |
BookKeeper.isClosed(long lId)
Check whether the ledger with identifier lId
has been closed.
|
void |
BookKeeperAdmin.notifyBookiesChanged(BookiesListener listener)
Notify when the available list of bookies changes.
|
void |
BookKeeperAdmin.notifyReadOnlyBookiesChanged(BookiesListener listener)
Notify when the available list of read only bookies changes.
|
LedgerHandle |
BookKeeperAdmin.openLedger(long lId)
Open a ledger as an administrator.
|
LedgerHandle |
BookKeeper.openLedger(long lId,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous open ledger call
|
LedgerHandle |
BookKeeperAdmin.openLedgerNoRecovery(long lId)
Open a ledger as an administrator without recovering the ledger.
|
LedgerHandle |
BookKeeper.openLedgerNoRecovery(long lId,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous, unsafe open ledger call
|
Enumeration<LedgerEntry> |
LedgerHandle.readEntries(long firstEntry,
long lastEntry)
Read a sequence of entries synchronously.
|
Iterable<LedgerEntry> |
BookKeeperAdmin.readEntries(long ledgerId,
long firstEntry,
long lastEntry)
Read entries from a ledger synchronously.
|
long |
LedgerHandle.readLastConfirmed()
Obtains synchronously the last confirmed write from a quorum of bookies.
|
void |
BookKeeperAdmin.recoverBookieData(org.apache.bookkeeper.net.BookieSocketAddress bookieSrc,
org.apache.bookkeeper.net.BookieSocketAddress bookieDest)
Synchronous method to rebuild and recover the ledger fragments data that
was stored on the source bookie.
|
void |
BookKeeperAdmin.replicateLedgerFragment(LedgerHandle lh,
LedgerFragment ledgerFragment,
org.apache.bookkeeper.net.BookieSocketAddress targetBookieAddress)
Replicate the Ledger fragment to target Bookie passed.
|
long |
LedgerHandle.tryReadLastConfirmed()
Obtains synchronously the last confirmed write from a quorum of bookies.
|
void |
UpdateLedgerOp.updateBookieIdInLedgers(org.apache.bookkeeper.net.BookieSocketAddress oldBookieId,
org.apache.bookkeeper.net.BookieSocketAddress newBookieId,
int rate,
int limit,
org.apache.bookkeeper.bookie.BookieShell.UpdateLedgerNotifier progressable)
Update the bookie id present in the ledger metadata.
|
Copyright © 2011-2016 The Apache Software Foundation. All Rights Reserved.