| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| org.apache.bookkeeper.client.api |
BookKeeper Client Public API.
|
| org.apache.bookkeeper.client.impl |
BookKeeper Client implementation package.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BKException
Class the enumerates all the possible error conditions.
|
static class |
BKException.BKAddEntryQuorumTimeoutException
Bookkeeper add entry quorum timeout exception.
|
static class |
BKException.BKBookieException
Bookkeeper bookie exception.
|
static class |
BKException.BKBookieHandleNotAvailableException
Bookkeeper bookie handle not available exception.
|
static class |
BKException.BKClientClosedException
Bookkeeper client closed exception.
|
static class |
BKException.BKDataUnknownException
Bookkeeper ledger in limbo and data may or may not exist.
|
static class |
BKException.BKDigestMatchException
Bookkeeper digest match exception.
|
static class |
BKException.BKDigestNotInitializedException
Bookkeeper digest not initialized exception.
|
static class |
BKException.BKDuplicateEntryIdException
Bookkeeper duplicate entry id exception.
|
static class |
BKException.BKIllegalOpException
Bookkeeper illegal operation exception.
|
static class |
BKException.BKIncorrectParameterException
Bookkeeper incorrect parameter exception.
|
static class |
BKException.BKInterruptedException
Bookkeeper interrupted exception.
|
static class |
BKException.BKLedgerClosedException
Bookkeeper ledger closed exception.
|
static class |
BKException.BKLedgerExistException
Bookkeeper ledger exist exception.
|
static class |
BKException.BKLedgerFencedException
Bookkeeper ledger fenced exception.
|
static class |
BKException.BKLedgerIdOverflowException
Bookkeeper ledger id overflow exception.
|
static class |
BKException.BKLedgerRecoveryException
Bookkeeper ledger recovery exception.
|
static class |
BKException.BKMetadataSerializationException
Bookkeeper metadata serialization exception.
|
static class |
BKException.BKMetadataVersionException
Bookkeeper metadata version exception.
|
static class |
BKException.BKNoSuchEntryException
Bookkeeper no such entry exception.
|
static class |
BKException.BKNoSuchLedgerExistsException
Bookkeeper no such ledger exists exception.
|
static class |
BKException.BKNoSuchLedgerExistsOnMetadataServerException
Bookkeeper no such ledger exists on metadata server exception.
|
static class |
BKException.BKNotEnoughBookiesException
Bookkeeper not enough bookies exception.
|
static class |
BKException.BKProtocolVersionException
Bookkeeper protocol version exception.
|
static class |
BKException.BKQuorumException
Bookkeeper quorum exception.
|
static class |
BKException.BKReadException
Bookkeeper read exception.
|
static class |
BKException.BKReplicationException
Bookkeeper replication exception.
|
static class |
BKException.BKSecurityException
Bookkeeper security exception.
|
static class |
BKException.BKTimeoutException
Bookkeeper timeout exception.
|
static class |
BKException.BKTooManyRequestsException
Bookkeeper too many requests exception.
|
static class |
BKException.BKUnauthorizedAccessException
Bookkeeper unauthorized access exception.
|
static class |
BKException.BKUnclosedFragmentException
Bookkeeper unclosed fragment exception.
|
static class |
BKException.BKUnexpectedConditionException
Bookkeeper unexpected condition exception.
|
static class |
BKException.BKWriteException
Bookkeeper write exception.
|
static class |
BKException.BKWriteOnReadOnlyBookieException
Bookkeeper write on readonly bookie exception.
|
static class |
BKException.MetaStoreException
Metastore exception.
|
static class |
BKException.ZKException
Zookeeper exception.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) static java.util.function.Function<java.lang.Throwable,BKException> |
BKException.HANDLER |
| Modifier and Type | Method and Description |
|---|---|
default long |
WriteHandle.append(byte[] data)
Add an entry synchronously to an open ledger.
|
default long |
WriteHandle.append(byte[] data,
int offset,
int length)
Add an entry synchronously to an open ledger.
|
default long |
WriteHandle.append(io.netty.buffer.ByteBuf data)
Add entry synchronously to an open ledger.
|
default long |
WriteHandle.append(java.nio.ByteBuffer data)
Add entry synchronously to an open ledger.
|
BookKeeper |
BookKeeperBuilder.build()
Start and initialize a new BookKeeper client.
|
void |
BookKeeper.close()
Close the client and release every resource.
|
default void |
Handle.close()
Close this handle synchronously.
|
default void |
WriteHandle.close()
Synchronous close the write handle, any adds in flight will return errors.
|
default LedgerEntries |
ReadHandle.read(long firstEntry,
long lastEntry)
Read a sequence of entries synchronously.
|
default long |
ReadHandle.readLastAddConfirmed()
Obtains asynchronously the last confirmed write from a quorum of bookies.
|
default LastConfirmedAndEntry |
ReadHandle.readLastAddConfirmedAndEntry(long entryId,
long timeOutInMillis,
boolean parallel)
Asynchronous read specific entry and the latest last add confirmed.
|
default LedgerEntries |
ReadHandle.readUnconfirmed(long firstEntry,
long lastEntry)
Read a sequence of entries synchronously.
|
default long |
ReadHandle.tryReadLastAddConfirmed()
Obtains asynchronously the last confirmed write from a quorum of bookies
but it doesn't wait all the responses from the quorum.
|
default long |
WriteAdvHandle.write(long entryId,
byte[] data)
Add entry synchronously to an open ledger.
|
default long |
WriteAdvHandle.write(long entryId,
byte[] data,
int offset,
int length)
Add entry synchronously to an open ledger.
|
default long |
WriteAdvHandle.write(long entryId,
io.netty.buffer.ByteBuf data)
Add entry asynchronously to an open ledger.
|
default long |
WriteAdvHandle.write(long entryId,
java.nio.ByteBuffer data)
Add entry synchronously to an open ledger.
|
| Modifier and Type | Method and Description |
|---|---|
BookKeeper |
BookKeeperBuilderImpl.build() |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.