Uses of Class
org.apache.bookkeeper.bookie.BookieException

Packages that use BookieException

Package	Description
org.apache.bookkeeper.bookie	Provides a Bookie server that stores entries for clients.
org.apache.bookkeeper.bookie.datainteg	Package of the classes for defining bookie stats.
org.apache.bookkeeper.bookie.storage.ldb	Classes related to DB based ledger storage.
org.apache.bookkeeper.discover	Classes related to service discovery.
org.apache.bookkeeper.meta	Classes for interacting with bookkeeper ledgers and ledger metadata.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.

Uses of BookieException in org.apache.bookkeeper.bookie

Subclasses of BookieException in org.apache.bookkeeper.bookie

Modifier and Type	Class	Description
static class	BookieException.BookieIllegalOpException	Signals that an illegal operation attempts to access the data in a bookie.
static class	BookieException.BookieUnauthorizedAccessException	Signals that an unauthorized operation attempts to access the data in a bookie.
static class	BookieException.CookieExistException	Signal that cookie already exists when creating a new cookie.
static class	BookieException.CookieNotFoundException	Signal that no cookie is found when starting a bookie.
static class	BookieException.DataUnknownException	Signal when a ledger is in a limbo state and certain operations cannot be performed on it.
static class	BookieException.DiskPartitionDuplicationException	Signals when multiple ledger/journal directories are mounted in same disk partition.
static class	BookieException.EntryLogMetadataMapException	Signal that error while accessing entry-log metadata map.
static class	BookieException.InvalidCookieException	Signal that an invalid cookie is found when starting a bookie.
static class	BookieException.LedgerFencedAndDeletedException	Signals that a ledger has been fenced in a bookie.
static class	BookieException.LedgerFencedException	Signals that a ledger has been fenced in a bookie.
static class	BookieException.MetadataStoreException	Signal when bookie has problems on accessing metadata store.
static class	BookieException.OperationRejectedException	Signals that a ledger's operation has been rejected by an internal component because of the resource saturation.
static class	BookieException.UnknownBookieIdException	Signal when bookie has problems on accessing metadata store.
static class	BookieException.UpgradeException	Signals that an exception occurs on upgrading a bookie.

Methods in org.apache.bookkeeper.bookie that return BookieException

Modifier and Type	Method	Description
static BookieException	BookieException.create(int code)

Methods in org.apache.bookkeeper.bookie that throw BookieException

