| 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.
|
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.
|
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.
|
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.
|
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.
|
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.