Uses of Class
org.apache.bookkeeper.client.BKException

Packages that use BKException

Package	Description
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.replication	Classes for replicating Bookkeeper data.
org.apache.bookkeeper.server.http	Package for bookkeeper http service.
org.apache.bookkeeper.streaming	A java io stream wrapper over bookkeeper ledgers.
org.apache.bookkeeper.tools.cli.commands.autorecovery

Uses of BKException in org.apache.bookkeeper.client

Subclasses of BKException in org.apache.bookkeeper.client

Modifier and Type	Class	Description
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.

Fields in org.apache.bookkeeper.client with type parameters of type BKException

Modifier and Type	Field	Description
static final Function<Throwable,BKException>	BKException.HANDLER

Methods in org.apache.bookkeeper.client that return BKException

Modifier and Type	Method	Description
static BKException	BKException.create(int code)	Create an exception from an error code.

Methods in org.apache.bookkeeper.client that throw BKException

Modifier and Type	Method	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	LedgerHandle.addEntry(long entryId, byte[] data)	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.
long	LedgerHandleAdv.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	ReadOnlyLedgerHandle.addEntry(byte[] data)
long	ReadOnlyLedgerHandle.addEntry(byte[] data, int offset, int length)
Enumeration<LedgerEntry>	LedgerHandle.batchReadEntries(long startEntry, int maxCount, long maxSize)	Read a sequence of entries synchronously.
Enumeration<LedgerEntry>	LedgerHandle.batchReadUnconfirmedEntries(long firstEntry, int maxCount, long maxSize)	Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range. This is the same of LedgerHandle.asyncBatchReadUnconfirmedEntries(long, int, long, ReadCallback, Object)
BookKeeper	BookKeeper.Builder.build()
void	BookKeeper.close()	Shuts down client.
void	BookKeeperAdmin.close()	Gracefully release resources that this client uses.
void	LedgerHandle.close()	Synchronous close the write handle, any adds in flight will return errors.
void	ReadOnlyLedgerHandle.close()
LedgerHandle	BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd)	Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, Map<String,byte[]> customMetadata)	Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedger(int ensSize, int qSize, BookKeeper.DigestType digestType, byte[] passwd)	Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedger(BookKeeper.DigestType digestType, byte[] passwd)	Creates a new ledger.
LedgerHandle	BookKeeper.createLedgerAdv(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, Map<String,byte[]> customMetadata)	Synchronous call to create ledger.
LedgerHandle	BookKeeper.createLedgerAdv(long ledgerId, int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, Map<String,byte[]> customMetadata)	Synchronously creates a new ledger using the interface which accepts a ledgerId as input.
void	BookKeeperAdmin.decommissionBookie(BookieId bookieAddress)	Triggers AuditTask by resetting lostBookieRecoveryDelay and then make sure the ledgers stored in the given decommissioning bookie are properly replicated and they are not underreplicated because of the given bookie.
void	BookKeeper.deleteLedger(long lId)	Synchronous call to delete a ledger.
Set<BookieId>	BookieWatcher.getAllBookies()
Set<BookieId>	BookieWatcherImpl.getAllBookies()
Collection<BookieId>	BookKeeperAdmin.getAllBookies()	Get a list of all bookies including the not available ones.
Collection<BookieId>	BookKeeperAdmin.getAvailableBookies()	Get a list of the available bookies.
(package private) Map<BookieId,BookieInfoReader.BookieInfo>	BookieInfoReader.getBookieInfo()
Map<BookieId,BookieInfoReader.BookieInfo>	BookKeeper.getBookieInfo()	Retrieves BookieInfo from all the bookies in the cluster.
Set<BookieId>	BookieWatcher.getBookies()
Set<BookieId>	BookieWatcherImpl.getBookies()
BookieServiceInfo	BookKeeperAdmin.getBookieServiceInfo(BookieId bookiedId)
SortedMap<Long,LedgerMetadata>	BookKeeperAdmin.getLedgersContainBookies(Set<BookieId> bookies)
Set<BookieId>	BookieWatcher.getReadOnlyBookies()
Set<BookieId>	BookieWatcherImpl.getReadOnlyBookies()
Collection<BookieId>	BookKeeperAdmin.getReadOnlyBookies()	Get a list of readonly bookies synchronously.
void	BookieWatcherImpl.initialBlockingBookieRead()	Blocks until bookies are read from zookeeper, used in the BookKeeper constructor.
boolean	BookKeeper.isClosed(long lId)	Check whether the ledger with identifier lId has been closed.
static BookKeeperAdmin	BookKeeperAdmin.newBookKeeperAdmin(ClientConfiguration conf)
LedgerHandle	BookKeeper.openLedger(long lId, BookKeeper.DigestType digestType, byte[] passwd)	Synchronous open ledger call.
LedgerHandle	BookKeeper.openLedger(long lId, BookKeeper.DigestType digestType, byte[] passwd, boolean keepUpdateMetadata)	Synchronous open ledger call.
LedgerHandle	BookKeeperAdmin.openLedger(long lId)	Open a ledger as an administrator.
LedgerHandle	BookKeeper.openLedgerNoRecovery(long lId, BookKeeper.DigestType digestType, byte[] passwd)	Synchronous, unsafe open ledger call.
LedgerHandle	BookKeeperAdmin.openLedgerNoRecovery(long lId)	Open a ledger as an administrator without recovering the ledger.
Iterable<LedgerEntry>	BookKeeperAdmin.readEntries(long ledgerId, long firstEntry, long lastEntry)	Read entries from a ledger synchronously.
Enumeration<LedgerEntry>	LedgerHandle.readEntries(long firstEntry, long lastEntry)	Read a sequence of entries synchronously.
long	LedgerHandle.readExplicitLastConfirmed()
long	LedgerHandle.readLastConfirmed()	Obtains synchronously the last confirmed write from a quorum of bookies.
LedgerEntry	LedgerHandle.readLastEntry()
Enumeration<LedgerEntry>	LedgerHandle.readUnconfirmedEntries(long firstEntry, long lastEntry)	Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range. This is the same of LedgerHandle.asyncReadUnconfirmedEntries(long, long, ReadCallback, Object)
void	BookKeeperAdmin.recoverBookieData(long lid, Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers, boolean skipUnrecoverableLedgers)
void	BookKeeperAdmin.recoverBookieData(BookieId bookieSrc)	Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
void	BookKeeperAdmin.replicateLedgerFragment(LedgerHandle lh, LedgerFragment ledgerFragment, BiConsumer<Long,Long> onReadEntryFailureCallback)	Replicate the Ledger fragment to target Bookie passed.
long	LedgerHandle.tryReadLastConfirmed()	Obtains synchronously the last confirmed write from a quorum of bookies.
static <T> T	SyncCallbackUtils.waitForResult(CompletableFuture<T> future)	Wait for a result.
void	BookKeeperAdmin.watchReadOnlyBookiesChanged(RegistrationClient.RegistrationListener listener)	Notify when the available list of read only bookies changes.
void	BookKeeperAdmin.watchWritableBookiesChanged(RegistrationClient.RegistrationListener listener)	Notify when the available list of bookies changes.

