| 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.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 |
Codes which represent the various
BKException types. |
| BookiesListener |
Listener for the the available bookies changes.
|
| BookKeeperClientStats |
List of constants for defining client stats names.
|
| 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.
|
| 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.
|
| PendingReadLacOp.LacCallback | |
| 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.WeightedObject |
| Class | Description |
|---|---|
| BookieInfoReader |
A utility class to read
BookieInfoReader.BookieInfo from bookies. |
| BookieInfoReader.BookieInfo |
A class represents the information (e.g.
|
| BookieWatcher |
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.
|
| BookKeeper.SyncOpenCallback | |
| BookKeeperAdmin |
Admin client for BookKeeper clusters
|
| BookKeeperAdmin.ReadMetadataCallback | |
| BookKeeperAdmin.ResultCallBack |
This is the class for getting the replication result
|
| BookKeeperAdmin.SyncObject | |
| CRC32DigestManager | |
| DefaultEnsemblePlacementPolicy |
Default Ensemble Placement Policy, which picks bookies randomly.
|
| DefaultSpeculativeRequestExecutionPolicy |
A default implementation of
SpeculativeRequestExecutionPolicy. |
| DigestManager |
This class takes an entry, attaches a digest to it and packages it with relevant
data so that it can be shipped to the bookie.
|
| DigestManager.RecoveryData | |
| ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl | |
| LedgerChecker |
A utility class to check the complete ledger and finds the UnderReplicated fragments if any.
|
| LedgerCreateOp |
Encapsulates asynchronous ledger create operation
|
| LedgerDeleteOp |
Encapsulates asynchronous ledger delete operation
|
| LedgerEntry |
Ledger entry.
|
| LedgerFragment |
Represents the entries of a segment of a ledger which are stored on a single
bookie 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.EnsembleInfo | |
| LedgerHandle.LastAddConfirmedCallback | |
| LedgerHandle.LastConfirmedCtx |
Context objects for synchronous call to read last confirmed.
|
| LedgerHandle.NoopCloseCallback | |
| LedgerHandle.SyncAddCallback | |
| LedgerHandle.SyncCloseCallback | |
| LedgerHandle.SyncReadCallback | |
| LedgerHandle.SyncReadLastConfirmedCallback | |
| LedgerHandleAdv |
Ledger Advanced handle extends
LedgerHandle to provide API to add entries with
user supplied entryIds. |
| LedgerHandleAdv.PendingOpsComparator | |
| LedgerMetadata |
This class encapsulates all the ledger metadata that is persistently stored
in metadata store.
|
| LedgerOpenOp |
Encapsulates the ledger open operation
|
| LedgerRecoveryOp |
This class encapsulated the ledger recovery operation.
|
| ListenerBasedPendingReadOp | |
| MacDigestManager |
A
SHA-1 based digest manager. |
| 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.
|
| RackawareEnsemblePlacementPolicyImpl.DefaultResolver | |
| 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. |
| SyncCounter |
Implements objects to help with the synchronization of asynchronous calls
|
| SynchCallbackUtils |
Utility for callbacks
|
| TopologyAwareEnsemblePlacementPolicy | |
| TopologyAwareEnsemblePlacementPolicy.BookieNode | |
| 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
|
| WeightedRandomSelection<T> |
| Enum | Description |
|---|---|
| BookieInfoReader.State |
Tracks whether there is an execution in progress as well as whether
another is pending.
|
| BookKeeper.DigestType |
There are 2 digest types that can be used for verification.
|
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.