Package org.apache.bookkeeper.client
package org.apache.bookkeeper.client
BookKeeper Client.
-
ClassDescriptionDefines all the callback interfaces for the async operations in bookkeeper client.Async Callback for adding entries to ledgers.Async Callback for adding entries to ledgers with latency information.Async Callback for updating LAC for ledgers.Async Callback for closing ledgers.Async Callback for creating ledgers.Async Callback for deleting ledgers.Async Callback for checking if a ledger is closed.Async Callback for opening ledgers.Async Callback for reading entries from ledgers.Async Callback for long polling read request.Async Callback for reading LAC for ledgers.Async Callback for recovering ledgers.Class the enumerates all the possible error conditions.Bookkeeper add entry quorum timeout exception.Bookkeeper bookie exception.Bookkeeper bookie handle not available exception.Bookkeeper client closed exception.Bookkeeper ledger in limbo and data may or may not exist.Bookkeeper digest match exception.Bookkeeper digest not initialized exception.Bookkeeper duplicate entry id exception.Bookkeeper illegal operation exception.Bookkeeper incorrect parameter exception.Bookkeeper interrupted exception.Bookkeeper ledger closed exception.Bookkeeper ledger exist exception.Bookkeeper ledger fenced exception.Bookkeeper ledger id overflow exception.Bookkeeper ledger recovery exception.Bookkeeper metadata serialization exception.Bookkeeper metadata version exception.Bookkeeper no such entry exception.Bookkeeper no such ledger exists exception.Bookkeeper no such ledger exists on metadata server exception.Bookkeeper not enough bookies exception.Bookkeeper protocol version exception.Bookkeeper quorum exception.Bookkeeper read exception.Bookkeeper replication exception.Bookkeeper security exception.Bookkeeper timeout exception.Bookkeeper too many requests exception.Bookkeeper unauthorized access exception.Bookkeeper unclosed fragment exception.Bookkeeper unexpected condition exception.Bookkeeper write exception.Bookkeeper write on readonly bookie exception.Legacy interface which holds constants for BookKeeper error codes.Metastore exception.Zookeeper exception.Resolve legacy style BookieIDs to Network addresses.A utility class to read
BookieInfoReader.BookieInfofrom bookies.A class represents the information (e.g.Tracks whether there is an execution in progress as well as whether another is pending.This interface returns heuristics used to determine the health of a Bookkeeper server for read ordering.Listener for the available bookies changes.Watch for Bookkeeper cluster status.This class is responsible for maintaining a consistent view of what bookies are available by reading Zookeeper (and setting watches on the bookie nodes).BookKeeper client.BookKeeper Client Builder to build client instances.There are 3 digest types that can be used for verification.Admin client for BookKeeper clusters.This is the class for getting the replication result.List of constants for defining client stats names.Collection of client objects used by LedgerHandle to interact with the outside world.Resolve BookieIDs to Network addresses.Default Ensemble Placement Policy, which picks bookies randomly.A default implementation ofSpeculativeRequestExecutionPolicy.This interface determines how entries are distributed among bookies.An ack set represents the set of bookies from which a response must be received so that an entry can be considered to be replicated on a quorum.Interface to keep track of which bookies in an ensemble, an action has been performed for.A write set represents the set of bookies to which a request will be written.DynamicWeightedRandomSelectionImpl class implements both getNextRandom overloaded methods.EnsemblePlacementPolicyencapsulates the algorithm that bookkeeper client uses to select a number of bookies from the cluster as an ensemble for storing entries.enum for PlacementPolicyAdherence.Result of a placement calculation against a placement policy.This represents a request to sync the ledger on every bookie.ITopologyAwareEnsemblePlacementPolicy<T extends Node>Interface for topology aware ensemble placement policy.Ensemble used to hold the result of an ensemble selected for placement.Predicate used when choosing an ensemble.A utility class to check the complete ledger and finds the UnderReplicated fragments if any.Encapsulates asynchronous ledger create operation.Encapsulates asynchronous ledger delete operation.Ledger entry.Represents the entries of a segment of a ledger which are stored on subset of bookies in the segments bookie ensemble.ReplicateType.This is the helper class for replicating the fragments from one bookie to another.Callback for recovery of a single ledger fragment.Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.Context objects for synchronous call to read last confirmed.Ledger Advanced handle extendsLedgerHandleto provide API to add entries with user supplied entryIds.Builder for building LedgerMetadata objects.This class encapsulates all the ledger metadata that is persistently stored in metadata store.Utilities for working with ledger metadata.Encapsulates the ledger open operation.This class encapsulated the ledger recovery operation.Mechanism to safely update the metadata of a ledger.This represents a pending add operation.This represents a pending ReadLac operation.Sequence of entries of a ledger that represents a pending read operation.This represents a pending WriteLac operation.A placement policy implementation use rack information for placing ensembles.Simple rackware ensemble placement policy.Notifier used by the RackawareEnsemblePlacementPolicy to get notified if a rack changes for a bookie.Long poll read operation.Wrapper to get all recovered data from the request.This class encapsulated the read last confirmed operation.Wrapper to get all recovered data from the request.Read only ledger handle.A placement policy use region information in the network topology for placing ensembles.A specificDistributionSchedulethat places entries in round-robin fashion.Define a policy for speculative request execution.Define an executor for issuing speculative requests.Utility for callbacks.Implements objects to help with the synchronization of asynchronous calls.Decorator for any existing dsn resolver.A predicate checking the rack coverage for write quorum inRoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.This op is try to read last confirmed without involving quorum coverage checking.Encapsulates updating the ledger metadata operation.A placement policy implementation use zone information for placing ensembles.Simple zoneaware ensemble placement policy.Zone and UpgradeDomain pair of a node.