Modifier and Type	Method	Description
void	Bookie.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, java.lang.Object ctx, byte[] masterKey)
void	BookieImpl.addEntry(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, BookkeeperInternalCallbacks.WriteCallback cb, java.lang.Object ctx, byte[] masterKey)	Add entry to a ledger.
(package private) abstract long	LedgerDescriptor.addEntry(io.netty.buffer.ByteBuf entry)
(package private) long	LedgerDescriptorImpl.addEntry(io.netty.buffer.ByteBuf entry)
long	LedgerStorage.addEntry(io.netty.buffer.ByteBuf entry)	Add an entry to the storage.
(package private) abstract void	LedgerDescriptor.checkAccess(byte[] masterKey)
(package private) void	LedgerDescriptorImpl.checkAccess(byte[] masterKey)
(package private) void	LedgerDescriptorReadOnlyImpl.checkAccess(byte[] masterKey)
void	CookieValidation.checkCookies(java.util.List<java.io.File> directories)
void	LegacyCookieValidation.checkCookies(java.util.List<java.io.File> directories)
static MetadataBookieDriver	BookieResources.createMetadataDriver(ServerConfiguration conf, StatsLogger statsLogger)	Instantiate the metadata driver for the Bookie.
void	Cookie.deleteFromRegistrationManager(RegistrationManager rm, ServerConfiguration conf, Version version)	Deletes cookie from registration manager.
void	Cookie.deleteFromRegistrationManager(RegistrationManager rm, BookieId address, Version version)	Delete cookie from registration manager.
boolean	LedgerStorage.entryExists(long ledgerId, long entryId)	Whether an entry exists.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	Bookie.fenceLedger(long ledgerId, byte[] masterKey)	Fences a ledger.
java.util.concurrent.CompletableFuture<java.lang.Boolean>	BookieImpl.fenceLedger(long ledgerId, byte[] masterKey)	Fences a ledger.
io.netty.buffer.ByteBuf	LedgerStorage.getEntry(long ledgerId, long entryId)	Read an entry from storage.
io.netty.buffer.ByteBuf	SortedLedgerStorage.getEntry(long ledgerId, long entryId)
io.netty.buffer.ByteBuf	Bookie.getExplicitLac(long ledgerId)
io.netty.buffer.ByteBuf	BookieImpl.getExplicitLac(long ledgerId)
(package private) abstract io.netty.buffer.ByteBuf	LedgerDescriptor.getExplicitLac()
(package private) io.netty.buffer.ByteBuf	LedgerDescriptorImpl.getExplicitLac()
io.netty.buffer.ByteBuf	LedgerStorage.getExplicitLac(long ledgerId)
LedgerDescriptor	HandleFactory.getHandle(long ledgerId, byte[] masterKey, boolean journalReplay)
LedgerDescriptor	HandleFactoryImpl.getHandle(long ledgerId, byte[] masterKey, boolean journalReplay)
(package private) abstract long	LedgerDescriptor.getLastAddConfirmed()
(package private) long	LedgerDescriptorImpl.getLastAddConfirmed()
long	LedgerStorage.getLastAddConfirmed(long ledgerId)	Get last add confirmed.
(package private) LedgerDescriptor	BookieImpl.getLedgerForEntry(io.netty.buffer.ByteBuf entry, byte[] masterKey)	Retrieve the ledger descriptor for the ledger which entry should be added to.
(package private) abstract boolean	LedgerDescriptor.isFenced()
(package private) boolean	LedgerDescriptorImpl.isFenced()
boolean	LedgerStorage.isFenced(long ledgerId)	Check whether the ledger is fenced in ledger storage or not.
static BookieImpl	BookieImpl.newBookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
io.netty.buffer.ByteBuf	Bookie.readEntry(long ledgerId, long entryId)
io.netty.buffer.ByteBuf	BookieImpl.readEntry(long ledgerId, long entryId)
(package private) abstract io.netty.buffer.ByteBuf	LedgerDescriptor.readEntry(long entryId)
(package private) io.netty.buffer.ByteBuf	LedgerDescriptorImpl.readEntry(long entryId)
static Versioned<Cookie>	Cookie.readFromRegistrationManager(RegistrationManager rm, ServerConfiguration conf)	Read cookie from registration manager.
static Versioned<Cookie>	Cookie.readFromRegistrationManager(RegistrationManager rm, BookieId address)	Read cookie from registration manager for a given bookie address.
(package private) void	BookieImpl.readJournal()
long	Bookie.readLastAddConfirmed(long ledgerId)
long	BookieImpl.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)
void	Bookie.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, java.lang.Object ctx, byte[] masterKey)
void	BookieImpl.recoveryAddEntry(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback cb, java.lang.Object ctx, byte[] masterKey)	Add entry to a ledger, even if the ledger has previous been fenced.
void	Bookie.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, java.lang.Object ctx, byte[] masterKey)
void	BookieImpl.setExplicitLac(io.netty.buffer.ByteBuf entry, BookkeeperInternalCallbacks.WriteCallback writeCallback, java.lang.Object ctx, byte[] masterKey)
void	Cookie.writeToRegistrationManager(RegistrationManager rm, ServerConfiguration conf, Version version)	Writes cookie details to registration manager.

Constructors in org.apache.bookkeeper.bookie that throw BookieException

Constructor	Description
BookieImpl(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)
ReadOnlyBookie(ServerConfiguration conf, RegistrationManager registrationManager, LedgerStorage storage, DiskChecker diskChecker, LedgerDirsManager ledgerDirsManager, LedgerDirsManager indexDirsManager, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, java.util.function.Supplier<BookieServiceInfo> bookieServiceInfoProvider)

Uses of BookieException in org.apache.bookkeeper.bookie.datainteg

Methods in org.apache.bookkeeper.bookie.datainteg that throw BookieException