Constructors in org.apache.bookkeeper.client that throw BKException

Modifier	Constructor	Description
	BookKeeper(String servers)	Create a bookkeeper client.
	BookKeeper(ClientConfiguration conf)	Create a bookkeeper client using a configuration object.
	BookKeeper(ClientConfiguration conf, org.apache.zookeeper.ZooKeeper zk)	Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.
	BookKeeper(ClientConfiguration conf, org.apache.zookeeper.ZooKeeper zk, io.netty.channel.EventLoopGroup eventLoopGroup)	Create a bookkeeper client but use the passed in zookeeper client and client event loop group instead of instantiating those.
(package private)	BookKeeper(ClientConfiguration conf, org.apache.zookeeper.ZooKeeper zkc, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator byteBufAllocator, StatsLogger rootStatsLogger, DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer requestTimer, FeatureProvider featureProvider)	Constructor for use with the builder.
	BookKeeperAdmin(String zkServers)	Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
	BookKeeperAdmin(ClientConfiguration conf)	Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
	LedgerEntriesIterator(long ledgerId, long firstEntry, long lastEntry)

Uses of BKException in org.apache.bookkeeper.replication

Methods in org.apache.bookkeeper.replication that throw BKException

Modifier and Type	Method	Description
(package private) void	AuditorBookieCheckTask.auditBookies()
(package private) void	AuditorCheckAllLedgersTask.checkAllLedgers()	List all the ledgers and check them individually.
protected List<String>	Auditor.getAvailableBookies()
protected List<String>	AuditorTask.getAvailableBookies()

Uses of BKException in org.apache.bookkeeper.server.http

Methods in org.apache.bookkeeper.server.http that throw BKException

Modifier and Type	Method	Description
BKHttpServiceProvider	BKHttpServiceProvider.Builder.build()

Uses of BKException in org.apache.bookkeeper.streaming

Constructors in org.apache.bookkeeper.streaming that throw BKException

Modifier	Constructor	Description
	LedgerInputStream(LedgerHandle lh)	construct a outputstream from a ledger handle.
	LedgerInputStream(LedgerHandle lh, int size)	construct a outputstream from a ledger handle.

Uses of BKException in org.apache.bookkeeper.tools.cli.commands.autorecovery

Methods in org.apache.bookkeeper.tools.cli.commands.autorecovery that throw BKException

Modifier and Type	Method	Description
boolean	LostBookieRecoveryDelayCommand.handler(ServerConfiguration conf, LostBookieRecoveryDelayCommand.LBRDFlags flags)