Interface | Description |
---|---|
AsyncCallback |
Defines all the callback interfaces for the async operations in bookkeeper client.
|
AsyncCallback.AddCallback |
Async Callback for adding entries to ledgers.
|
AsyncCallback.AddCallbackWithLatency |
Async Callback for adding entries to ledgers with latency information.
|
AsyncCallback.AddLacCallback |
Async Callback for updating LAC for ledgers.
|
AsyncCallback.CloseCallback |
Async Callback for closing ledgers.
|
AsyncCallback.CreateCallback |
Async Callback for creating ledgers.
|
AsyncCallback.DeleteCallback |
Async Callback for deleting ledgers.
|
AsyncCallback.IsClosedCallback |
Async Callback for checking if a ledger is closed.
|
AsyncCallback.OpenCallback |
Async Callback for opening ledgers.
|
AsyncCallback.ReadCallback |
Async Callback for reading entries from ledgers.
|
AsyncCallback.ReadLastConfirmedAndEntryCallback |
Async Callback for long polling read request.
|
AsyncCallback.ReadLastConfirmedCallback |
Async Callback for reading LAC for ledgers.
|
AsyncCallback.RecoverCallback |
Async Callback for recovering ledgers.
|
BKException.Code |
Legacy interface which holds constants for BookKeeper error codes.
|
BookiesHealthInfo |
This interface returns heuristics used to determine the health of a Bookkeeper server for read
ordering.
|
BookiesListener |
Listener for the the available bookies changes.
|
BookieWatcher | |
BookKeeperClientStats |
List of constants for defining client stats names.
|
ClientContext |
Collection of client objects used by LedgerHandle to interact with
the outside world.
|
DistributionSchedule |
This interface determins how entries are distributed among bookies.
|
DistributionSchedule.AckSet |
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.
|
DistributionSchedule.QuorumCoverageSet |
Interface to keep track of which bookies in an ensemble, an action
has been performed for.
|
DistributionSchedule.WriteSet |
A write set represents the set of bookies to which
a request will be written.
|
EnsemblePlacementPolicy |
EnsemblePlacementPolicy encapsulates the algorithm that bookkeeper client uses to select a number of bookies
from the cluster as an ensemble for storing entries. |
ExplicitLacFlushPolicy | |
ITopologyAwareEnsemblePlacementPolicy<T extends org.apache.bookkeeper.net.Node> |
Interface for topology aware ensemble placement policy.
|
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T extends org.apache.bookkeeper.net.Node> |
Ensemble used to hold the result of an ensemble selected for placement.
|
ITopologyAwareEnsemblePlacementPolicy.Predicate<T extends org.apache.bookkeeper.net.Node> |
Predicate used when choosing an ensemble.
|
MetadataUpdateLoop.LocalValueUpdater | |
MetadataUpdateLoop.MetadataTransform | |
MetadataUpdateLoop.NeedsUpdatePredicate | |
PendingReadLacOp.LacCallback | |
RackChangeNotifier |
Notifier used by the RackawareEnsemblePlacementPolicy to get notified if a
rack changes for a bookie.
|
ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback |
Wrapper to get all recovered data from the request.
|
ReadLastConfirmedOp.LastConfirmedDataCallback |
Wrapper to get all recovered data from the request.
|
SpeculativeRequestExecutionPolicy |
Define a policy for speculative request execution.
|
SpeculativeRequestExecutor |
Define an executor for issuing speculative requests.
|
TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet | |
WeightedRandomSelection<T> | |
WeightedRandomSelection.WeightedObject |
Class | Description |
---|---|
BookieInfoReader |
A utility class to read
BookieInfoReader.BookieInfo from bookies. |
BookieInfoReader.BookieInfo |
A class represents the information (e.g.
|
BookieWatcherImpl |
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 |
BookKeeper client.
|
BookKeeper.Builder |
BookKeeper Client Builder to build client instances.
|
BookKeeperAdmin |
Admin client for BookKeeper clusters.
|
BookKeeperAdmin.ResultCallBack |
This is the class for getting the replication result.
|
BookKeeperAdmin.SyncObject | |
ClientInternalConf | |
DefaultEnsemblePlacementPolicy |
Default Ensemble Placement Policy, which picks bookies randomly.
|
DefaultSpeculativeRequestExecutionPolicy |
A default implementation of
SpeculativeRequestExecutionPolicy . |
DynamicWeightedRandomSelectionImpl<T> |
DynamicWeightedRandomSelectionImpl class implements both getNextRandom
overloaded methods.
|
EnsemblePlacementPolicy.PlacementResult<T> |
Result of a placement calculation against a placement policy.
|
EnsembleUtils | |
ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl | |
ForceLedgerOp |
This represents a request to sync the ledger on every bookie.
|
LedgerChecker |
A utility class to check the complete ledger and finds the UnderReplicated fragments if any.
|
LedgerCreateOp |
Encapsulates asynchronous ledger create operation.
|
LedgerCreateOp.CreateBuilderImpl | |
LedgerDeleteOp |
Encapsulates asynchronous ledger delete operation.
|
LedgerDeleteOp.DeleteBuilderImpl | |
LedgerEntry |
Ledger entry.
|
LedgerFragment |
Represents the entries of a segment of a ledger which are stored on subset of
bookies in the segments bookie ensemble.
|
LedgerFragmentReplicator |
This is the helper class for replicating the fragments from one bookie to
another.
|
LedgerFragmentReplicator.SingleFragmentCallback |
Callback for recovery of a single ledger fragment.
|
LedgerHandle |
Ledger handle contains ledger metadata and is used to access the read and
write operations to a ledger.
|
LedgerHandle.LastConfirmedCtx |
Context objects for synchronous call to read last confirmed.
|
LedgerHandle.NoopCloseCallback | |
LedgerHandleAdv |
Ledger Advanced handle extends
LedgerHandle to provide API to add entries with
user supplied entryIds. |
LedgerHandleAdv.PendingOpsComparator | |
LedgerMetadataBuilder |
Builder for building LedgerMetadata objects.
|
LedgerMetadataImpl |
This class encapsulates all the ledger metadata that is persistently stored
in metadata store.
|
LedgerMetadataUtils |
Utilities for working with ledger metadata.
|
LedgerOpenOp |
Encapsulates the ledger open operation.
|
LedgerOpenOp.OpenBuilderImpl | |
LedgerRecoveryOp |
This class encapsulated the ledger recovery operation.
|
ListenerBasedPendingReadOp | |
MetadataUpdateLoop |
Mechanism to safely update the metadata of a ledger.
|
PendingAddOp |
This represents a pending add operation.
|
PendingReadLacOp |
This represents a pending ReadLac operation.
|
PendingReadOp |
Sequence of entries of a ledger that represents a pending read operation.
|
PendingWriteLacOp |
This represents a pending WriteLac operation.
|
RackawareEnsemblePlacementPolicy |
A placement policy implementation use rack information for placing ensembles.
|
RackawareEnsemblePlacementPolicyImpl |
Simple rackware ensemble placement policy.
|
ReadLastConfirmedAndEntryOp |
Long poll read operation.
|
ReadLastConfirmedOp |
This class encapsulated the read last confirmed operation.
|
ReadOnlyLedgerHandle |
Read only ledger handle.
|
RegionAwareEnsemblePlacementPolicy |
A placement policy use region information in the network topology for placing ensembles.
|
RoundRobinDistributionSchedule |
A specific
DistributionSchedule that places entries in round-robin
fashion. |
SyncCallbackUtils |
Utility for callbacks.
|
SyncCallbackUtils.FutureReadLastConfirmed | |
SyncCallbackUtils.FutureReadLastConfirmedAndEntry | |
SyncCallbackUtils.LastAddConfirmedCallback | |
SyncCallbackUtils.SyncAddCallback | |
SyncCallbackUtils.SyncCloseCallback | |
SyncCallbackUtils.SyncCreateAdvCallback | |
SyncCallbackUtils.SyncCreateCallback | |
SyncCallbackUtils.SyncDeleteCallback | |
SyncCallbackUtils.SyncOpenCallback | |
SyncCallbackUtils.SyncReadCallback | |
SyncCallbackUtils.SyncReadLastConfirmedCallback | |
SyncCounter |
Implements objects to help with the synchronization of asynchronous calls.
|
TopologyAwareEnsemblePlacementPolicy | |
TopologyAwareEnsemblePlacementPolicy.DefaultResolver | |
TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator |
Decorator for any existing dsn resolver.
|
TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints | |
TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble |
A predicate checking the rack coverage for write quorum in
RoundRobinDistributionSchedule ,
which ensures that a write quorum should be covered by at least two racks. |
TopologyAwareEnsemblePlacementPolicy.TruePredicate | |
TryReadLastConfirmedOp |
This op is try to read last confirmed without involving quorum coverage checking.
|
UpdateLedgerOp |
Encapsulates updating the ledger metadata operation.
|
WeightedRandomSelectionImpl<T> | |
ZoneawareEnsemblePlacementPolicy |
A placement policy implementation use zone information for placing ensembles.
|
ZoneawareEnsemblePlacementPolicyImpl |
Simple zoneaware ensemble placement policy.
|
ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation |
Zone and UpgradeDomain pair of a node.
|
Enum | Description |
---|---|
BookieInfoReader.State |
Tracks whether there is an execution in progress as well as whether
another is pending.
|
BookKeeper.DigestType |
There are 3 digest types that can be used for verification.
|
EnsemblePlacementPolicy.PlacementPolicyAdherence |
enum for PlacementPolicyAdherence.
|
Exception | Description |
---|---|
BKException |
Class the enumerates all the possible error conditions.
|
BKException.BKAddEntryQuorumTimeoutException |
Bookkeeper add entry quorum timeout exception.
|
BKException.BKBookieException |
Bookkeeper bookie exception.
|
BKException.BKBookieHandleNotAvailableException |
Bookkeeper bookie handle not available exception.
|
BKException.BKClientClosedException |
Bookkeeper client closed exception.
|
BKException.BKDigestMatchException |
Bookkeeper digest match exception.
|
BKException.BKDigestNotInitializedException |
Bookkeeper digest not initialized exception.
|
BKException.BKDuplicateEntryIdException |
Bookkeeper duplicate entry id exception.
|
BKException.BKIllegalOpException |
Bookkeeper illegal operation exception.
|
BKException.BKIncorrectParameterException |
Bookkeeper incorrect parameter exception.
|
BKException.BKInterruptedException |
Bookkeeper interrupted exception.
|
BKException.BKLedgerClosedException |
Bookkeeper ledger closed exception.
|
BKException.BKLedgerExistException |
Bookkeeper ledger exist exception.
|
BKException.BKLedgerFencedException |
Bookkeeper ledger fenced exception.
|
BKException.BKLedgerIdOverflowException |
Bookkeeper ledger id overflow exception.
|
BKException.BKLedgerRecoveryException |
Bookkeeper ledger recovery exception.
|
BKException.BKMetadataSerializationException |
Bookkeeper metadata serialization exception.
|
BKException.BKMetadataVersionException |
Bookkeeper metadata version exception.
|
BKException.BKNoSuchEntryException |
Bookkeeper no such entry exception.
|
BKException.BKNoSuchLedgerExistsException |
Bookkeeper no such ledger exists exception.
|
BKException.BKNoSuchLedgerExistsOnMetadataServerException |
Bookkeeper no such ledger exists on metadata server exception.
|
BKException.BKNotEnoughBookiesException |
Bookkeeper not enough bookies exception.
|
BKException.BKProtocolVersionException |
Bookkeeper protocol version exception.
|
BKException.BKQuorumException |
Bookkeeper quorum exception.
|
BKException.BKReadException |
Bookkeeper read exception.
|
BKException.BKReplicationException |
Bookkeeper replication exception.
|
BKException.BKSecurityException |
Bookkeeper security exception.
|
BKException.BKTimeoutException |
Bookkeeper timeout exception.
|
BKException.BKTooManyRequestsException |
Bookkeeper too many requests exception.
|
BKException.BKUnauthorizedAccessException |
Bookkeeper unauthorized access exception.
|
BKException.BKUnclosedFragmentException |
Bookkeeper unclosed fragment exception.
|
BKException.BKUnexpectedConditionException |
Bookkeeper unexpected condition exception.
|
BKException.BKWriteException |
Bookkeeper write exception.
|
BKException.BKWriteOnReadOnlyBookieException |
Bookkeeper write on readonly bookie exception.
|
BKException.MetaStoreException |
Metastore exception.
|
BKException.ZKException |
Zookeeper exception.
|
LedgerChecker.InvalidFragmentException |
Copyright © 2011–2020 The Apache Software Foundation. All rights reserved.