Package org.apache.bookkeeper.bookie
package org.apache.bookkeeper.bookie
Provides a Bookie server that stores entries for clients.
-
ClassDescriptionAbstract entry log compactor used for compaction.LogRemovalListener.class Throttler.Interface for the bookie.Exception is thrown when no such an entry is found in this bookie.Exception is thrown when no such a ledger is found in this bookie.Thread is marked as critical and will exit, when there is an uncaught exception occurred in thread.Signals that a Bookie exception of some sort has occurred.Signals that an illegal operation attempts to access the data in a bookie.Signals that an unauthorized operation attempts to access the data in a bookie.An exception code indicates the failure reason.Signal that cookie already exists when creating a new cookie.Signal that no cookie is found when starting a bookie.Signal when a ledger is in a limbo state and certain operations cannot be performed on it.Signals when multiple ledger/journal directories are mounted in same disk partition.Signal that error while accessing entry-log metadata map.Signal that an invalid cookie is found when starting a bookie.Signals that a ledger has been fenced in a bookie.Signals that a ledger has been fenced in a bookie.Signal when bookie has problems on accessing metadata store.Signals that a ledger's operation has been rejected by an internal component because of the resource saturation.Signal when bookie has problems on accessing metadata store.Signals that an exception occurs on upgrading a bookie.A FileChannel for the JournalChannel read and write, we can use this interface to extend the FileChannel which we use in the JournalChannel.Implements a bookie.Centralizes the creation of injected resources.Bookie Shell is to provide utilities for users to administer a bookkeeper cluster.BookieShell command.A facility for reporting update ledger progress.An implementation of StateManager.The status object represents the current status of a bookie instance.Wrapper that wraps bookie threads.A utility class used for managing the stats constants used in server side.Provides a buffering layer in front of a FileChannel.A
BufferedChannelBaseadds functionality to an existing file channel, the ability to buffer the input and output data.A Buffered channel without a write buffer.Interface plugged into caching to receive callback notifications.The instance that is responsible for checkpointing ledger storage.Interface to communicate checkpoint progress.A checkpoint presented a time point.ACheckpointSourceListmanages a list ofCheckpointSources.Interface that identifies LedgerStorage implementations using EntryLogger and running periodic entries compaction.When a bookie starts for the first time it generates a cookie, and stores the cookie in registration manager as well as in the each of the local filesystem directories it uses.Cookie builder.Interface for cookie validation.This class manages the writing of the bookkeeper entries.Entry Log Listener.Exception type for representing lookup errors.Represents case where log is present, but encoded entry length header is invalid.Represents case where entry log is present, but does not contain the specified entry.Represents case where log file is missing.Represents case where the entry at pos is wrong.Datastructure which maintains the status of logchannels.Default FileChannel for bookie to read and write.A wrapper of FileChannel.AnEntryKeyrepresents an entry in a ledger, identified byledgerIdandentryId.An entry Key/Value.AnEntryLocationrepresents the location where an entry is stored.This is the basic entry log compactor to compact entry logs.An allocator pre-allocates entry log files.Records the total size, remaining size and the set of ledgers that comprise a entry log.RecyclableEntryLogMetadataclass.Map-store to store Entrylogger metadata.The EntryMemTable holds in-memory representation to the entries not-yet flushed.Entry skip list.EntryMemTableWithParallelFlusher.Exit code used to exit bookie server.An interface of the FileChannelProvider.This is the file handle for a ledger's index file that maps entry ids to location.Application for upgrading the bookkeeper filesystem between versions.This is the garbage collection thread status.This is the garbage collector interface, garbage collector implementers need to extends this class to remove the deleted ledgers.A interface used to define customised garbage cleaner.This is the garbage collector thread that runs in the background to remove any entry log files that no longer contains any active ledger.AIndexPersistenceMgris responsible for managing the persistence state for the index in a bookie.In-memory metadata-store to store entry-log metadata-map in memory-map.Interleave ledger storage.Scan all entries in the entry log and rebuild the index file for one ledger.Provide journal related management.For testability.Token which represents the need to force a write to the Journal.Filter to pickup journals.Scanner used to scan a journal.Journal Entry to Record.Listener for journal alive.Simple wrapper around FileChannel to add versioning information to the file.Compare EntryKey.A signal object is used for notifying the observers when theLastAddConfirmedis advanced.This class maps a ledger entry number into a location (entrylogid, offset) in an entry log file.Represents summary of ledger metadata.Specific exception to encode the case where the index is not present.Represents a page of the index.Iterable over index pages -- returns PageEntries rather than individual entries because getEntries() above needs to be able to throw an IOException.Implementation of LedgerCache interface.Implements a ledger inside a bookie.Implements a ledger inside a bookie.Implements a ledger inside a bookie.This class manages ledger directories used by the bookie.Listener for the disk check events will be notified from theLedgerDirsManagerwhenever disk full/failure detected.Indicates All configured ledger directories are full.Thread to monitor the disk space periodically.This is a page in the LedgerCache.Interface for getEntries to propagate entry, pos pairs.Interface for storing ledger data on persistent storage.Class for describing location of a generic inconsistency.Signals that a ledger is deleted by the garbage collection thread.StorageState flags.A factory that createsLedgerStorageby reflection.Legacy implementation of CookieValidation.Callback interface when state of ledger entry page changed.Special ensemble placement policy that always return local bookie.Journal stream position.Implements a read only bookie.Read Only Entry Logger.Provide a readonly file info.Garbage collector implementation using scan and compare.Stats associated with the consistency checker.Short Read Exception.SkipList allocation buffer to reduce memory fragment.The result of a single allocation.Flush entries from skip list.Strictly for testing.ASortedLedgerStorageis an extension ofInterleavedLedgerStorage.State management of Bookie, including register, turn bookie to w/r mode.ShutdownHandler used to shutdown bookie.SyncThread is a background thread which help checkpointing ledger storage when a checkpoint is requested.This class is used for compaction.An abstract class that would be extended to be the actual transactional phases for compaction.An interface for unclean shutdown detection.Used to determine if the prior shutdown was unclean or not.