Uses of Class
org.apache.bookkeeper.client.BKException
Packages that use BKException
Package
Description
BookKeeper Client.
Classes for replicating Bookkeeper data.
Package for bookkeeper http service.
A java io stream wrapper over bookkeeper ledgers.
-
Uses of BKException in org.apache.bookkeeper.client
Subclasses of BKException in org.apache.bookkeeper.clientModifier and TypeClassDescriptionstatic classBookkeeper add entry quorum timeout exception.static classBookkeeper bookie exception.static classBookkeeper bookie handle not available exception.static classBookkeeper client closed exception.static classBookkeeper ledger in limbo and data may or may not exist.static classBookkeeper digest match exception.static classBookkeeper digest not initialized exception.static classBookkeeper duplicate entry id exception.static classBookkeeper illegal operation exception.static classBookkeeper incorrect parameter exception.static classBookkeeper interrupted exception.static classBookkeeper ledger closed exception.static classBookkeeper ledger exist exception.static classBookkeeper ledger fenced exception.static classBookkeeper ledger id overflow exception.static classBookkeeper ledger recovery exception.static classBookkeeper metadata serialization exception.static classBookkeeper metadata version exception.static classBookkeeper no such entry exception.static classBookkeeper no such ledger exists exception.static classBookkeeper no such ledger exists on metadata server exception.static classBookkeeper not enough bookies exception.static classBookkeeper protocol version exception.static classBookkeeper quorum exception.static classBookkeeper read exception.static classBookkeeper replication exception.static classBookkeeper security exception.static classBookkeeper timeout exception.static classBookkeeper too many requests exception.static classBookkeeper unauthorized access exception.static classBookkeeper unclosed fragment exception.static classBookkeeper unexpected condition exception.static classBookkeeper write exception.static classBookkeeper write on readonly bookie exception.static classMetastore exception.static classZookeeper exception.Fields in org.apache.bookkeeper.client with type parameters of type BKExceptionModifier and TypeFieldDescriptionstatic final Function<Throwable,BKException> BKException.HANDLERMethods in org.apache.bookkeeper.client that return BKExceptionModifier and TypeMethodDescriptionstatic BKExceptionBKException.create(int code) Create an exception from an error code.Methods in org.apache.bookkeeper.client that throw BKExceptionModifier and TypeMethodDescriptionlongLedgerHandle.addEntry(byte[] data) Add entry synchronously to an open ledger.longLedgerHandle.addEntry(byte[] data, int offset, int length) Add entry synchronously to an open ledger.longLedgerHandle.addEntry(long entryId, byte[] data) Add entry synchronously to an open ledger.longLedgerHandle.addEntry(long entryId, byte[] data, int offset, int length) Add entry synchronously to an open ledger.longLedgerHandleAdv.addEntry(long entryId, byte[] data) Add entry synchronously to an open ledger.longLedgerHandleAdv.addEntry(long entryId, byte[] data, int offset, int length) Add entry synchronously to an open ledger.longReadOnlyLedgerHandle.addEntry(byte[] data) longReadOnlyLedgerHandle.addEntry(byte[] data, int offset, int length) LedgerHandle.batchReadEntries(long startEntry, int maxCount, long maxSize) Read a sequence of entries synchronously.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 ofLedgerHandle.asyncBatchReadUnconfirmedEntries(long, int, long, ReadCallback, Object)BookKeeper.Builder.build()voidBookKeeper.close()Shuts down client.voidBookKeeperAdmin.close()Gracefully release resources that this client uses.voidLedgerHandle.close()Synchronous close the write handle, any adds in flight will return errors.voidReadOnlyLedgerHandle.close()BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.BookKeeper.createLedger(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, Map<String, byte[]> customMetadata) Synchronous call to create ledger.BookKeeper.createLedger(int ensSize, int qSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.BookKeeper.createLedger(BookKeeper.DigestType digestType, byte[] passwd) Creates a new ledger.BookKeeper.createLedgerAdv(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd) Synchronous call to create ledger.BookKeeper.createLedgerAdv(int ensSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, Map<String, byte[]> customMetadata) Synchronous call to create ledger.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.voidBookKeeperAdmin.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.voidBookKeeper.deleteLedger(long lId) Synchronous call to delete a ledger.BookieWatcher.getAllBookies()BookieWatcherImpl.getAllBookies()BookKeeperAdmin.getAllBookies()Get a list of all bookies including the not available ones.BookKeeperAdmin.getAvailableBookies()Get a list of the available bookies.(package private) Map<BookieId,BookieInfoReader.BookieInfo> BookieInfoReader.getBookieInfo()BookKeeper.getBookieInfo()Retrieves BookieInfo from all the bookies in the cluster.BookieWatcher.getBookies()BookieWatcherImpl.getBookies()BookKeeperAdmin.getBookieServiceInfo(BookieId bookiedId) BookKeeperAdmin.getLedgersContainBookies(Set<BookieId> bookies) BookieWatcher.getReadOnlyBookies()BookieWatcherImpl.getReadOnlyBookies()BookKeeperAdmin.getReadOnlyBookies()Get a list of readonly bookies synchronously.voidBookieWatcherImpl.initialBlockingBookieRead()Blocks until bookies are read from zookeeper, used in theBookKeeperconstructor.booleanBookKeeper.isClosed(long lId) Check whether the ledger with identifier lId has been closed.static BookKeeperAdminBookKeeperAdmin.newBookKeeperAdmin(ClientConfiguration conf) BookKeeper.openLedger(long lId, BookKeeper.DigestType digestType, byte[] passwd) Synchronous open ledger call.BookKeeper.openLedger(long lId, BookKeeper.DigestType digestType, byte[] passwd, boolean keepUpdateMetadata) Synchronous open ledger call.BookKeeperAdmin.openLedger(long lId) Open a ledger as an administrator.BookKeeper.openLedgerNoRecovery(long lId, BookKeeper.DigestType digestType, byte[] passwd) Synchronous, unsafe open ledger call.BookKeeperAdmin.openLedgerNoRecovery(long lId) Open a ledger as an administrator without recovering the ledger.BookKeeperAdmin.readEntries(long ledgerId, long firstEntry, long lastEntry) Read entries from a ledger synchronously.LedgerHandle.readEntries(long firstEntry, long lastEntry) Read a sequence of entries synchronously.longLedgerHandle.readExplicitLastConfirmed()longLedgerHandle.readLastConfirmed()Obtains synchronously the last confirmed write from a quorum of bookies.LedgerHandle.readLastEntry()LedgerHandle.readUnconfirmedEntries(long firstEntry, long lastEntry) Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range.
This is the same ofLedgerHandle.asyncReadUnconfirmedEntries(long, long, ReadCallback, Object)voidBookKeeperAdmin.recoverBookieData(long lid, Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers) voidBookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc) voidBookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers) voidBookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers, boolean skipUnrecoverableLedgers) voidBookKeeperAdmin.recoverBookieData(BookieId bookieSrc) Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.voidBookKeeperAdmin.replicateLedgerFragment(LedgerHandle lh, LedgerFragment ledgerFragment, BiConsumer<Long, Long> onReadEntryFailureCallback) Replicate the Ledger fragment to target Bookie passed.longLedgerHandle.tryReadLastConfirmed()Obtains synchronously the last confirmed write from a quorum of bookies.static <T> TSyncCallbackUtils.waitForResult(CompletableFuture<T> future) Wait for a result.voidBookKeeperAdmin.watchReadOnlyBookiesChanged(RegistrationClient.RegistrationListener listener) Notify when the available list of read only bookies changes.voidBookKeeperAdmin.watchWritableBookiesChanged(RegistrationClient.RegistrationListener listener) Notify when the available list of bookies changes.Constructors in org.apache.bookkeeper.client that throw BKExceptionModifierConstructorDescriptionBookKeeper(String servers) Create a bookkeeper client.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.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 BKExceptionModifier and TypeMethodDescription(package private) voidAuditorBookieCheckTask.auditBookies()(package private) voidAuditorCheckAllLedgersTask.checkAllLedgers()List all the ledgers and check them individually.Auditor.getAvailableBookies()AuditorTask.getAvailableBookies() -
Uses of BKException in org.apache.bookkeeper.server.http
Methods in org.apache.bookkeeper.server.http that throw BKException -
Uses of BKException in org.apache.bookkeeper.streaming
Constructors in org.apache.bookkeeper.streaming that throw BKExceptionModifierConstructorDescriptionconstruct 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 BKExceptionModifier and TypeMethodDescriptionbooleanLostBookieRecoveryDelayCommand.handler(ServerConfiguration conf, LostBookieRecoveryDelayCommand.LBRDFlags flags)