Package | Description |
---|---|
org.apache.bookkeeper.client |
Modifier and Type | Class and Description |
---|---|
static class |
BKException.BKBookieException |
static class |
BKException.BKBookieHandleNotAvailableException |
static class |
BKException.BKDigestMatchException |
static class |
BKException.BKDigestNotInitializedException |
static class |
BKException.BKIllegalOpException |
static class |
BKException.BKIncorrectParameterException |
static class |
BKException.BKInterruptedException |
static class |
BKException.BKLedgerClosedException |
static class |
BKException.BKLedgerFencedException |
static class |
BKException.BKLedgerRecoveryException |
static class |
BKException.BKNoSuchEntryException |
static class |
BKException.BKNoSuchLedgerExistsException |
static class |
BKException.BKNotEnoughBookiesException |
static class |
BKException.BKProtocolVersionException |
static class |
BKException.BKQuorumException |
static class |
BKException.BKReadException |
static class |
BKException.BKWriteException |
static class |
BKException.ZKException |
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 |
---|---|
void |
LedgerHandle.addEntry(byte[] data)
Add entry synchronously to an open ledger.
|
void |
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.
|
void |
BookKeeper.deleteLedger(long lId)
Synchronous call to delete a ledger.
|
LedgerHandle |
BookKeeper.openLedger(long lId,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous open ledger call
|
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() |
void |
BookKeeperAdmin.recoverBookieData(InetSocketAddress bookieSrc,
InetSocketAddress bookieDest)
Synchronous method to rebuild and recover the ledger fragments data that
was stored on the source bookie.
|
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.