Uses of Class
org.apache.bookkeeper.bookie.BookieException
Packages that use BookieException
Package
Description
Provides a Bookie server that stores entries for clients.
Package of the classes for defining bookie stats.
Classes related to DB based ledger storage.
Classes related to service discovery.
Classes for interacting with bookkeeper ledgers and ledger metadata.
Classes related to the Bookkeeper protocol.
-
Uses of BookieException in org.apache.bookkeeper.bookie
Subclasses of BookieException in org.apache.bookkeeper.bookieModifier and TypeClassDescriptionstatic classSignals that an illegal operation attempts to access the data in a bookie.static classSignals that an unauthorized operation attempts to access the data in a bookie.static classSignal that cookie already exists when creating a new cookie.static classSignal that no cookie is found when starting a bookie.static classSignal when a ledger is in a limbo state and certain operations cannot be performed on it.static classSignals when multiple ledger/journal directories are mounted in same disk partition.static classSignal that error while accessing entry-log metadata map.static classSignal that an invalid cookie is found when starting a bookie.static classSignals that a ledger has been fenced in a bookie.static classSignals that a ledger has been fenced in a bookie.static classSignal when bookie has problems on accessing metadata store.static classSignals that a ledger's operation has been rejected by an internal component because of the resource saturation.static classSignal when bookie has problems on accessing metadata store.static classSignals that an exception occurs on upgrading a bookie.Methods in org.apache.bookkeeper.bookie that return BookieExceptionMethods in org.apache.bookkeeper.bookie that throw BookieExceptionModifier and TypeMethodDescriptionvoidBookie.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey) voidBookieImpl.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey) Add entry to a ledger.(package private) abstract longLedgerDescriptor.addEntry(io.netty.buffer.ByteBuf entry) (package private) longLedgerDescriptorImpl.addEntry(io.netty.buffer.ByteBuf entry) longLedgerStorage.addEntry(io.netty.buffer.ByteBuf entry) Add an entry to the storage.(package private) abstract voidLedgerDescriptor.checkAccess(byte[] masterKey) (package private) voidLedgerDescriptorImpl.checkAccess(byte[] masterKey) (package private) voidLedgerDescriptorReadOnlyImpl.checkAccess(byte[] masterKey) voidCookieValidation.checkCookies(List<File> directories) voidLegacyCookieValidation.checkCookies(List<File> directories) static MetadataBookieDriverBookieResources.createMetadataDriver(ServerConfiguration conf, StatsLogger statsLogger) Instantiate the metadata driver for the Bookie.voidCookie.deleteFromRegistrationManager(RegistrationManager rm, ServerConfiguration conf, Version version) Deletes cookie from registration manager.voidCookie.deleteFromRegistrationManager(RegistrationManager rm, BookieId address, Version version) Delete cookie from registration manager.booleanLedgerStorage.entryExists(long ledgerId, long entryId) Whether an entry exists.Bookie.fenceLedger(long ledgerId, byte[] masterKey) Fences a ledger.BookieImpl.fenceLedger(long ledgerId, byte[] masterKey) Fences a ledger.io.netty.buffer.ByteBufLedgerStorage.getEntry(long ledgerId, long entryId) Read an entry from storage.io.netty.buffer.ByteBufSortedLedgerStorage.getEntry(long ledgerId, long entryId) io.netty.buffer.ByteBufBookie.getExplicitLac(long ledgerId) io.netty.buffer.ByteBufBookieImpl.getExplicitLac(long ledgerId) (package private) abstract io.netty.buffer.ByteBufLedgerDescriptor.getExplicitLac()(package private) io.netty.buffer.ByteBufLedgerDescriptorImpl.getExplicitLac()io.netty.buffer.ByteBufLedgerStorage.getExplicitLac(long ledgerId) HandleFactory.getHandle(long ledgerId, byte[] masterKey, boolean journalReplay) HandleFactoryImpl.getHandle(long ledgerId, byte[] masterKey, boolean journalReplay) (package private) abstract longLedgerDescriptor.getLastAddConfirmed()(package private) longLedgerDescriptorImpl.getLastAddConfirmed()longLedgerStorage.getLastAddConfirmed(long ledgerId) Get last add confirmed.(package private) LedgerDescriptorBookieImpl.getLedgerForEntry(io.netty.buffer.ByteBuf entry, byte[] masterKey) Retrieve the ledger descriptor for the ledger which entry should be added to.(package private) abstract booleanLedgerDescriptor.isFenced()(package private) booleanLedgerDescriptorImpl.isFenced()booleanLedgerStorage.isFenced(long ledgerId) Check whether the ledger is fenced in ledger storage or not.static BookieImplBookieImpl.newBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, Supplier<BookieServiceInfo> bookieServiceInfoProvider) io.netty.buffer.ByteBufBookie.readEntry(long ledgerId, long entryId) io.netty.buffer.ByteBufBookieImpl.readEntry(long ledgerId, long entryId) (package private) abstract io.netty.buffer.ByteBufLedgerDescriptor.readEntry(long entryId) (package private) io.netty.buffer.ByteBufLedgerDescriptorImpl.readEntry(long entryId) Cookie.readFromRegistrationManager(RegistrationManager rm, ServerConfiguration conf) Read cookie from registration manager.Cookie.readFromRegistrationManager(RegistrationManager rm, BookieId address) Read cookie from registration manager for a given bookie address.(package private) voidBookieImpl.readJournal()longBookie.readLastAddConfirmed(long ledgerId) longBookieImpl.readLastAddConfirmed(long ledgerId) (package private) byte[]IndexPersistenceMgr.readMasterKey(long ledgerId) byte[]InterleavedLedgerStorage.readMasterKey(long ledgerId) byte[]InterleavedStorageRegenerateIndexOp.DryRunLedgerCache.readMasterKey(long ledgerId) byte[]LedgerCache.readMasterKey(long ledgerId) byte[]LedgerCacheImpl.readMasterKey(long ledgerId) byte[]LedgerStorage.readMasterKey(long ledgerId) Get the master key for a ledger.byte[]SortedLedgerStorage.readMasterKey(long ledgerId) voidBookie.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey) voidBookieImpl.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, byte[] masterKey) Add entry to a ledger, even if the ledger has previous been fenced.voidBookie.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, Object ctx, byte[] masterKey) voidBookieImpl.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, Object ctx, byte[] masterKey) voidCookie.writeToRegistrationManager(RegistrationManager rm, ServerConfiguration conf, Version version) Writes cookie details to registration manager.Constructors in org.apache.bookkeeper.bookie that throw BookieExceptionModifierConstructorDescriptionBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, Supplier<BookieServiceInfo> bookieServiceInfoProvider) ReadOnlyBookie(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, Supplier<BookieServiceInfo> bookieServiceInfoProvider) -
Uses of BookieException in org.apache.bookkeeper.bookie.datainteg
Methods in org.apache.bookkeeper.bookie.datainteg that throw BookieExceptionModifier and TypeMethodDescriptionvoidDataIntegrityCookieValidation.checkCookies(List<File> directories) (package private) booleanDataIntegrityCheckImpl.isEntryMissing(WriteSets writeSets, NavigableMap<Long, Integer> bookieIndices, long ledgerId, long entryId) -
Uses of BookieException in org.apache.bookkeeper.bookie.storage.ldb
Methods in org.apache.bookkeeper.bookie.storage.ldb that throw BookieExceptionModifier and TypeMethodDescriptionlongDbLedgerStorage.addEntry(io.netty.buffer.ByteBuf entry) longSingleDirectoryDbLedgerStorage.addEntry(io.netty.buffer.ByteBuf entry) booleanDbLedgerStorage.entryExists(long ledgerId, long entryId) booleanSingleDirectoryDbLedgerStorage.entryExists(long ledgerId, long entryId) io.netty.buffer.ByteBufDbLedgerStorage.getEntry(long ledgerId, long entryId) io.netty.buffer.ByteBufSingleDirectoryDbLedgerStorage.getEntry(long ledgerId, long entryId) io.netty.buffer.ByteBufDbLedgerStorage.getExplicitLac(long ledgerId) io.netty.buffer.ByteBufSingleDirectoryDbLedgerStorage.getExplicitLac(long ledgerId) longDbLedgerStorage.getLastAddConfirmed(long ledgerId) longSingleDirectoryDbLedgerStorage.getLastAddConfirmed(long ledgerId) io.netty.buffer.ByteBufDbLedgerStorage.getLastEntry(long ledgerId) io.netty.buffer.ByteBufSingleDirectoryDbLedgerStorage.getLastEntry(long ledgerId) booleanDbLedgerStorage.isFenced(long ledgerId) booleanSingleDirectoryDbLedgerStorage.isFenced(long ledgerId) byte[]DbLedgerStorage.readMasterKey(long ledgerId) byte[]SingleDirectoryDbLedgerStorage.readMasterKey(long ledgerId) -
Uses of BookieException in org.apache.bookkeeper.discover
Methods in org.apache.bookkeeper.discover that throw BookieExceptionModifier and TypeMethodDescriptionRegistrationManager.getClusterInstanceId()Return the cluster instance id.ZKRegistrationManager.getClusterInstanceId()booleanRegistrationManager.isBookieRegistered(BookieId bookieId) Checks if Bookie with the given BookieId is registered as readwrite or readonly bookie.booleanZKRegistrationManager.isBookieRegistered(BookieId bookieId) Versioned<byte[]>RegistrationManager.readCookie(BookieId bookieId) Read the cookie data, which will be used for verifying the integrity of the bookie environment.Versioned<byte[]>ZKRegistrationManager.readCookie(BookieId bookieId) voidRegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo serviceInfo) Registering the bookie server as bookieId.voidZKRegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo bookieServiceInfo) voidRegistrationManager.removeCookie(BookieId bookieId, Version version) Remove the cookie data.voidZKRegistrationManager.removeCookie(BookieId bookieId, Version version) voidRegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly) Unregistering the bookie server as bookieId.voidZKRegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly) voidRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData) Write the cookie data, which will be used for verifying the integrity of the bookie environment.voidZKRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData) -
Uses of BookieException in org.apache.bookkeeper.meta
Methods in org.apache.bookkeeper.meta that throw BookieExceptionModifier and TypeMethodDescriptionVersioned<byte[]>NullMetadataBookieDriver.NullRegistrationManager.readCookie(BookieId bookieId) voidNullMetadataBookieDriver.NullRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData) -
Uses of BookieException in org.apache.bookkeeper.proto
Methods in org.apache.bookkeeper.proto that throw BookieExceptionModifier and TypeMethodDescriptionstatic BookieServerBookieServer.newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection) protected BookkeeperProtocol.ReadResponseLongPollReadEntryProcessorV3.readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) protected BookkeeperProtocol.ReadResponseReadEntryProcessorV3.readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, boolean readLACPiggyBack, com.google.common.base.Stopwatch startTimeSw) Read a specific entry.protected BookkeeperProtocol.ReadResponseReadEntryProcessorV3.readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw) Read a specific entry.Constructors in org.apache.bookkeeper.proto that throw BookieExceptionModifierConstructorDescription(package private)BookieNettyServer(ServerConfiguration conf, RequestProcessor processor, io.netty.buffer.ByteBufAllocator allocator) BookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)