Modifier and Type	Method	Description
void	DataIntegrityCookieValidation.checkCookies(java.util.List<java.io.File> directories)
(package private) boolean	DataIntegrityCheckImpl.isEntryMissing(WriteSets writeSets, java.util.NavigableMap<java.lang.Long,java.lang.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 BookieException

Modifier and Type	Method	Description
long	DbLedgerStorage.addEntry(io.netty.buffer.ByteBuf entry)
long	SingleDirectoryDbLedgerStorage.addEntry(io.netty.buffer.ByteBuf entry)
boolean	DbLedgerStorage.entryExists(long ledgerId, long entryId)
boolean	SingleDirectoryDbLedgerStorage.entryExists(long ledgerId, long entryId)
io.netty.buffer.ByteBuf	DbLedgerStorage.getEntry(long ledgerId, long entryId)
io.netty.buffer.ByteBuf	SingleDirectoryDbLedgerStorage.getEntry(long ledgerId, long entryId)
io.netty.buffer.ByteBuf	DbLedgerStorage.getExplicitLac(long ledgerId)
io.netty.buffer.ByteBuf	SingleDirectoryDbLedgerStorage.getExplicitLac(long ledgerId)
long	DbLedgerStorage.getLastAddConfirmed(long ledgerId)
long	SingleDirectoryDbLedgerStorage.getLastAddConfirmed(long ledgerId)
io.netty.buffer.ByteBuf	DbLedgerStorage.getLastEntry(long ledgerId)
io.netty.buffer.ByteBuf	SingleDirectoryDbLedgerStorage.getLastEntry(long ledgerId)
boolean	DbLedgerStorage.isFenced(long ledgerId)
boolean	SingleDirectoryDbLedgerStorage.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 BookieException

Modifier and Type	Method	Description
java.lang.String	RegistrationManager.getClusterInstanceId()	Return the cluster instance id.
java.lang.String	ZKRegistrationManager.getClusterInstanceId()
boolean	RegistrationManager.isBookieRegistered(BookieId bookieId)	Checks if Bookie with the given BookieId is registered as readwrite or readonly bookie.
boolean	ZKRegistrationManager.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)
void	RegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo serviceInfo)	Registering the bookie server as bookieId.
void	ZKRegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo bookieServiceInfo)
void	RegistrationManager.removeCookie(BookieId bookieId, Version version)	Remove the cookie data.
void	ZKRegistrationManager.removeCookie(BookieId bookieId, Version version)
void	RegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly)	Unregistering the bookie server as bookieId.
void	ZKRegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly)
void	RegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)	Write the cookie data, which will be used for verifying the integrity of the bookie environment.
void	ZKRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)

Uses of BookieException in org.apache.bookkeeper.meta

Methods in org.apache.bookkeeper.meta that throw BookieException

Modifier and Type	Method	Description
Versioned<byte[]>	NullMetadataBookieDriver.NullRegistrationManager.readCookie(BookieId bookieId)
void	NullMetadataBookieDriver.NullRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)

Uses of BookieException in org.apache.bookkeeper.proto

Methods in org.apache.bookkeeper.proto that throw BookieException

Modifier and Type	Method	Description
static BookieServer	BookieServer.newBookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)
protected BookkeeperProtocol.ReadResponse	LongPollReadEntryProcessorV3.readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, com.google.common.base.Stopwatch startTimeSw)
protected BookkeeperProtocol.ReadResponse	ReadEntryProcessorV3.readEntry(BookkeeperProtocol.ReadResponse.Builder readResponseBuilder, long entryId, boolean readLACPiggyBack, com.google.common.base.Stopwatch startTimeSw)	Read a specific entry.
protected BookkeeperProtocol.ReadResponse	ReadEntryProcessorV3.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 BookieException

Constructor	Description
BookieNettyServer(ServerConfiguration conf, RequestProcessor processor, io.netty.buffer.ByteBufAllocator allocator)
BookieServer(ServerConfiguration conf, Bookie bookie, StatsLogger statsLogger, io.netty.buffer.ByteBufAllocator allocator, UncleanShutdownDetection uncleanShutdownDetection)