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.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)
-