A B C D E F G H I J K L M N O P Q R S T U V W Z 
All Classes All Packages

A

AbstractConfiguration<T extends AbstractConfiguration> - Class in org.apache.bookkeeper.conf
Abstract configuration.
AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration
 
ackQuorumSize - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ackQuorumSize - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
ackSet - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
ackSet - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
ackSet - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
acquire(int) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler
 
acquirePermit() - Method in class org.apache.bookkeeper.client.LedgerChecker
Acquires a permit from permit manager, blocking until all are available.
ACTIVE_NON_TLS_CHANNEL_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ACTIVE_TLS_CHANNEL_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ADD_ENTRY_QUORUM_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ADD_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ADD_OP_OUTSTANDING - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ADD_OP_UR - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
addBookie(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.QuorumCoverageSet
Add a bookie to the result set.
addBookie(BookieNode) - Method in interface org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet
 
addBookie(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
 
addBookie(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
addComplete(int, LedgerHandle, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback
Callback to implement if latency information is not desired.
addComplete(int, LedgerHandle, long, Object) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
addComplete(int, LedgerHandle, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncAddCallback
Implementation of callback interface for synchronous read method.
addCompleteWithLatency(int, LedgerHandle, long, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback
Callback declaration which additionally passes quorum write complete latency.
addCompleteWithLatency(int, LedgerHandle, long, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallbackWithLatency
Callback declaration which additionally passes quorum write complete latency.
addCount(long) - Method in interface org.apache.bookkeeper.stats.Counter
Add delta to the value associated with this stat.
addCount(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
addCount(long) - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
addCount(long) - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
addCount(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
addDefaultFaultDomainBookies(Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
addDefaultRackBookiesIfMinNumRacksIsEnforced(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
addEntry(byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addEntry(byte[]) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
addEntry(long, byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addEntry(long, byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry synchronously to an open ledger.
addEntry(long, byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addEntry(long, byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry synchronously to an open ledger.
AddEntryQuorumTimeoutException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Add entry operation timeouts on waiting quorum responses.
addEntryQuorumTimeoutNanos - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
addEntrySuccessBookies - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
addLacComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddLacCallback
Callback declaration.
addLacComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.LastAddConfirmedCallback
Implementation of callback interface for synchronous read method.
addLatency(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.Counter
An operation succeeded with the given eventLatency.
addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
When counter is used to count time.
addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
addMissingIndices(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
If we want a write set to cover all bookies in an ensemble of size X, then all of the index from 0..X must exist in the write set.
addNode(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
 
addNode(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
addNode(T) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Ensemble
Append the new bookie node to the ensemble only if the ensemble doesnt already contain the same bookie.
address2NodePlacement - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
address2Region - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
addToLength(long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add to the length of the ledger in bytes.
administrativeOpen - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
adv - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ADVERTISED_ADDRESS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
alertStatName - Variable in class org.apache.bookkeeper.stats.AlertStatsLogger
 
AlertStatsLogger - Class in org.apache.bookkeeper.stats
This class is used to raise alert when we detect an event that should never happen in production.
AlertStatsLogger(StatsLogger, String) - Constructor for class org.apache.bookkeeper.stats.AlertStatsLogger
 
AlertStatsLogger(StatsLogger, String, String) - Constructor for class org.apache.bookkeeper.stats.AlertStatsLogger
 
allocationToRacksOrRegions - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
 
allocator - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
allocator(ByteBufAllocator) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Configure the bookkeeper client with a provided ByteBufAllocator.
allocator(ByteBufAllocator) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
Configure the bookkeeper client with a provided ByteBufAllocator.
allocator(ByteBufAllocator) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
ALLOCATOR_LEAK_DETECTION_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ALLOCATOR_OOM_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ALLOCATOR_POOLING_CONCURRENCY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ALLOCATOR_POOLING_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ALLOW_EPHEMERAL_PORTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ALLOW_LOOPBACK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ALLOW_MULTIPLEDIRS_UNDER_SAME_DISKPARTITION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ALLOW_SHADED_LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ALLOW_STORAGE_EXPANSION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
allowFailFast - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
allowFailFast - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
allowFailFastOnUnwritableChannel() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
allowFailFastOnUnwritableChannel() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
append(byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add an entry synchronously to an open ledger.
append(byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add an entry synchronously to an open ledger.
append(ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add entry synchronously to an open ledger.
append(ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add entry synchronously to an open ledger.
appendAsync(byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add an entry asynchronously to an open ledger.
appendAsync(byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add an entry asynchronously to an open ledger.
appendAsync(ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add entry asynchronously to an open ledger.
appendAsync(ByteBuf) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger.
appendAsync(ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Add entry asynchronously to an open ledger.
apply(BookieNode) - Method in interface org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet
 
apply(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
 
apply(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
apply(BookieNode, ITopologyAwareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.TruePredicate
 
apply(BookieNode, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
apply(T, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Predicate
 
areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Returns true if the bookies that have acknowledged a write adhere to the minimum fault domains as defined in the placement policy in use.
areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
areEntriesOfLedgerStoredInTheBookie(long, BookieId, LedgerMetadata) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
areEntriesOfLedgerStoredInTheBookie(long, BookieId, LedgerManager) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
asJson() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
returns the string representation of json format of this config.
asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
LedgerHandleAdv will not allow addEntry without providing an entryId.
asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger.
asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(long, byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger.
asyncAddEntry(long, byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry asynchronously to an open ledger.
asyncAddEntry(long, ByteBuf, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(long, ByteBuf, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Add entry asynchronously to an open ledger, using an offset and range.
asyncAddEntry(ByteBuf, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
asyncAddEntry(ByteBuf, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
LedgerHandleAdv will not allow addEntry without providing an entryId.
AsyncCallback - Interface in org.apache.bookkeeper.client
Defines all the callback interfaces for the async operations in bookkeeper client.
AsyncCallback.AddCallback - Interface in org.apache.bookkeeper.client
Async Callback for adding entries to ledgers.
AsyncCallback.AddCallbackWithLatency - Interface in org.apache.bookkeeper.client
Async Callback for adding entries to ledgers with latency information.
AsyncCallback.AddLacCallback - Interface in org.apache.bookkeeper.client
Async Callback for updating LAC for ledgers.
AsyncCallback.CloseCallback - Interface in org.apache.bookkeeper.client
Async Callback for closing ledgers.
AsyncCallback.CreateCallback - Interface in org.apache.bookkeeper.client
Async Callback for creating ledgers.
AsyncCallback.DeleteCallback - Interface in org.apache.bookkeeper.client
Async Callback for deleting ledgers.
AsyncCallback.IsClosedCallback - Interface in org.apache.bookkeeper.client
Async Callback for checking if a ledger is closed.
AsyncCallback.OpenCallback - Interface in org.apache.bookkeeper.client
Async Callback for opening ledgers.
AsyncCallback.ReadCallback - Interface in org.apache.bookkeeper.client
Async Callback for reading entries from ledgers.
AsyncCallback.ReadLastConfirmedAndEntryCallback - Interface in org.apache.bookkeeper.client
Async Callback for long polling read request.
AsyncCallback.ReadLastConfirmedCallback - Interface in org.apache.bookkeeper.client
Async Callback for reading LAC for ledgers.
AsyncCallback.RecoverCallback - Interface in org.apache.bookkeeper.client
Async Callback for recovering ledgers.
asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous close, any adds in flight will return errors.
asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
asyncCloseInternal(AsyncCallback.CloseCallback, Object, int) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
asyncCreateLedger(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger asynchronously.
asyncCreateLedger(int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger asynchronously.
asyncCreateLedgerAdv(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger asynchronously and returns LedgerHandleAdv which can accept entryId.
asyncCreateLedgerAdv(long, int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Asynchronously creates a new ledger using the interface which accepts a ledgerId as input.
asyncDeleteLedger(long, AsyncCallback.DeleteCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Deletes a ledger asynchronously.
asyncExplicitLacFlush(long) - Method in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
Make a LastAddUpdate request.
asyncGetLedgersContainBookies(Set<BookieId>, BookkeeperInternalCallbacks.GenericCallback<SortedMap<Long, LedgerMetadata>>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
asyncGetListOfEntriesOfLedger(BookieId, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.
asyncIsClosed(long, AsyncCallback.IsClosedCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Check asynchronously whether the ledger with identifier lId has been closed.
asyncOpenLedger(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator.
asyncOpenLedger(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Open existing ledger asynchronously for reading.
asyncOpenLedgerNoRecovery(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator without recovering the ledger.
asyncOpenLedgerNoRecovery(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Open existing ledger asynchronously for reading, but it does not try to recover the ledger if it is not yet closed.
asyncReadEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries asynchronously.
asyncReadEntriesInternal(long, long, AsyncCallback.ReadCallback, Object, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
asyncReadExplicitLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the explicit last add confirmed from a quorum of bookies.
asyncReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
asyncReadLastConfirmedAndEntry(long, long, boolean, AsyncCallback.ReadLastConfirmedAndEntryCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous read next entry and the latest last add confirmed.
asyncReadLastEntry(AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
asyncReadLastEntry(AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
asyncReadUnconfirmedEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.
asyncRecoverBookieData(long, Set<BookieId>, boolean, boolean, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Recover a specific ledger.
asyncRecoverBookieData(Set<BookieId>, boolean, boolean, boolean, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
asyncRecoverBookieData(Set<BookieId>, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
asyncRecoverBookieData(BookieId, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.
asyncRecoveryAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Make a recovery add entry request.
asyncTryReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
AUDITOR_ACQUIRE_CONCURRENT_OPEN_LEDGER_OPERATIONS_TIMEOUT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_LEDGER_VERIFICATION_PERCENTAGE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_MAX_NUMBER_OF_CONCURRENT_OPEN_LEDGER_OPERATIONS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_PERIODIC_BOOKIE_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_PERIODIC_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_PERIODIC_PLACEMENT_POLICY_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_REPLICAS_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUTHORIZED_ROLES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUTO_RECOVERY_DAEMON_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
availability - Variable in class org.apache.bookkeeper.feature.FixedValueFeature
 
availability - Variable in class org.apache.bookkeeper.feature.SettableFeatureProvider
 
availability() - Method in interface org.apache.bookkeeper.feature.Feature
Returns the availability of this feature, an integer between 0 and 100.
availability() - Method in class org.apache.bookkeeper.feature.FixedValueFeature
 
AVAILABLE_NODE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
availableBookiesChanged() - Method in interface org.apache.bookkeeper.client.BookiesListener
Callback method triggered when the list of available bookies are changed.
availableBookiesChanged(Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookieInfoReader
 

B

backoffMultiplier - Variable in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy
 
basename - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
bk - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
bk - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
bk - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
BKAddEntryQuorumTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKAddEntryQuorumTimeoutException
 
BKBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieException
 
BKBookieHandleNotAvailableException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieHandleNotAvailableException
 
BKClientClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKClientClosedException
 
BKDataUnknownException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDataUnknownException
 
BKDigestMatchException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestMatchException
 
BKDigestNotInitializedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestNotInitializedException
 
BKDuplicateEntryIdException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDuplicateEntryIdException
 
BKException - Exception in org.apache.bookkeeper.client.api
Super class for all errors which occur using BookKeeper client.
BKException - Exception in org.apache.bookkeeper.client
Class the enumerates all the possible error conditions.
BKException(int) - Constructor for exception org.apache.bookkeeper.client.api.BKException
Create a new exception.
BKException(int) - Constructor for exception org.apache.bookkeeper.client.BKException
 
BKException(int, Throwable) - Constructor for exception org.apache.bookkeeper.client.api.BKException
Create a new exception with the cause.
BKException(int, Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException
 
BKException.BKAddEntryQuorumTimeoutException - Exception in org.apache.bookkeeper.client
Bookkeeper add entry quorum timeout exception.
BKException.BKBookieException - Exception in org.apache.bookkeeper.client
Bookkeeper bookie exception.
BKException.BKBookieHandleNotAvailableException - Exception in org.apache.bookkeeper.client
Bookkeeper bookie handle not available exception.
BKException.BKClientClosedException - Exception in org.apache.bookkeeper.client
Bookkeeper client closed exception.
BKException.BKDataUnknownException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger in limbo and data may or may not exist.
BKException.BKDigestMatchException - Exception in org.apache.bookkeeper.client
Bookkeeper digest match exception.
BKException.BKDigestNotInitializedException - Exception in org.apache.bookkeeper.client
Bookkeeper digest not initialized exception.
BKException.BKDuplicateEntryIdException - Exception in org.apache.bookkeeper.client
Bookkeeper duplicate entry id exception.
BKException.BKIllegalOpException - Exception in org.apache.bookkeeper.client
Bookkeeper illegal operation exception.
BKException.BKIncorrectParameterException - Exception in org.apache.bookkeeper.client
Bookkeeper incorrect parameter exception.
BKException.BKInterruptedException - Exception in org.apache.bookkeeper.client
Bookkeeper interrupted exception.
BKException.BKLedgerClosedException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger closed exception.
BKException.BKLedgerExistException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger exist exception.
BKException.BKLedgerFencedException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger fenced exception.
BKException.BKLedgerIdOverflowException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger id overflow exception.
BKException.BKLedgerRecoveryException - Exception in org.apache.bookkeeper.client
Bookkeeper ledger recovery exception.
BKException.BKMetadataSerializationException - Exception in org.apache.bookkeeper.client
Bookkeeper metadata serialization exception.
BKException.BKMetadataVersionException - Exception in org.apache.bookkeeper.client
Bookkeeper metadata version exception.
BKException.BKNoSuchEntryException - Exception in org.apache.bookkeeper.client
Bookkeeper no such entry exception.
BKException.BKNoSuchLedgerExistsException - Exception in org.apache.bookkeeper.client
Bookkeeper no such ledger exists exception.
BKException.BKNoSuchLedgerExistsOnMetadataServerException - Exception in org.apache.bookkeeper.client
Bookkeeper no such ledger exists on metadata server exception.
BKException.BKNotEnoughBookiesException - Exception in org.apache.bookkeeper.client
Bookkeeper not enough bookies exception.
BKException.BKProtocolVersionException - Exception in org.apache.bookkeeper.client
Bookkeeper protocol version exception.
BKException.BKQuorumException - Exception in org.apache.bookkeeper.client
Bookkeeper quorum exception.
BKException.BKReadException - Exception in org.apache.bookkeeper.client
Bookkeeper read exception.
BKException.BKReplicationException - Exception in org.apache.bookkeeper.client
Bookkeeper replication exception.
BKException.BKSecurityException - Exception in org.apache.bookkeeper.client
Bookkeeper security exception.
BKException.BKTimeoutException - Exception in org.apache.bookkeeper.client
Bookkeeper timeout exception.
BKException.BKTooManyRequestsException - Exception in org.apache.bookkeeper.client
Bookkeeper too many requests exception.
BKException.BKUnauthorizedAccessException - Exception in org.apache.bookkeeper.client
Bookkeeper unauthorized access exception.
BKException.BKUnclosedFragmentException - Exception in org.apache.bookkeeper.client
Bookkeeper unclosed fragment exception.
BKException.BKUnexpectedConditionException - Exception in org.apache.bookkeeper.client
Bookkeeper unexpected condition exception.
BKException.BKWriteException - Exception in org.apache.bookkeeper.client
Bookkeeper write exception.
BKException.BKWriteOnReadOnlyBookieException - Exception in org.apache.bookkeeper.client
Bookkeeper write on readonly bookie exception.
BKException.Code - Interface in org.apache.bookkeeper.client.api
Codes which represent the various exception types.
BKException.Code - Interface in org.apache.bookkeeper.client
Legacy interface which holds constants for BookKeeper error codes.
BKException.MetaStoreException - Exception in org.apache.bookkeeper.client
Metastore exception.
BKException.ZKException - Exception in org.apache.bookkeeper.client
Zookeeper exception.
BKIllegalOpException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIllegalOpException
 
BKIncorrectParameterException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIncorrectParameterException
 
BKInterruptedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKInterruptedException
 
BKLedgerClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerClosedException
 
BKLedgerExistException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerExistException
 
BKLedgerFencedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerFencedException
 
BKLedgerIdOverflowException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerIdOverflowException
 
BKLedgerRecoveryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerRecoveryException
 
BKMetadataSerializationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataSerializationException
 
BKMetadataSerializationException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataSerializationException
 
BKMetadataVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataVersionException
 
BKNoSuchEntryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchEntryException
 
BKNoSuchLedgerExistsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsException
 
BKNoSuchLedgerExistsOnMetadataServerException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsOnMetadataServerException
 
BKNotEnoughBookiesException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException
 
BKNotEnoughBookiesException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException
 
BKProtocolVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKProtocolVersionException
 
BKQuorumException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKQuorumException
 
BKReadException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReadException
 
BKReplicationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReplicationException
 
BKSecurityException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKSecurityException
 
BKTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKTimeoutException
 
BKTooManyRequestsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKTooManyRequestsException
 
BKUnauthorizedAccessException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnauthorizedAccessException
 
BKUnclosedFragmentException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnclosedFragmentException
 
BKUnexpectedConditionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnexpectedConditionException
 
BKWriteException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteException
 
BKWriteOnReadOnlyBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteOnReadOnlyBookieException
 
block(int) - Method in class org.apache.bookkeeper.client.SyncCounter
 
BOOKIE_ADDRESS_RESOLVER_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BOOKIE_ERROR_THRESHOLD_PER_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_FAILURE_HISTORY_EXPIRATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_HEALTH_CHECK_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_HEALTH_CHECK_INTERVAL_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_ID - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BOOKIE_LABEL - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
BOOKIE_MAX_MULTIPLE_FOR_WEIGHTED_PLACEMENT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BOOKIE_QUARANTINE_RATIO - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_QUARANTINE_TIME_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
bookieAddressResolver - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
BookieAddressResolverDisabled - Class in org.apache.bookkeeper.client
Resolve legacy style BookieIDs to Network addresses.
BookieAddressResolverDisabled() - Constructor for class org.apache.bookkeeper.client.BookieAddressResolverDisabled
 
bookieClient - Variable in class org.apache.bookkeeper.client.BookKeeper
 
bookieClient - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
bookieClient - Variable in class org.apache.bookkeeper.client.LedgerChecker
 
bookieClient - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
bookieClient - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
bookieFailureHistory - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
bookieFailureHistoryExpirationMSec - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Bookies are not available.
BookieInfo() - Constructor for class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo
 
BookieInfo(long, long) - Constructor for class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo
 
bookieInfoMap - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
bookieInfoReader - Variable in class org.apache.bookkeeper.client.BookKeeper
 
BookieInfoReader - Class in org.apache.bookkeeper.client
A utility class to read BookieInfoReader.BookieInfo from bookies.
BookieInfoReader(BookKeeper, ClientConfiguration, ScheduledExecutorService) - Constructor for class org.apache.bookkeeper.client.BookieInfoReader
 
BookieInfoReader.BookieInfo - Class in org.apache.bookkeeper.client
A class represents the information (e.g.
BookieInfoReader.State - Enum in org.apache.bookkeeper.client
Tracks whether there is an execution in progress as well as whether another is pending.
bookieInfoScheduler - Variable in class org.apache.bookkeeper.client.BookKeeper
 
bookiesHealthInfo - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
BookiesHealthInfo - Interface in org.apache.bookkeeper.client
This interface returns heuristics used to determine the health of a Bookkeeper server for read ordering.
bookiesJoinedCounter - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
bookiesLeftCounter - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
BookiesListener - Interface in org.apache.bookkeeper.client
Listener for the available bookies changes.
bookieWatcher - Variable in class org.apache.bookkeeper.client.BookKeeper
 
bookieWatcher - Variable in class org.apache.bookkeeper.client.LedgerChecker
 
BookieWatcher - Interface in org.apache.bookkeeper.client
Watch for Bookkeeper cluster status.
BookieWatcherImpl - Class in org.apache.bookkeeper.client
This class is responsible for maintaining a consistent view of what bookies are available by reading Zookeeper (and setting watches on the bookie nodes).
BookieWatcherImpl(ClientConfiguration, EnsemblePlacementPolicy, RegistrationClient, BookieAddressResolver, StatsLogger) - Constructor for class org.apache.bookkeeper.client.BookieWatcherImpl
 
BookKeeper - Class in org.apache.bookkeeper.client
BookKeeper client.
BookKeeper - Interface in org.apache.bookkeeper.client.api
This is the entry point for BookKeeper client side API.
BookKeeper() - Constructor for class org.apache.bookkeeper.client.BookKeeper
Allow to extend BookKeeper for mocking in unit tests.
BookKeeper(String) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client.
BookKeeper(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client using a configuration object.
BookKeeper(ClientConfiguration, ZooKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.
BookKeeper(ClientConfiguration, ZooKeeper, EventLoopGroup) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client and client event loop group instead of instantiating those.
BookKeeper(ClientConfiguration, ZooKeeper, EventLoopGroup, ByteBufAllocator, StatsLogger, DNSToSwitchMapping, HashedWheelTimer, FeatureProvider) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Constructor for use with the builder.
BookKeeper.Builder - Class in org.apache.bookkeeper.client
BookKeeper Client Builder to build client instances.
BookKeeper.DigestType - Enum in org.apache.bookkeeper.client
There are 3 digest types that can be used for verification.
BookKeeperAdmin - Class in org.apache.bookkeeper.client
Admin client for BookKeeper clusters.
BookKeeperAdmin(String) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(BookKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
 
BookKeeperAdmin(BookKeeper, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
 
BookKeeperAdmin(BookKeeper, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a BookKeeper instance .
BookKeeperAdmin(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin.LedgerEntriesIterable - Class in org.apache.bookkeeper.client
 
BookKeeperAdmin.LedgerEntriesIterator - Class in org.apache.bookkeeper.client
 
BookKeeperAdmin.ResultCallBack - Class in org.apache.bookkeeper.client
This is the class for getting the replication result.
BookKeeperAdmin.SyncObject - Class in org.apache.bookkeeper.client
 
BookKeeperBuilder - Interface in org.apache.bookkeeper.client.api
BookKeeper Client Builder to build client instances.
BookKeeperBuilderImpl - Class in org.apache.bookkeeper.client.impl
Internal builder for BookKeeper client.
BookKeeperBuilderImpl(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
BookKeeperClientStats - Interface in org.apache.bookkeeper.client
List of constants for defining client stats names.
BookKeeperClientStatsImpl - Class in org.apache.bookkeeper.client.impl
The default implementation of BookKeeperClientStats.
BookKeeperClientStatsImpl(StatsLogger) - Constructor for class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
build() - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Start and initialize a new BookKeeper client.
build() - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 
build() - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
build() - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
Builder(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper.Builder
 
BYTEBUF_ALLOCATOR_SIZE_INITIAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BYTEBUF_ALLOCATOR_SIZE_MAX - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BYTEBUF_ALLOCATOR_SIZE_MIN - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

C

CacheableFeatureProvider<T extends Feature> - Class in org.apache.bookkeeper.feature
Cacheable Feature Provider.
CacheableFeatureProvider(String) - Constructor for class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
CachingStatsLogger - Class in org.apache.bookkeeper.stats
A StatsLogger that caches the stats objects created by other StatsLogger.
CachingStatsLogger(StatsLogger) - Constructor for class org.apache.bookkeeper.stats.CachingStatsLogger
 
CachingStatsProvider - Class in org.apache.bookkeeper.stats
A CachingStatsProvider adds the caching functionality to an existing StatsProvider.
CachingStatsProvider(StatsProvider) - Constructor for class org.apache.bookkeeper.stats.CachingStatsProvider
 
callbackTriggered - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
cancelSpeculativeTask(boolean) - Method in class org.apache.bookkeeper.client.PendingReadOp
 
cancelSpeculativeTask(boolean) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
canEqual(Object) - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
canEqual(Object) - Method in class org.apache.bookkeeper.stats.otel.ScopeContext
 
category() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The name of the category to group stats together.
CATEGORY_CLIENT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
cb - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
cb - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
cb - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
cb - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
cb - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
cb - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
cb - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
cb - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
changingEnsemble - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
CHANNEL_ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_FORCE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_READ_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_START_TLS_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_ADD - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_FORCE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_READ - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_READ_LAC - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_START_TLS_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_WRITE_LAC - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_WRITE_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
checkCovered() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.QuorumCoverageSet
check if all quorum in the set have had the action performed for it.
checkForFaultyBookies() - Method in class org.apache.bookkeeper.client.BookKeeper
 
checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>) - Method in class org.apache.bookkeeper.client.LedgerChecker
Check that all the fragments in the passed in ledger, and report those which are missing.
checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>, long) - Method in class org.apache.bookkeeper.client.LedgerChecker
 
chosenNodes - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
clear() - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
clear() - Method in interface org.apache.bookkeeper.stats.Counter
Clear this stat.
clear() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
clear() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
clear() - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
Clear stats for this operation.
clear() - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
clear() - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
clear() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
clear() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
clear() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger
 
clear() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
clear() - Static method in class org.apache.bookkeeper.stats.ThreadRegistry
 
CLIENT_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_CHANNEL_WRITE_WAIT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CLIENT_CONNECT_BOOKIE_UNAVAILABLE_LOG_THROTTLING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_CONNECT_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_CONNECT_TIMER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CLIENT_RECEIVEBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_ROLE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_ROLE_STANDARD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
This client will act as a standard client.
CLIENT_ROLE_SYSTEM - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
This client will act as a system client, like the Auditor.
CLIENT_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CLIENT_SENDBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_SOCK_KEEPALIVE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_TCP_USER_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_TLS_KEYSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_KEYSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_KEYSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ClientClosedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Executing operations on a closed client.
ClientConfiguration - Class in org.apache.bookkeeper.conf
Configuration settings for client side.
ClientConfiguration() - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a default client-side configuration.
ClientConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a client-side configuration using a base configuration.
ClientContext - Interface in org.apache.bookkeeper.client
Collection of client objects used by LedgerHandle to interact with the outside world.
clientCtx - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
clientCtx - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
clientCtx - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
ClientInternalConf - Class in org.apache.bookkeeper.client
 
clientStats - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
close() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Close the client and release every resource.
close() - Method in interface org.apache.bookkeeper.client.api.Handle
Close this handle synchronously.
close() - Method in interface org.apache.bookkeeper.client.api.LastConfirmedAndEntry
close() - Method in interface org.apache.bookkeeper.client.api.LedgerEntries
Close to release the resources held by this instance.
close() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
close() - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Synchronous close the write handle, any adds in flight will return errors.
close() - Method in class org.apache.bookkeeper.client.BookKeeper
Shuts down client.
close() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Gracefully release resources that this client uses.
close() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
close() - Method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl
 
close() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
close() - Method in class org.apache.bookkeeper.client.LedgerHandle
Synchronous close the write handle, any adds in flight will return errors.
close() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
close() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
close() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
CLOSE_CHANNEL_ON_RESPONSE_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
closeAsync() - Method in interface org.apache.bookkeeper.client.api.Handle
Asynchronous close the handle.
closeAsync() - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Asynchronous close the write handle, any adds in flight will return errors.
closeAsync() - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous close the write handle, any adds in flight will return errors.
closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback
Callback definition.
closeComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback
 
closeComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCloseCallback
Close callback method.
closed - Variable in class org.apache.bookkeeper.client.BookKeeper
 
CLOSED - org.apache.bookkeeper.client.api.LedgerMetadata.State
The ledger is closed.
closeLock - Variable in class org.apache.bookkeeper.client.BookKeeper
 
closeRecovered() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
coarse - org.apache.bookkeeper.stats.codahale.FastTimer.Buckets
 
CodahaleMetricsProvider - Class in org.apache.bookkeeper.stats.codahale
A StatsProvider implemented based on Codahale metrics library.
CodahaleMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
CodahaleOpStatsLogger - Class in org.apache.bookkeeper.stats.codahale
 
CodahaleOpStatsLogger(Timer, Timer) - Constructor for class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
CodahaleStatsLogger - Class in org.apache.bookkeeper.stats.codahale
A StatsLogger implemented based on Codahale metrics library.
CodahaleStatsLogger(MetricRegistry, String) - Constructor for class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
code - Variable in exception org.apache.bookkeeper.client.api.BKException
 
codeLogger(int) - Static method in exception org.apache.bookkeeper.client.api.BKException
Returns a lazy error code formatter suitable to pass to log functions.
COMPACTION_MAX_OUTSTANDING_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE_BY_BYTES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE_BY_ENTRIES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
compare(PendingAddOp, PendingAddOp) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv.PendingOpsComparator
 
complete - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
complete - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
complete - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
complete(int, BookieId, ByteBuf) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Complete the read request from host.
complete(int, BookieId, ByteBuf) - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
complete(int, BookieId, ByteBuf, long) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Complete the read request from host.
complete(int, BookieId, ByteBuf, long) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
completeBookieAndCheck(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet
Add a bookie response and check if quorum has been met.
completed - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
completed - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
completed - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
completed - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
completed - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
conf - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
conf - Variable in class org.apache.bookkeeper.client.BookKeeper
 
Configurable - Interface in org.apache.bookkeeper.conf
Class that may be configured with a Configuration.
contains(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Whether the set contains the given index.
convertBookiesToNodes(Collection<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
convertBookieToNode(BookieId) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
copy() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Make a deep copy of this write set.
Counter - Interface in org.apache.bookkeeper.stats
Simple stats that require only increment and decrement functions on a Long.
counters - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger
 
counters - Variable in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider
 
counters - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
coverageSet - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
CRC32 - org.apache.bookkeeper.client.api.DigestType
Entries are verified by applied CRC32 algorithm.
CRC32 - org.apache.bookkeeper.client.BookKeeper.DigestType
 
CRC32C - org.apache.bookkeeper.client.api.DigestType
Entries are verified by applied CRC32C algorithm.
CRC32C - org.apache.bookkeeper.client.BookKeeper.DigestType
 
create() - Static method in class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
create(int) - Static method in exception org.apache.bookkeeper.client.BKException
Create an exception from an error code.
create(long, long) - Static method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
 
create(long, long, long, ByteBuf) - Static method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
 
create(long, LedgerEntry) - Static method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
 
create(List<LedgerEntry>) - Static method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl
Create ledger entries.
create(LedgerHandle, ClientContext, List<BookieId>, ByteBuf, EnumSet<WriteFlag>, AsyncCallback.AddCallbackWithLatency, Object) - Static method in class org.apache.bookkeeper.client.PendingAddOp
 
CREATE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CreateAdvBuilder - Interface in org.apache.bookkeeper.client.api
Builder-style interface to create new ledgers.
createBookieNode(BookieId) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
CreateBuilder - Interface in org.apache.bookkeeper.client.api
Builder-style interface to create new ledgers.
CreateBuilderImpl(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl
 
createComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CreateCallback
Declaration of callback method.
createComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCreateAdvCallback
Create callback implementation for synchronous create call.
createComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCreateCallback
Create callback implementation for synchronous create call.
createDummyLocalBookieNode(String) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
createLedger(int, int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedger(int, int, int, BookKeeper.DigestType, byte[], Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedger(int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedger(BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger.
createLedgerAdv(int, int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedgerAdv(int, int, int, BookKeeper.DigestType, byte[], Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedgerAdv(long, int, int, int, BookKeeper.DigestType, byte[], Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronously creates a new ledger using the interface which accepts a ledgerId as input.
createOpLogger - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ctx - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ctx - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
ctx - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
ctx - Variable in class org.apache.bookkeeper.client.ListenerBasedPendingReadOp
 
ctx - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
ctx - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
cummulativeMap - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
currentEnsemble - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
currentEnsemble - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
currentEnsemble - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
currentEnsemble - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
currentEntry - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
currentLedgerLength - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
currentNonDurableLastAddConfirmed - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
customMetadata - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 

D

data - Variable in class org.apache.bookkeeper.client.LedgerEntry
 
DATA_INTEGRITY_CHECKING_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DATA_INTEGRITY_COOKIE_STAMPING_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DATA_LOSS - org.apache.bookkeeper.client.LedgerFragment.ReplicateType
 
DATA_NOT_ADHERING_PLACEMENT - org.apache.bookkeeper.client.LedgerFragment.ReplicateType
 
DataSketchesOpStatsLogger - Class in org.apache.bookkeeper.stats.prometheus
OpStatsLogger implementation that uses DataSketches library to calculate the approximated latency quantiles.
DataSketchesOpStatsLogger(Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
DataUnknownException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Operations failed due to ledger data in an unknown state.
DEATH_WATCH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
dec() - Method in class org.apache.bookkeeper.client.SyncCounter
 
dec() - Method in interface org.apache.bookkeeper.stats.Counter
Decrement the value associated with this stat.
dec() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
dec() - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
dec() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
dec() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
decommissionBookie(BookieId) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Triggers AuditTask by resetting lostBookieRecoveryDelay and then make sure the ledgers stored in the given decommissioning bookie are properly replicated and they are not underreplicated because of the given bookie.
DEFAULT_ENTRY_FORMATTER - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DEFAULT_LEDGERID_FORMATTER - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DEFAULT_LOADER - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DEFAULT_NETTY_MAX_FRAME_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DEFAULT_PROMETHEUS_STATS_HTTP_ADDR - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
DEFAULT_PROMETHEUS_STATS_HTTP_ENABLE - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
DEFAULT_PROMETHEUS_STATS_HTTP_PORT - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
DEFAULT_PROMETHEUS_STATS_LATENCY_ROLLOVER_SECONDS - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
DEFAULT_ROCKSDB_CONF - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DefaultBookieAddressResolver - Class in org.apache.bookkeeper.client
Resolve BookieIDs to Network addresses.
DefaultBookieAddressResolver(RegistrationClient) - Constructor for class org.apache.bookkeeper.client.DefaultBookieAddressResolver
 
DefaultEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
Default Ensemble Placement Policy, which picks bookies randomly.
DefaultEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
defaultRackSupplier - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver
 
defaultRackSupplier - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
DefaultResolver(Supplier<String>) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver
 
DefaultSpeculativeRequestExecutionPolicy - Class in org.apache.bookkeeper.client
A default implementation of SpeculativeRequestExecutionPolicy.
DefaultSpeculativeRequestExecutionPolicy(int, int, float) - Constructor for class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy
 
defaultValues() - Static method in class org.apache.bookkeeper.client.ClientInternalConf
 
DEFERRED_SYNC - org.apache.bookkeeper.client.api.WriteFlag
Writes will be acknowledged after writing to the filesystem but not yet been persisted to disks.
DELAY_ENSEMBLE_CHANGE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
delayedWriteFailedBookies - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
delayEnsembleChange - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
DELETE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
DeleteBuilder - Interface in org.apache.bookkeeper.client.api
Builder-style interface to delete exiting ledgers.
DeleteBuilderImpl(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerDeleteOp.DeleteBuilderImpl
 
deleteComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.DeleteCallback
Callback definition for delete operations.
deleteComplete(int, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncDeleteCallback
Delete callback implementation for synchronous delete call.
deleteLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to delete a ledger.
deleteOpLogger - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
DESIRED_NUM_ZONES_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
desiredNumZonesPerWriteQuorum - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
diffEnsemble(List<BookieId>, List<BookieId>) - Static method in class org.apache.bookkeeper.client.EnsembleUtils
 
differBetweenBookies(List<BookieId>, List<BookieId>) - Static method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
DIGEST_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
DigestMatchException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Digest doesn't match on returned entries.
DigestNotInitializedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Digest Manager is not initialized (client error).
digestType - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
digestType - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
DigestType - Enum in org.apache.bookkeeper.client.api
Digest type.
DISABLE_ALL - Static variable in class org.apache.bookkeeper.feature.SettableFeatureProvider
 
DISABLE_ENSEMBLE_CHANGE_FEATURE_NAME - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
DISABLE_SERVER_SOCKET_BIND - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
disableDurabilityFeature - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
disableEnsembleChangeFeature - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
disallowBookiePlacementInRegionFeatureName - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
DISK_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_LWM_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_WARN_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_WEIGHT_BASED_PLACEMENT_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
distanceFromLeaves - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
distributionSchedule - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
DistributionSchedule - Interface in org.apache.bookkeeper.client
This interface determins how entries are distributed among bookies.
DistributionSchedule.AckSet - Interface in org.apache.bookkeeper.client
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 in org.apache.bookkeeper.client
Interface to keep track of which bookies in an ensemble, an action has been performed for.
DistributionSchedule.WriteSet - Interface in org.apache.bookkeeper.client
A write set represents the set of bookies to which a request will be written.
dnsResolver - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
dnsResolver - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
dnsResolver(DNSToSwitchMapping) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Configure the bookkeeper client to use the provided dns resolver DNSToSwitchMapping.
dnsResolver(DNSToSwitchMapping) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
Configure the bookkeeper client to use the provided dns resolver DNSToSwitchMapping.
dnsResolver(DNSToSwitchMapping) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
DNSResolverDecorator(DNSToSwitchMapping, Supplier<String>, Counter) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
doAsyncAddEntry(PendingAddOp) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
doAsyncAddEntry(PendingAddOp) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv
Overriding part is mostly around setting entryId.
doAsyncCloseInternal(AsyncCallback.CloseCallback, Object, int) - Method in class org.apache.bookkeeper.client.LedgerHandle
Same as public version of asyncClose except that this one takes an additional parameter which is the return code to hand to all the pending add ops.
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusServlet
 
doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusServlet
 
doRecovery - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
drainPendingAddsAndAdjustLength() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
DUMMY - org.apache.bookkeeper.client.api.DigestType
Entries are not verified.
DUMMY - org.apache.bookkeeper.client.BookKeeper.DigestType
 
dump(OutputStream) - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
duplicate() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
Returns a duplicate of this entry.
duplicate() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
Returns a duplicate of this entry.
duplicate() - Method in interface org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet
 
duplicate() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
 
duplicate() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
duplicate(LedgerEntry) - Static method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
 
DuplicateEntryIdException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Duplicated entry id is found when LedgerHandleAdv.addEntry(long, byte[]).
DynamicWeightedRandomSelectionImpl<T> - Class in org.apache.bookkeeper.client
DynamicWeightedRandomSelectionImpl class implements both getNextRandom overloaded methods.
DynamicWeightedRandomSelectionImpl() - Constructor for class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
DynamicWeightedRandomSelectionImpl(int) - Constructor for class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 

E

eId - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
EMPTY_LIST - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
 
EMPTY_SET - Static variable in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
emptyResponseReplicas - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
emptyResponsesFromHostsBitSet - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
ENABLE_BOOKIE_FAILURE_TRACKING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ENABLE_BUSY_WAIT - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ENABLE_DIGEST_TYPE_AUTODETECTION - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ENABLE_HEALTH_CHECK - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ENABLE_LOCAL_TRANSPORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENABLE_PARALLEL_RECOVERY_READ - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ENABLE_STATISTICS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENABLE_TASK_EXECUTION_STATS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ENABLE_TASK_EXECUTION_STATS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
enableBookieFailureTracking - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
enableBookieHealthCheck() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Enables the bookie health check.
enableDigestAutodetection - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
enableParallelRecoveryRead - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
enableRecoveryAdd() - Method in class org.apache.bookkeeper.client.PendingAddOp
Enable the recovery add flag for this operation.
enableReorderReadSequence - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
enableStickyReads - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
enableValidation - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
endEntryId - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
endEntryToRead - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
ENFORCE_MIN_NUM_FAULT_DOMAINS_FOR_WRITE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ENFORCE_MIN_NUM_RACKS_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ENFORCE_STRICT_ZONEAWARE_PLACEMENT - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
enforceDurability - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
enforceDurabilityInReplace - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
enforceMinNumFaultDomainsForWrite - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
enforceMinNumRacksPerWriteQuorum - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
enforceStrictZoneawarePlacement - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
ensemble - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
ensemble - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
ensemble - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
ENSEMBLE_CHANGES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ENSEMBLE_PLACEMENT_POLICY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ENSEMBLE_PLACEMENT_POLICY_ORDER_SLOW_BOOKIES - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ensembleChangeCounter - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
ensembleChangeLoop(List<BookieId>, Map<Integer, BookieId>) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
EnsembleForReplacementWithNoConstraints() - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
 
EnsemblePlacementPolicy - Interface in org.apache.bookkeeper.client
EnsemblePlacementPolicy encapsulates the algorithm that bookkeeper client uses to select a number of bookies from the cluster as an ensemble for storing entries.
EnsemblePlacementPolicy.PlacementPolicyAdherence - Enum in org.apache.bookkeeper.client
enum for PlacementPolicyAdherence.
EnsemblePlacementPolicy.PlacementResult<T> - Class in org.apache.bookkeeper.client
Result of a placement calculation against a placement policy.
ensembleSize - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ensembleSize - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
EnsembleUtils - Class in org.apache.bookkeeper.client
 
EnsembleUtils() - Constructor for class org.apache.bookkeeper.client.EnsembleUtils
 
ENTRY_FORMATTER_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ENTRY_ID_PENDING - Static variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
ENTRY_LOCATION_ROCKSDB_CONF - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_FILE_PREALLOCATION_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_PER_LEDGER_COUNTER_LIMITS_MULT_FACTOR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_PER_LEDGER_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_SIZE_LIMIT_KEY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
entryId - Variable in class org.apache.bookkeeper.client.LedgerEntry
 
entryId - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
entryImpl - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
entryImpl - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
entryLength - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
entryListener - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
ENTRYLOGMAP_ACCESS_EXPIRYTIME_INSECONDS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
equals(Object) - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
equals(Object) - Method in class org.apache.bookkeeper.client.PendingAddOp
 
equals(Object) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation
 
equals(Object) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
equals(Object) - Method in class org.apache.bookkeeper.stats.otel.ScopeContext
 
equals(Object) - Method in class org.apache.bookkeeper.stats.prometheus.ScopeContext
 
errored - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
erroredReplicas - Variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
erroredReplicas - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
errorOutPendingAdds(int) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
errorOutPendingAdds(int, List<PendingAddOp>) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
eventLoopGroup - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
eventLoopGroup - Variable in class org.apache.bookkeeper.client.BookKeeper
 
eventLoopGroup(EventLoopGroup) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Configure the bookkeeper client with a provided Netty EventLoopGroup.
eventLoopGroup(EventLoopGroup) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
Configure the bookkeeper client with a provided EventLoopGroup.
eventLoopGroup(EventLoopGroup) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
execute() - Method in interface org.apache.bookkeeper.client.api.OpBuilder
Start the operation and return an handle to the result.
execute() - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl
 
execute() - Method in class org.apache.bookkeeper.client.LedgerDeleteOp.DeleteBuilderImpl
 
execute() - Method in class org.apache.bookkeeper.client.LedgerOpenOp.OpenBuilderImpl
 
executeOrdered(Runnable) - Method in class org.apache.bookkeeper.client.LedgerHandle
Execute the callback in the thread pinned to the ledger.
executor - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
EXPLICIT_LAC_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
explicitLac - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
explicitLacFlushPolicy - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
ExplicitLacFlushPolicy - Interface in org.apache.bookkeeper.client
 
ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl - Class in org.apache.bookkeeper.client
 
ExplicitLacFlushPolicyImpl(LedgerHandle, ClientContext) - Constructor for class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
explicitLacInterval - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
EXTRA_SERVER_COMPONENTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

F

fail - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
fail(int) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Fail the request with given result code rc.
fail(int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Fail the request with given result code rc.
FAIL - org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence
 
failBookieAndCheck(int, BookieId) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet
Received failure response from a bookie and check if ack quorum will be broken.
FAILED_CONNECTION_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
FAILED_TLS_HANDSHAKE_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
failedToResolveNetworkLocationCounter - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
failedToResolveNetworkLocationCounter - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
failedToResolveNetworkLocationCounter - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
FastCodahaleMetricsProvider - Class in org.apache.bookkeeper.stats.codahale
A StatsProvider implemented based on Codahale metrics library.
FastCodahaleMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.codahale.FastCodahaleMetricsProvider
 
FastCodahaleStatsLogger - Class in org.apache.bookkeeper.stats.codahale
A StatsLogger implemented based on Codahale metrics library.
FastCodahaleStatsLogger(MetricRegistry, String) - Constructor for class org.apache.bookkeeper.stats.codahale.FastCodahaleStatsLogger
 
FastSnapshot - Class in org.apache.bookkeeper.stats.codahale
A snapshot of a FastTimer.
FastSnapshot(FastTimer, long, long, long, long, long[]) - Constructor for class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
FastTimer - Class in org.apache.bookkeeper.stats.codahale
A fast and (nearly) garbage-free Rate and Response Times Timer.
FastTimer() - Constructor for class org.apache.bookkeeper.stats.codahale.FastTimer
Constructs a new timer with default time window (60 seconds) and default time buckets (fine).
FastTimer(int, FastTimer.Buckets) - Constructor for class org.apache.bookkeeper.stats.codahale.FastTimer
Constructs a new timer.
FastTimer.Buckets - Enum in org.apache.bookkeeper.stats.codahale
Defines the response time buckets to use.
Feature - Interface in org.apache.bookkeeper.feature
This interface represents a feature.
FEATURE_AVAILABILITY_MAX_VALUE - Static variable in interface org.apache.bookkeeper.feature.Feature
 
featureProvider - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
featureProvider - Variable in class org.apache.bookkeeper.client.BookKeeper
 
featureProvider - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
featureProvider(FeatureProvider) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Configure the bookkeeper client to use a provided FeatureProvider.
featureProvider(FeatureProvider) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
Feature Provider.
featureProvider(FeatureProvider) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
FeatureProvider - Interface in org.apache.bookkeeper.feature
Provider to provide features.
features - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
FILEINFO_CACHE_INITIAL_CAPACITY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FILEINFO_FORMAT_VERSION_TO_WRITE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FILEINFO_MAX_IDLE_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
fine - org.apache.bookkeeper.stats.codahale.FastTimer.Buckets
 
finish(int, T, CompletableFuture<? super T>) - Static method in class org.apache.bookkeeper.client.SyncCallbackUtils
Handle the Response Code and transform it to a BKException.
FIRST_SPECULATIVE_READ_LAC_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
FIRST_SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
firstEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
firstError - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
firstError - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
firstSpeculativeRequestTimeout - Variable in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy
 
FixedValueFeature - Class in org.apache.bookkeeper.feature
A feature implementation that has a fixed value of availability.
FixedValueFeature(String, boolean) - Constructor for class org.apache.bookkeeper.feature.FixedValueFeature
 
FixedValueFeature(String, int) - Constructor for class org.apache.bookkeeper.feature.FixedValueFeature
 
FLUSH_ENTRYLOG_INTERVAL_BYTES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FLUSH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FOLLOW_BOOKIE_ADDRESS_TRACKING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
force() - Method in interface org.apache.bookkeeper.client.api.ForceableHandle
Enforce durability to the entries written by this handle.
force() - Method in class org.apache.bookkeeper.client.LedgerHandle
Enforce durability to the entries written by this handle.
FORCE_ALLOW_COMPACTION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FORCE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
FORCE_READ_ONLY_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ForceableHandle - Interface in org.apache.bookkeeper.client.api
Provide the ability to enforce durability guarantees to the writer.
forceLedgerComplete(int, long, BookieId, Object) - Method in class org.apache.bookkeeper.client.ForceLedgerOp
 
ForceLedgerOp - Class in org.apache.bookkeeper.client
This represents a request to sync the ledger on every bookie.
ForceLedgerOp(LedgerHandle, BookieClient, List<BookieId>, CompletableFuture<Void>) - Constructor for class org.apache.bookkeeper.client.ForceLedgerOp
 
forConfig(ClientConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeper
 
format(ServerConfiguration, boolean, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Format the BookKeeper metadata in zookeeper.
formatEnsemble(List<BookieId>, Set<BookieId>, char) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
fragmentStartId - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
from(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
fromApiDigestType(DigestType) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType
 
fromConfig(ClientConfiguration) - Static method in class org.apache.bookkeeper.client.ClientInternalConf
 
fromConfigAndFeatureProvider(ClientConfiguration, FeatureProvider) - Static method in class org.apache.bookkeeper.client.ClientInternalConf
 
FULL - org.apache.bookkeeper.client.BookieInfoReader.State
 
future() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
FutureReadLastConfirmed() - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmed
 
FutureReadLastConfirmedAndEntry() - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmedAndEntry
 

G

Gauge<T extends java.lang.Number> - Interface in org.apache.bookkeeper.stats
A guage is a value that has only one value at a specific point in time.
gauges - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
GC_ENTRYLOG_METADATA_CACHE_PATH - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
GC_ENTRYLOGMETADATA_CACHE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
GC_OVERREPLICATED_LEDGER_MAX_CONCURRENT_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
GC_OVERREPLICATED_LEDGER_WAIT_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
GC_WAIT_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
generateLedgerId - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
generateLedgerIdAndCreateLedger(LedgerMetadataBuilder) - Method in class org.apache.bookkeeper.client.LedgerCreateOp
 
get() - Method in interface org.apache.bookkeeper.stats.Counter
Get the value associated with this stat.
get() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
get() - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
get() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
get() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
get() - Static method in class org.apache.bookkeeper.stats.Stats
 
get() - Static method in class org.apache.bookkeeper.stats.ThreadRegistry
 
get(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Get the index at index i.
GET_BOOKIE_INFO_INTERVAL_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
GET_BOOKIE_INFO_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
GET_BOOKIE_INFO_RETRY_INTERVAL_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
GET_BOOKIE_INFO_TIMEOUT_SECS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
GET_LIST_OF_ENTRIES_OF_LEDGER_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getAckQuorumSize() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the ack quorum size of this ledger.
getAckQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getAckSet() - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Returns an ackset object, responses should be checked against this.
getAckSet() - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getAddEntryQuorumTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the timeout for top-level add request.
getAddEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the timeout for add request.
getAddOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getAddOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getAddOpUrCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getAddOpUrCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getAddress(int) - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the failedBookie address.
getAddresses() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
getAdheringToPolicy() - Method in class org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementResult
 
getAdvertisedAddress() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the configured advertised address for the bookie.
getAllBookies() - Method in interface org.apache.bookkeeper.client.BookieWatcher
 
getAllBookies() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
getAllBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get a list of all bookies including the not available ones.
getAllEnsembles() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns all the ensembles of this ledger.
getAllEnsembles() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getAllocatorLeakDetectionPolicy() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Return the configured leak detection policy for the allocator.
getAllocatorOutOfMemoryPolicy() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
 
getAllocatorPoolingConcurrency() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
 
getAllocatorPoolingPolicy() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
 
getAllowEphemeralPorts() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is the bookie allowed to use an ephemeral port (port 0) as its server port.
getAllowLoopback() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is the bookie allowed to use a loopback interface as its primary interface(i.e.
getAllowStorageExpansion() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Return whether we should allow addition of ledger/index dirs to an existing bookie.
getAttributes() - Method in class org.apache.bookkeeper.stats.otel.ScopeContext
 
getAuditorAcquireConcurrentOpenLedgerOperationsTimeoutMSec() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the acquire concurrent open ledger operations timeout.
getAuditorLedgerVerificationPercentage() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get what percentage of a ledger (fragment)'s entries will be verified.
getAuditorMaxNumberOfConcurrentOpenLedgerOperations() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the semaphore limit value of getting ledger from zookeeper in auto recovery.
getAuditorPeriodicBookieCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the interval between auditor bookie check runs.
getAuditorPeriodicCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the regularity at which the auditor checks all ledgers.
getAuditorPeriodicPlacementPolicyCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the regularity at which the auditor does placement policy check of all ledgers, which are closed.
getAuditorPeriodicReplicasCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the interval at which the auditor does replicas check of all ledgers.
getAuthorizedRoles() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the authorized roles.
getAvailableBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get a list of the available bookies.
getAvgLatencyMillis() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getBookieAddressResolver() - Method in interface org.apache.bookkeeper.client.BookieWatcher
 
getBookieAddressResolver() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
getBookieAddressResolver() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getBookieAddressResolver() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getBookieAddressResolverEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to enable BookieAddressResolver.
getBookieAuthProviderFactoryClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the bookie authentication provider factory class name.
getBookieClient() - Method in class org.apache.bookkeeper.client.BookKeeper
Get the BookieClient, currently used for doing bookie recovery.
getBookieClient() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getBookieErrorThresholdPerInterval() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the error threshold for a bookie to be quarantined.
getBookieFailureHistory(BookieId) - Method in interface org.apache.bookkeeper.client.BookiesHealthInfo
Return the failure history for a bookie.
getBookieFailureHistoryExpirationMSec() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the bookie failure tracking expiration timeout.
getBookieHealthCheckIntervalSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the bookie health check interval in seconds.
getBookieId() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the configured BookieId for the bookie.
getBookieInfo() - Method in class org.apache.bookkeeper.client.BookieInfoReader
 
getBookieInfo() - Method in class org.apache.bookkeeper.client.BookKeeper
Retrieves BookieInfo from all the bookies in the cluster.
getBookieInfoTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Return the timeout value for getBookieInfo request.
getBookieMaxWeightMultipleForWeightBasedPlacement() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Returns the max multiple to use for nodes with very high weight.
getBookiePendingRequests(BookieId) - Method in interface org.apache.bookkeeper.client.BookiesHealthInfo
Returns pending requests to a bookie.
getBookiePort() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get bookie port that bookie server listen on.
getBookieQuarantineRatio() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the bookie quarantine ratio.
getBookieQuarantineTimeSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the time for which a bookie will be quarantined.
getBookieRecoveryDigestType() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get digest type used in bookkeeper admin.
getBookieRecoveryPasswd() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get passwd used in bookkeeper admin.
getBookies() - Method in interface org.apache.bookkeeper.client.BookieWatcher
 
getBookies() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
getBookieServiceInfo(BookieId) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getBookiesHealthInfo() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the health info for bookies for this ledger.
getBookiesIndexes() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the failedBookie index.
getBookiesInThisLedger(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils
 
getBookieWatcher() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getBookieWatcher() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getBucket(long) - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Figure out which percentile bucket an event of a given duration belongs into.
getBucketBound(int) - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the upper bucket bound (inclusive) of a given bucket.
getBucketValue(int) - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the average value of a given bucket (the mean between its lower and upper bound).
getByteBufAllocator() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getCause() - Method in exception org.apache.bookkeeper.conf.UncheckedConfigurationException
Returns the cause of this exception.
getClientAuthProviderFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the client authentication provider factory class name.
getClientChannelWriteWaitLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getClientChannelWriteWaitLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getClientConnectBookieUnavailableLogThrottlingMs() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the log frequency when a bookie is unavailable, in milliseconds.
getClientConnectTimeoutMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty connect timeout in millis.
getClientCtx() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getClientReceiveBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel receive buffer size.
getClientRole() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the role of the client.
getClientSendBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel send buffer size.
getClientSockKeepalive() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
get socket keepalive.
getClientStats() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getClientTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Is tcp connection no delay.
getClientWriteBufferHighWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel write buffer high water mark.
getClientWriteBufferLowWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel write buffer low water mark.
getCloseChannelOnResponseTimeout() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configures action in case if server timed out sending response to the client.
getCloseLock() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getCode() - Method in exception org.apache.bookkeeper.client.api.BKException
Get the return code for the exception.
getCompactionMaxOutstandingRequests() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the maximum number of entries which can be compacted without flushing.
getCompactionRate() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
getCompactionRateByBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the rate of compaction adds.
getCompactionRateByEntries() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the rate of compaction adds.
getConf() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getConf() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getConf() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getConf() - Method in interface org.apache.bookkeeper.conf.Configurable
Return the configuration used by this object.
getCount() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the all-time count of events this timer has seen.
getCount(boolean) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
getCounter(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
getCounter(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
getCounter(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
getCounter(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
getCounter(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
getCounter(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
 
getCoverageSet() - Method in interface org.apache.bookkeeper.client.DistributionSchedule
 
getCoverageSet() - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getCreateOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getCreateOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getCtime() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the creation timestamp of this ledger.
getCtime() - Method in class org.apache.bookkeeper.client.LedgerHandle
Returns the ledger creation time.
getCtime() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getCToken() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Get the unique creator token of the Ledger.
getCToken() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getCurrentAuditor() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getCurrentEnsemble() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the current ensemble from the ensemble list.
getCurrentEnsemble() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
getCurrentEnsemble(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils
 
getCustomMetadata() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the custom metadata stored with the ledgers.
getCustomMetadata() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get this ledger's customMetadata map.
getCustomMetadata() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getDeathWatchInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get bookie death watch interval.
getDefaultFaultDomain() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
getDefaultRack() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
getDefaultRocksDBConf() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get default rocksdb conf.
getDefaultValue() - Method in interface org.apache.bookkeeper.stats.Gauge
 
getDelayEnsembleChange() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to delay ensemble change or not?
getDeleteOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getDeleteOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getDesiredNumZonesPerWriteQuorum() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the desired number of zones per write quorum in ZoneAwarePlacementPolicy.
getDigestManager() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the DigestManager.
getDigestType() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the digest type used by this ledger.
getDigestType() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getDisableEnsembleChangeFeatureName() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the name of the dynamic feature that disables ensemble change.
getDiskCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the disk checker interval.
getDiskLowWaterMarkUsageThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Returns disk free space low water mark threshold.
getDiskUsageThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Returns disk free space threshold.
getDiskUsageWarnThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Returns the warning threshold for disk usage.
getDiskWeightBasedPlacementEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Return whether disk weight based placement policy is enabled.
getDistributionSchedule() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the Distribution Schedule.
getEnableBookieAddressTracking() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to enable bookie address changes tracking.
getEnableBookieFailureTracking() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to enable bookie failure tracking.
getEnableDigestTypeAutodetection() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get autodetection of digest type.
getEnableParallelRecoveryRead() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to enable parallel reading in recovery read.
getEnableTaskExecutionStats() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to enable recording task execution stats.
getEnableTaskExecutionStats() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Whether to enable recording task execution stats.
getEnforceMinNumFaultDomainsForWrite() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the flag to enforce minimum number of fault domains for write.
getEnforceMinNumRacksPerWriteQuorum() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the flag which enforces the minimum number of racks per write quorum.
getEnforceStrictZoneawarePlacement() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the flag to enforce strict zoneaware placement.
getEnsemble() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the ensemble of fragment.
getEnsembleAckSet() - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Returns an ackset object useful to wait for all bookies in the ensemble, responses should be checked against this.
getEnsembleAckSet() - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getEnsembleAt(long) - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the ensemble at the given entryId.
getEnsembleAt(long) - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getEnsembleBookieDistributionCounter(String) - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getEnsembleBookieDistributionCounter(String) - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getEnsembleChangeCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getEnsembleChangeCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getEnsemblePlacementPolicy() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get Ensemble Placement Policy Class.
getEnsemblePlacementPolicySlowBookies() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to order slow bookies in placement policy.
getEnsembleSet(long) - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Return the set of bookies indices to send the messages to the whole ensemble.
getEnsembleSet(long) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getEnsembleSize() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the ensemble size of this ledger.
getEnsembleSize() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getEntriesStripedToTheBookie(int, long, long) - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Get the bitset representing the entries from entry 'startEntryId' to 'lastEntryId', that would be striped to the bookie with index - bookieIndex.
getEntriesStripedToTheBookie(int, long, long) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getEntry() - Method in interface org.apache.bookkeeper.client.api.LastConfirmedAndEntry
Gets wanted LedgerEntry.
getEntry() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
Gets wanted LedgerEntry.
getEntry() - Method in class org.apache.bookkeeper.client.LedgerEntry
Returns the content of the entry.
getEntry(long) - Method in interface org.apache.bookkeeper.client.api.LedgerEntries
Gets a specific LedgerEntry by entryId.
getEntry(long) - Method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl
Gets a specific LedgerEntry by entryId.
getEntryBuffer() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
Return the internal ByteBuf that contains the entry payload.
getEntryBuffer() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
Return the internal ByteBuf that contains the entry payload.
getEntryBuffer() - Method in class org.apache.bookkeeper.client.LedgerEntry
Return the internal buffer that contains the entry payload.
getEntryBytes() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
Returns the content of the entry as a byte array.
getEntryBytes() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
Returns the content of the entry as a byte array.
getEntryFormatterClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get entry formatter class.
getEntryId() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
The id of the entry.
getEntryId() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
The id of the entry.
getEntryId() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getEntryId() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
getEntryInputStream() - Method in class org.apache.bookkeeper.client.LedgerEntry
Returns the content of the entry.
getEntryLocationRocksdbConf() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get entry Location rocksdb conf.
getEntrylogMapAccessExpiryTimeInSeconds() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getEntryLogPerLedgerCounterLimitsMultFactor() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getEntryLogSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get entry logger size limitation.
getEntryNioBuffer() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
Exposes this entry's data as an NIO ByteBuffer.
getEntryNioBuffer() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
Exposes this entry's data as an NIO ByteBuffer.
getExceptionCode(Throwable) - Static method in exception org.apache.bookkeeper.client.BKException
Extract an exception code from an BKException, or default to unexpected exception if throwable is not a BKException.
getExceptionCode(Throwable, int) - Static method in exception org.apache.bookkeeper.client.BKException
Extract an exception code from an BKException, or use a default if it's another type.
getExplictLacInterval() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the configured interval between explicit LACs to bookies.
getExtraServerComponents() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the extra list of server lifecycle components to enable on a bookie server.
getFailedBookies() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet
Return the list of bookies that already failed.
getFeature(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
getFeature(String) - Method in interface org.apache.bookkeeper.feature.FeatureProvider
Return the feature with given name.
getFeature(String, Feature) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
 
getFifteenMinuteRate() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
 
getFileInfoCacheInitialCapacity() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the minimum total size for the internal file info cache tables.
getFileInfoFormatVersionToWrite() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get fileinfo format version to write.
getFileInfoMaxIdleTime() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the max idle time allowed for a open file info existed in file info cache.
getFirstEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
getFirstError() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
getFirstSpeculativeReadLACTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the period of time after which the first speculative read last add confirmed and entry should be triggered.
getFirstSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the first speculative read timeout.
getFirstStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the first stored entry id of the fragment in failed bookies.
getFirstStoredEntryId(int) - Method in class org.apache.bookkeeper.client.LedgerFragment
Get the first stored entry id of the fragment in the given failed bookies.
getFiveMinuteRate() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
 
getFlushInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get flush interval.
getFlushIntervalInBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set entry log flush interval in bytes.
getForceOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getForceOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getFreeDiskSpace() - Method in class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo
 
getFreeDiskSpace(BookieId) - Method in class org.apache.bookkeeper.client.BookieInfoReader
Method to allow tests to block until bookie info is available.
getGcEntryLogMetadataCachePath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get directory to persist Entrylog metadata if gcPersistentEntrylogMetadataMapEnabled is true.
getGcOverreplicatedLedgerMaxConcurrentRequests() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Max number of concurrent requests in garbage collection of overreplicated ledgers.
getGcOverreplicatedLedgerWaitTimeMillis() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get wait time in millis for garbage collection of overreplicated ledgers.
getGcWaitTime() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get Garbage collection wait time.
getGetBookieInfoIntervalSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the time interval between successive calls for bookie get info.
getGetBookieInfoRetryIntervalSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the time interval between retries on unsuccessful bookie info request.
getHostnameVerificationEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether hostname verification enabled?
getHttpServerHost() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server host.
getHttpServerKeystorePassword() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server keyStore password.
getHttpServerKeystorePath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server keystore path.
getHttpServerPort() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server port.
getHttpServerTrustStorePassword() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server trustStore password.
getHttpServerTrustStorePath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server trustStore path.
getId() - Method in interface org.apache.bookkeeper.client.api.Handle
Get the id of the current ledger.
getId() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the id of the current ledger.
getIgnoreExtraServerComponentsStartupFailures() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Return the flag whether to ignore startup failures on loading server components specified at ServerConfiguration.getExtraServerComponents().
getIgnoreLocalNodeInPlacementPolicy() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Whether to ignore localnode in placementpolicy.
getIndexDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir name to store index files.
getIndexDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get index dir to store ledger index files.
getInFlightReadEntryNumInLedgerChecker() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get in flight read entry number when ledger checker.
getIsForceGCAllowWhenNoSpace() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether force compaction is allowed when disk full or almost full.
getIsThrottleByBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether use bytes to throttle garbage collector compaction or not.
getJournalAdaptiveGroupWrites() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we group journal force writes.
getJournalAlignmentSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
All the journal writes and commits should be aligned to given size.
getJournalBufferedEntriesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum entries to buffer to impose on a journal write to achieve grouping.
getJournalBufferedWritesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum bytes to buffer to impose on a journal write to achieve grouping.
getJournalChannelProvider() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getJournalDirName() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Deprecated.
getJournalDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir names to store journal files.
getJournalDirNameWithoutDefault() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir name to store journal files.
getJournalDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dirs to store journal files.
getJournalFlushWhenQueueEmpty() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we flush the journal when queue is empty.
getJournalFormatVersionToWrite() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get journal format version to write.
getJournalMaxGroupWaitMSec() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum latency to impose on a journal write to achieve grouping.
getJournalMaxMemorySizeMb() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the max amount of memory that can be used by the journal.
getJournalPageCacheFlushIntervalMSec() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get journal pageCache flush interval.
getJournalPreAllocSizeMB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
How much space should we pre-allocate at a time in the journal.
getJournalQueueSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get size of journal queue.
getJournalRemovePagesFromCache() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we remove pages from page cache after force write.
getJournalReuseFiles() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get reuse journal files.
getJournalSyncData() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should the data be fsynced on journal before acknowledgment.
getJournalWriteBufferSizeKB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Size of the write buffers used for the journal.
getJournalWriteData() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should the data be written to journal before acknowledgment.
getLabels() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
getLabels() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
getLabels() - Method in class org.apache.bookkeeper.stats.prometheus.SimpleGauge
 
getLacComplete(int, long) - Method in interface org.apache.bookkeeper.client.PendingReadLacOp.LacCallback
 
getLacUpdateHitsCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getLacUpdateHitsCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getLacUpdateMissesCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getLacUpdateMissesCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getLastAddConfirmed() - Method in interface org.apache.bookkeeper.client.api.LastConfirmedAndEntry
Gets LastAddConfirmed entryId.
getLastAddConfirmed() - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Get the last confirmed entry id on this ledger.
getLastAddConfirmed() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
Gets LastAddConfirmed entryId.
getLastAddConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the last confirmed entry id on this ledger.
getLastAddPushed() - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Get the entry id of the last entry that has been enqueued for addition (but may not have possibly been persisted to the ledger).
getLastAddPushed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the entry id of the last entry that has been enqueued for addition (but may not have possibly been persisted to the ledger).
getlastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
getLastEnsembleKey(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils
 
getLastEnsembleValue(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils
 
getLastEntryId() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the last entry id of this ledger.
getLastEntryId() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getLastKnownEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
getLastStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the last stored entry id of the fragment in failed bookie.
getLastStoredEntryId(int) - Method in class org.apache.bookkeeper.client.LedgerFragment
Get the last stored entry id of the fragment in the given failed bookie.
getLedgerDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir names to store ledger data.
getLedgerDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dirs that stores ledger data.
getLedgerDirWithoutDefault() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir names to store ledger data.
getLedgerId() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
The id of the ledger which contains the entry.
getLedgerId() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the id of this ledger.
getLedgerId() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
The id of the ledger which contains the entry.
getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getLedgerIdFormatterClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get ledger id formatter class.
getLedgerIdGenerator() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getLedgerKey() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the Ledger's key/password.
getLedgerManager() - Method in class org.apache.bookkeeper.client.BookKeeper
Returns ref to speculative read counter, needed in PendingReadOp.
getLedgerManager() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getLedgerManagerFactory() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getLedgerManagerFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get ledger manager factory class.
getLedgerManagerFactoryClassName() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get Ledger Manager Factory Class Name.
getLedgerManagerLayoutStringFromFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get layout string ("null" if unconfigured).
getLedgerManagerType() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
getLedgerMetadata() - Method in interface org.apache.bookkeeper.client.api.Handle
Returns the metadata of this ledger.
getLedgerMetadata() - Method in class org.apache.bookkeeper.client.LedgerHandle
Returns the metadata of this ledger.
getLedgerMetadata() - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp
 
getLedgerMetadata() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
getLedgerMetadata() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
getLedgerMetadata(long) - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Get ledger metadata of a given ledger id.
getLedgerMetadata(long) - Method in class org.apache.bookkeeper.client.BookKeeper
 
getLedgerMetadata(LedgerHandle) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getLedgerMetadataFormatVersion() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get Ledger metadata format version.
getLedgerMetadataRocksdbConf() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get ledger metadata rocksdb conf.
getLedgersContainBookies(Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getLedgerStorageClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getLength() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
The length of the entry, that is the size of the content expressed in bytes.
getLength() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the length of this ledger.
getLength() - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Returns the length of the data written in this ledger so much, in bytes.
getLength() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
The length of the entry, that is the size of the content expressed in bytes.
getLength() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getLength() - Method in class org.apache.bookkeeper.client.LedgerHandle
Returns the length of the ledger in bytes.
getLength() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getLh() - Method in class org.apache.bookkeeper.client.SyncCounter
 
getLimitStatsLogging() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Return the flag indicating whether to limit stats logging.
getListeningInterface() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the network interface that the bookie should listen for connections on.
getLocalRegion(BookieNode) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
getLocalScrubPeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get local scrub interval.
getLocalScrubRateLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get local scrub rate limit (entries/second).
getLockReleaseOfFailedLedgerGracePeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the grace period, in milliseconds, which the replication worker has to wait before releasing the lock after it failed to replicate a ledger.
getLostBookieRecoveryDelay() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Returns the current LostBookieRecoveryDelay value (in seconds) in Zookeeper.
getLostBookieRecoveryDelay() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get how long to delay the recovery of ledgers of a lost bookie.
getMainWorkerPool() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getMainWorkerPool() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getMajorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get interval to run major compaction, in seconds.
getMajorCompactionMaxTimeMillis() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the maximum milliseconds to run major compaction.
getMajorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get threshold of major compaction.
getMax() - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getMaxAddsInProgressLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get max number of adds in progress.
getMaxAllowedEnsembleChanges() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the max allowed ensemble change number.
getMaxBackupJournals() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Max number of older journal files kept.
getMaximumNumberOfActiveEntryLogs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getMaxJournalSizeMB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Max journal file size.
getMaxOperationNumbersInSingleRocksDBBatch() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the max operation numbers in a single rocksdb write batch.
getMaxPendingAddRequestPerThread() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
If add workers threads are enabled, limit the number of pending requests, to avoid the executor queue to grow indefinitely (default: 10000 entries).
getMaxPendingReadRequestPerThread() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
If read workers threads are enabled, limit the number of pending requests, to avoid the executor queue to grow indefinitely (default: 10000 entries).
getMaxReadsInProgressLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get max number of reads in progress.
getMaxSpeculativeReadLACTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the maximum interval between successive speculative read last add confirmed and entry requests.
getMaxSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the max speculative read timeout.
getMean() - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getMeanRate() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
 
getMessage(int) - Static method in exception org.apache.bookkeeper.client.api.BKException
Describe an error code.
getMetadataClientDriver() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getMetadataFormatVersion() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Get the format version which should be used to serialize the metadata.
getMetadataFormatVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getMetadataServiceUri() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get metadata service uri.
getMetadataServiceUriUnchecked() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get metadata service uri.
getMetastoreImplClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get metastore implementation class.
getMetastoreMaxEntriesPerScan() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get max entries per scan in metastore.
getMetrics() - Method in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
getMin() - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getMinNumRacksPerWriteQuorum() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the minimum number of racks per write quorum.
getMinNumZonesPerWriteQuorum() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the minimum number of zones per write quorum in ZoneAwarePlacementPolicy.
getMinorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get interval to run minor compaction, in seconds.
getMinorCompactionMaxTimeMillis() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the maximum milliseconds to run minor compaction.
getMinorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get threshold of minor compaction.
getMinUsableSizeForEntryLogCreation() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Gets the minimum safe usable size to be available in ledger directory for Bookie to create entry log files.
getMinUsableSizeForHighPriorityWrites() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Gets the minimum safe usable size to be available in ledger directory for Bookie to accept high priority writes.
getMinUsableSizeForIndexFileCreation() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Gets the minimum safe Usable size to be available in index directory for Bookie to create Index File while replaying journal at the time of Bookie Start in Readonly Mode (in bytes).
getName() - Method in class org.apache.bookkeeper.stats.otel.ScopeContext
 
getNettyMaxFrameSizeBytes() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the maximum netty frame size in bytes.
getNetworkLocations(Set<Node>) - Static method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
getNetworkTopologyStabilizePeriodSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the network topology stabilize period in seconds.
getNextEnsembleChange(LedgerMetadata, long) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils
the entry id greater than the given entry-id at which the next ensemble change takes place.
getNextRandom() - Method in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
getNextRandom() - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection
 
getNextRandom() - Method in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
getNextRandom(Collection<T>) - Method in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
getNextRandom(Collection<T>) - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection
 
getNextRandom(Collection<T>) - Method in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
getNumAddWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle write requests.
getNumberOfBuckets() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the number of response time buckets used by this timer.
getNumBookies() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the count of unique bookies that own part of this ledger by going over all the fragments of the ledger.
getNumChannelsPerBookie() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get num channels per bookie.
getNumFailedEvents() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getNumFragments() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the number of fragments that makeup this ledger.
getNumHighPriorityWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should be used for high priority requests (i.e.
getNumIOThreads() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the number of IO threads.
getNumJournalCallbackThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Deprecated.
getNumLongPollWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle long poll requests.
getNumOfMemtableFlushThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getNumReadWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle read requests.
getNumResponsesPending() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
getNumSuccessfulEvents() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getNumVal() - Method in enum org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence
 
getNumWorkerThreads() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the number of worker threads.
getOneMinuteRate() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
 
getOpenFileLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get open file limit.
getOpenLedgerRereplicationGracePeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the grace period which the rereplication worker to wait before fencing and rereplicating a ledger fragment which is still being written to, on bookie failure.
getOpenOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getOpenOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getOpportunisticStriping() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Whether to allow opportunistic striping.
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.codahale.FastCodahaleStatsLogger
 
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
getOpStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
 
getOrdinal() - Method in class org.apache.bookkeeper.stats.ThreadRegistry.ThreadPoolThread
 
getP10Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getP50Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getP90Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getP9999Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getP999Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getP99Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData
 
getPageLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get limitation number of index pages in ledger cache.
getPageSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get page size.
getPassword() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Get the password for the ledger.
getPassword() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getPCBCTimeoutTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
getPCBCTimeoutTimerTickDurationMs() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
getPermittedStartupUsers() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get array of users specified in this property.
getPlacementPolicy() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getPlacementPolicy() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getPreserveMdcForTaskExecution() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Whether to preserve MDC for tasks in Executor.
getQuantileValue(boolean, double) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
getRate() - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler
 
getRate(int) - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the average per-second rate of events this timer has seen.
getrc() - Method in class org.apache.bookkeeper.client.SyncCounter
 
getRc() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Get result code of this entry.
getRc() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Get result code of this entry.
getRC() - Method in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
getReadBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes we should use as capacity for org.apache.bookkeeper.bookie.BufferedReadChannel.
getReadEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the timeout for read entry.
getReadLacAndEntryOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getReadLacAndEntryOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getReadLacAndEntryRespLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getReadLacAndEntryRespLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getReadLacOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getReadLacOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getReadOnlyBookies() - Method in interface org.apache.bookkeeper.client.BookieWatcher
 
getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get a list of readonly bookies synchronously.
getReadOpDmCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getReadOpDmCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getReadOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getReadOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
getReadWriteBookieInfo() - Method in class org.apache.bookkeeper.client.BookieInfoReader
Performs scan described by instanceState using the cached bookie information in bookieInfoMap.
getRecoverAddCountLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getRecoverAddCountLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getRecoverOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getRecoverOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getRecoverReadCountLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getRecoverReadCountLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getRecoveryReadBatchSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get Recovery Read Batch Size.
getRecvByteBufAllocatorSizeInitial() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get Recv ByteBuf allocator initial buf size.
getRecvByteBufAllocatorSizeMax() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get Recv ByteBuf allocator max buf size.
getRecvByteBufAllocatorSizeMin() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get Recv ByteBuf allocator min buf size.
getRegion(BookieId) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
getRegistrationClient() - Method in class org.apache.bookkeeper.client.DefaultBookieAddressResolver
 
getRegistrationClientClass() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
since 4.7.0
getRegistrationManagerClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Deprecated.
since 4.7.0, in favor of using AbstractConfiguration.getMetadataServiceUri()
getReorderThresholdPendingRequests() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the threshold for the number of pending requests beyond which to reorder reads.
getReplicateType() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
getReplicationRateByBytes() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the bytes rate of re-replication.
getRequestTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of ticks per wheel for the request timer.
getRequestTimerTickDurationMs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the tick duration in milliseconds.
getRereplicationEntryBatchSize() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the re-replication entry batch size.
getResult() - Method in class org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementResult
 
getReturnRc(int) - Method in class org.apache.bookkeeper.client.BookKeeper
 
getReturnRc(BookieClient, int) - Static method in class org.apache.bookkeeper.client.BookKeeper
 
getRwRereplicateBackoffMs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get how long to backoff when encountering exception on rereplicating a ledger.
getSample() - Method in interface org.apache.bookkeeper.stats.Gauge
 
getSample() - Method in class org.apache.bookkeeper.stats.prometheus.SimpleGauge
 
getScheduler() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getScheduler() - Method in interface org.apache.bookkeeper.client.ClientContext
 
getScope() - Method in class org.apache.bookkeeper.stats.prometheus.ScopeContext
 
getSequence() - Method in class org.apache.bookkeeper.client.SyncCounter
 
getServerNumAcceptorThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of Acceptor threads.
getServerNumIOThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of IO threads.
getServerSockKeepalive() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get socket keepalive.
getServerSockLinger() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Timeout to drain the socket on close.
getServerTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is tcp connection no delay.
getServerWriteBufferHighWaterMark() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get server netty channel write buffer high water mark.
getServerWriteBufferLowWaterMark() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get server netty channel write buffer low water mark.
getShadedLedgerManagerFactoryClassPrefix() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the class prefix of the shaded ledger manager factory class name allowed to be used for instantiating ledger manager factory.
getSkipListArenaChunkSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes we should use as chunk allocation for org.apache.bookkeeper.bookie.SkipListArena.
getSkipListArenaMaxAllocSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the max size we should allocate from the skiplist arena.
getSkipListSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get skip list data size limitation (default 64MB).
getSnapshot() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns a snapshot of this timer.
getSortedLedgerStorageEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Check if sorted-ledger storage enabled (default true).
getSpeculativeReadCounter() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getSpeculativeReadCounter() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getSpeculativeReadLACTimeoutBackoffMultiplier() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Multipler to use when determining time between successive speculative read LAC requests.
getSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the period of time after which a speculative entry read should be triggered.
getSpeculativeReadTimeoutBackoffMultiplier() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Multipler to use when determining time between successive speculative read requests.
getSpeculativeTask() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
getStartTLSTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Return the timeout value for startTLS request.
getState() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the state of the metadata.
getState() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getStatsLogger() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CachingStatsProvider
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.codahale.FastCodahaleMetricsProvider
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsProvider
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider
 
getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
getStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsProvider
Return the stats logger to a given scope.
getStatsName(String...) - Method in class org.apache.bookkeeper.stats.CachingStatsProvider
 
getStatsName(String...) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
getStatsName(String...) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
getStatsName(String...) - Method in interface org.apache.bookkeeper.stats.StatsProvider
Return the fully qualified stats name comprised of given statsComponents.
getStatsProviderClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the stats provider used by bookie.
getStdDev() - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getStickyReadBookieIndex(LedgerMetadata, Optional<Integer>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Select one bookie to the "sticky" bookie where all reads for a particular ledger will be directed to.
getStoreSystemtimeAsLedgerCreationTime() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Return the flag that indicates whether client is using system time as the ledger creation time when creating ledgers.
getStoreSystemTimeAsLedgerUnderreplicatedMarkTime() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Return the flag that indicates whether auditor is using system time as underreplicated ledger mark time.
getSum(boolean) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
getTaskExecutionWarnTimeMicros() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get task execution duration which triggers a warning.
getTcpUserTimeoutMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty TCP user timeout in millis (only for Epoll channels).
getThis() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Trickery to allow inheritance with fluent style.
getThis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
 
getThis() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
getThreadPool() - Method in class org.apache.bookkeeper.stats.ThreadRegistry.ThreadPoolThread
 
getThreadScopedCounter(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
Thread-scoped stats not currently supported.
getThreadScopedCounter(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
Thread-scoped stats not currently supported.
getThreadScopedCounter(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
getThreadScopedCounter(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
getThreadScopedCounter(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
getThreadScopedCounter(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
 
getThreadScopedOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
Thread-scoped stats not currently supported.
getThreadScopedOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
Thread-scoped stats not currently supported.
getThreadScopedOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
getThreadScopedOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
getThreadScopedOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
getThreadScopedOpStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
 
getThrottleValue() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get throttle value.
getTime() - Method in class org.apache.bookkeeper.stats.codahale.FastTimer
Returns the current absolute time (in seconds).
getTimeoutMonitorIntervalSec() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the interval between successive executions of the operation timeout monitor.
getTimeoutTaskIntervalMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
getTimeoutTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get number of ticks that used for timeout timer.
getTimeoutTimerTickDurationMs() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the tick duration in milliseconds that used for timeout timer.
getTLSCertFilesRefreshDurationSeconds() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get tls certificate files refresh duration in seconds.
getTLSCertificatePath() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the path to file containing TLS Certificate.
getTLSCertificatePath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the path to file containing TLS Certificate.
getTLSClientAuthentication() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Whether the client will send an TLS certificate on TLS-handshake.
getTLSEnabledCipherSuites() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the list of enabled TLS cipher suites.
getTLSEnabledProtocols() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the list of enabled TLS protocols.
getTLSKeyStore() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the keystore path for the client.
getTLSKeyStore() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the keystore path for the client.
getTLSKeyStorePasswordPath() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the path to file containing keystore password, if the client keystore is password protected.
getTLSKeyStorePasswordPath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the path to file containing keystore password if the client keystore is password protected.
getTLSKeyStoreType() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the keystore type for client.
getTLSKeyStoreType() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the keystore type for client.
getTLSProvider() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get TLS Provider (JDK or OpenSSL).
getTLSProviderFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the security provider factory class name.
getTLSTrustStore() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the truststore path for the client.
getTLSTrustStore() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the truststore path for the client.
getTLSTrustStorePasswordPath() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the path to file containing truststore password, if the client truststore is password protected.
getTLSTrustStorePasswordPath() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the path to file containing truststore password if the client truststore is password protected.
getTLSTrustStoreType() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the truststore type for client.
getTLSTrustStoreType() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the truststore type for client.
getTotalDiskSpace() - Method in class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo
 
getTypeNameSuffix(Collector.Type) - Static method in class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat
 
getTypeStr(Collector.Type) - Static method in class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat
 
getUnderlyingLedgerManager() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getUnderreplicatedLedgerRecoveryGracePeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Gets the grace period (in seconds) for underreplicated ledgers recovery.
getUpgradeDomain() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation
 
getUseHostNameAsBookieID() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether bookie is using hostname for registration and in ledger metadata.
getUseShortHostName() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
If bookie is using hostname for registration and in ledger metadata then whether to use short hostname or FQDN hostname.
getUseTransactionalCompaction() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to use transactional compaction and using a separate log for compaction or not.
getUseV2WireProtocol() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Use older Bookkeeper wire protocol (no protobuf).
getValue() - Method in enum org.apache.bookkeeper.client.api.WriteFlag
 
getValue(double) - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getValues() - Method in class org.apache.bookkeeper.stats.codahale.FastSnapshot
 
getVerifyMetadataOnGC() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the bookie is configured to double check prior to gc.
getVersionedLedgerMetadata() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
getWaitTimeoutOnBackpressureMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Timeout controlling wait on request send in case of unresponsive bookie(s) (i.e.
getWaitTimeoutOnResponseBackpressureMillis() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Timeout controlling wait on response send in case of unresponsive client (i.e.
getWeight() - Method in class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo
 
getWeight() - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection.WeightedObject
 
getWriteBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes used as capacity for the write buffer.
getWriteDelayedDueToNotEnoughFaultDomains() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getWriteDelayedDueToNotEnoughFaultDomains() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getWriteDelayedDueToNotEnoughFaultDomainsLatency() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getWriteDelayedDueToNotEnoughFaultDomainsLatency() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getWriteFlags() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
getWriteFlags(int) - Static method in enum org.apache.bookkeeper.client.api.WriteFlag
Converts a set of flags from a binary representation.
getWriteFlagsValue(EnumSet<WriteFlag>) - Static method in enum org.apache.bookkeeper.client.api.WriteFlag
Converts a set of flags from a binary representation.
getWriteLacOpLogger() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getWriteLacOpLogger() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getWriteQuorumSize() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns the write quorum size of this ledger.
getWriteQuorumSize() - Method in interface org.apache.bookkeeper.client.DistributionSchedule
 
getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getWriteSet(long) - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Return the set of bookie indices to send the message to.
getWriteSet(long) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getWriteSetBookieIndex(long, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Return the WriteSet bookie index for a given and index in the WriteSet.
getWriteSetBookieIndex(long, int) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
getWriteSetForReadOperation(long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Return a DistributionSchedule.WriteSet suitable for reading a particular entry.
getWriteTimedOutDueToNotEnoughFaultDomains() - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
getWriteTimedOutDueToNotEnoughFaultDomains() - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
getZkAvailableBookiesPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Deprecated.
getZkLedgersRootPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Deprecated.
getZkRequestRateLimit() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get zookeeper access request rate limit.
getZkRetryBackoffMaxMs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get zookeeper client backoff retry max time in millis.
getZkRetryBackoffMaxRetries() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get zookeeper client backoff max retry times.
getZkRetryBackoffStartMs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get zookeeper client backoff retry start time in millis.
getZkServers() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Deprecated.
since 4.7.0
getZkTimeout() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get zookeeper timeout.
getZone() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation
 
getZoneAwareNodeLocation(BookieId) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
getZoneAwareNodeLocation(BookieNode) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 

H

handle - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
Handle - Interface in org.apache.bookkeeper.client.api
Handle to manage an open ledger.
handleBookieFailure(Map<Integer, BookieId>) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
handleBookieFailure(Map<Integer, BookieId>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
For a read only ledger handle, this method will only ever be called during recovery, when we are reading forward from LAC and writing back those entries.
handleBookiesThatJoined(Set<BookieId>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Handle bookies that joined.
handleBookiesThatJoined(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
handleBookiesThatJoined(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
handleBookiesThatJoined(Set<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
handleBookiesThatJoined(Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
handleBookiesThatLeft(Set<BookieId>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Handle bookies that left.
handleBookiesThatLeft(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
handleBookiesThatLeft(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
handleBookiesThatLeft(Set<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
handleBookiesThatLeft(Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
HANDLER - Static variable in exception org.apache.bookkeeper.client.api.BKException
 
HANDLER - Static variable in exception org.apache.bookkeeper.client.BKException
 
handleUnrecoverableErrorDuringAdd(int) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
handleUnrecoverableErrorDuringAdd(int) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
happensAfter() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The metric name of an operation that happens after the operation of this metric.
hasDelayedWriteFailedBookies() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
hasEntry() - Method in interface org.apache.bookkeeper.client.api.LastConfirmedAndEntry
Whether this entity contains an entry.
hasEntry() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
Whether this entity contains an entry.
hasEntry(long, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule
Whether entry presents on given bookie index.
hasEntry(long, int) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
hashCode() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
hashCode() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
hashCode() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation
 
hashCode() - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
hashCode() - Method in class org.apache.bookkeeper.stats.otel.ScopeContext
 
hashCode() - Method in class org.apache.bookkeeper.stats.prometheus.ScopeContext
 
hasNext() - Method in interface org.apache.bookkeeper.client.api.LedgersIterator
Return true if there is at least one ledger to visit.
hasNext() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
hasPassword() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Whether the metadata contains the password and digest type for the ledger.
hasPassword() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
In versions 4.1.0 and below, the digest type and password were not stored in the metadata.
hasRun - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
hasValidResponse - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
heardFromHostsBitSet - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
help() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The help message of this stats.
historyBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
HTTP_SERVER_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_HOST - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_KEY_STORE_PASSWORD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_KEY_STORE_PATH - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_TLS_ENABLE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_TRUST_STORE_PASSWORD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
HTTP_SERVER_TRUST_STORE_PATH - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

I

i - Variable in class org.apache.bookkeeper.client.SyncCounter
 
IGNORE_EXTRA_SERVER_COMPONENTS_STARTUP_FAILURES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
IGNORE_LOCAL_NODE_IN_PLACEMENT_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ignoreLocalNodeInPlacementPolicy - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
IllegalOpException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Operation is illegal.
IN_FLIGHT_READ_ENTRY_NUM_IN_LEDGER_CHECKER - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
IN_RECOVERY - org.apache.bookkeeper.client.api.LedgerMetadata.State
A reader has tried to, or may be trying to recover the ledger.
inc() - Method in class org.apache.bookkeeper.client.SyncCounter
 
inc() - Method in interface org.apache.bookkeeper.stats.Counter
Increment the value associated with this stat.
inc() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
inc() - Method in class org.apache.bookkeeper.stats.otel.OtelCounter
 
inc() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
inc() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter
 
IncorrectParameterException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Incorrect parameters (operations are absolutely not executed).
INDEX_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
indexOf(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Index of a specified bookie index.
initBookie(ServerConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Initializes bookie, by making sure that the journalDir, ledgerDirs and indexDirs are empty and there is no registered Bookie with this BookieId.
initialBlockingBookieRead() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
Blocks until bookies are read from zookeeper, used in the BookKeeper constructor.
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Initialize the policy.
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
initialize(DNSToSwitchMapping, HashedWheelTimer, boolean, int, int, boolean, int, int, boolean, boolean, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
initialize(DNSToSwitchMapping, HashedWheelTimer, boolean, int, int, boolean, int, int, boolean, boolean, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
Initialize the policy.
initializeEnsemblePlacementPolicy(ClientConfiguration, DNSToSwitchMapping, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.BookKeeper
 
initializeThread(Map<String, String>) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
initializeThread(Map<String, String>) - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
initializeWriteHandleState() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
initializeWriteHandleState() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
initiate() - Method in class org.apache.bookkeeper.client.ForceLedgerOp
 
initiate() - Method in class org.apache.bookkeeper.client.LedgerCreateOp
Initiates the operation.
initiate() - Method in class org.apache.bookkeeper.client.LedgerDeleteOp
Initiates the operation.
initiate() - Method in class org.apache.bookkeeper.client.LedgerOpenOp
Inititates the ledger open operation.
initiate() - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
initiate() - Method in class org.apache.bookkeeper.client.PendingAddOp
Initiate the add operation.
initiate() - Method in class org.apache.bookkeeper.client.PendingReadLacOp
 
initiate() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
initiate() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
initiate() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
initiate() - Method in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
initiate(ByteBufList) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp
 
initiateAdv(long) - Method in class org.apache.bookkeeper.client.LedgerCreateOp
Initiates the operation to return LedgerHandleAdv.
initiateSpeculativeRequest(ScheduledExecutorService, SpeculativeRequestExecutor) - Method in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy
Initialize the speculative request execution policy.
initiateSpeculativeRequest(ScheduledExecutorService, SpeculativeRequestExecutor) - Method in interface org.apache.bookkeeper.client.SpeculativeRequestExecutionPolicy
Initialize the speculative request execution policy and initiate requests.
initiateWithFencing() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
initiateWithoutRecovery() - Method in class org.apache.bookkeeper.client.LedgerOpenOp
Inititates the ledger open operation without recovery.
initIfNecessary() - Method in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
initNewCluster(ServerConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Intializes new cluster by creating required znodes for the cluster.
instance - Static variable in class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback
 
INSTANCE - Static variable in class org.apache.bookkeeper.client.SyncCallbackUtils.LastAddConfirmedCallback
 
INSTANCE - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
 
INSTANCE - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.TruePredicate
 
INSTANCE - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger
 
InterfaceAudience - Class in org.apache.bookkeeper.common.annotation
Annotation to inform users of a package, class or method's intended audience.
InterfaceAudience.LimitedPrivate - Annotation Type in org.apache.bookkeeper.common.annotation
Intended for use only within the project(s) specified in the annotation.
InterfaceAudience.Private - Annotation Type in org.apache.bookkeeper.common.annotation
Intended for use only within bookkeeper itself.
InterfaceAudience.Public - Annotation Type in org.apache.bookkeeper.common.annotation
Intended for use by any project or application.
InterfaceStability - Class in org.apache.bookkeeper.common.annotation
Annotation to inform users of how much to rely on a particular package, class or method not changing over time.
InterfaceStability.Evolving - Annotation Type in org.apache.bookkeeper.common.annotation
Evolving, but can break compatibility at minor release (i.e.
InterfaceStability.Stable - Annotation Type in org.apache.bookkeeper.common.annotation
Can evolve while retaining compatibility for minor release boundaries.; can break compatibility only at major release (ie.
InterfaceStability.Unstable - Annotation Type in org.apache.bookkeeper.common.annotation
No guarantee is provided as to reliability or stability across any level of release granularity.
internalConf - Variable in class org.apache.bookkeeper.client.BookKeeper
 
InterruptedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Synchronous operations are interrupted.
INVALID_ENTRY_ID - Static variable in class org.apache.bookkeeper.client.LedgerHandle
Invalid entry id.
INVALID_LEDGER_ID - Static variable in class org.apache.bookkeeper.client.LedgerHandle
Invalid ledger id.
InvalidFragmentException() - Constructor for exception org.apache.bookkeeper.client.LedgerChecker.InvalidFragmentException
 
IS_FORCE_GC_ALLOW_WHEN_NO_SPACE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
IS_THROTTLE_BY_BYTES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
isAdheringToPolicy() - Method in class org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementResult
Deprecated.
isAllowMultipleDirsUnderSameDiskPartition() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
returns whether it is allowed to have multiple ledger/index/journal Directories in the same filesystem diskpartition.
isAutoRecoveryDaemonEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the Bookie itself can start auto-recovery service also or not.
isAvailable() - Method in interface org.apache.bookkeeper.feature.Feature
Whether this feature is available or not.
isAvailable() - Method in class org.apache.bookkeeper.feature.FixedValueFeature
 
isBookieHealthCheckEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Check if bookie health check is enabled.
isBookieUnavailable(BookieId) - Method in interface org.apache.bookkeeper.client.BookieWatcher
Determine if a bookie should be considered unavailable.
isBookieUnavailable(BookieId) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
Determine if a bookie should be considered unavailable.
isBusyWaitEnabled() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Return whether the busy-wait is enabled for BookKeeper and Netty IO threads.
isClientClosed() - Method in interface org.apache.bookkeeper.client.ClientContext
 
isClosed() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata
Returns whether the ledger is sealed or not.
isClosed() - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Returns whether the ledger is sealed or not.
isClosed() - Method in class org.apache.bookkeeper.client.BookKeeper
 
isClosed() - Method in class org.apache.bookkeeper.client.LedgerFragment
Returns true, if and only if the ledger fragment will never be modified by any of the clients in future, otherwise false.
isClosed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Returns whether the ledger is sealed or not.
isClosed() - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
isClosed(long) - Method in class org.apache.bookkeeper.client.BookKeeper
Check whether the ledger with identifier lId has been closed.
isClosedComplete(int, boolean, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.IsClosedCallback
Callback definition for isClosed operation.
isComplete() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Whether the read request completed.
isComplete() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Whether the read request completed.
isDataIntegrityCheckingEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
isDataIntegrityStampMissingCookiesEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
isDisableServerSocketBind() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to disable bind of server-side sockets.
isEnableLocalTransport() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to listen for local JVM clients.
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
returns boolean value specifying if the ensemble of the segment is adhering to the ensemble placement policy for the given writeQuorumSize and ackQuorumSize.
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
returns AdherenceLevel if the Ensemble is strictly/softly/fails adhering to placement policy, like in the case of RackawareEnsemblePlacementPolicy, bookies in the writeset are from 'minNumRacksPerWriteQuorum' number of racks.
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
isEnsembleAdheringToPlacementPolicy(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
isEntryLogFilePreAllocationEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is entry log file preallocation enabled.
isEntryLogPerLedgerEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
isForceAllowCompaction() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
The force compaction is allowed or not when disabling the entry log compaction.
isForceReadOnlyBookie() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the Bookie is force started in read only mode or not.
isGcEntryLogMetadataCacheEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the bookie is configured to use persistent entrylogMetadataMap.
isHandleWritable() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
isHttpServerEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to start the http server or not.
isHttpServerTlsEnable() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get if Http Server Tls enable.
isLocalConsistencyCheckOnStartup() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
True if a local consistency check should be performed on startup.
isLocalScrubEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether local scrub is enabled.
isNettyUsePooledBuffers() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
isPersistBookieStatusEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to persist the bookie status so that when bookie server restarts, it will continue using the previous status.
isReadOnlyModeEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether read-only mode is enabled.
isReadOnlyModeOnAnyDiskFullEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether read-only mode is enable when any disk is full.
isReadWorkerThreadsThrottlingEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the auto-throttling status of the read-worker threads.
isRecoveryAdd - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
isRecoveryRead - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
isReorderReadSequenceEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
If reorder read sequence enabled or not.
isRepairedPlacementPolicyNotAdheringBookieEnable() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Now the feature only support RackawareEnsemblePlacementPolicy.
isSanityCheckMetricsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Flag to enable sanity check metrics in bookie stats.
isShadedLedgerManagerFactoryClassAllowed() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Is shaded ledger manager factory class name allowed to be used for instantiating ledger manager factory.
isSkipReplayJournalInvalidRecord() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
isStatisticsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is statistics enabled.
isStickyReadsEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
If read operation should be sticky to a single bookie or not.
isStoredEntryId(long, int) - Method in class org.apache.bookkeeper.client.LedgerFragment
 
issueSpeculativeRequest() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Issues a speculative request and indicates if more speculative requests should be issued.
issueSpeculativeRequest() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
Speculative Read Logic.
issueSpeculativeRequest() - Method in interface org.apache.bookkeeper.client.SpeculativeRequestExecutor
Issues a speculative request and indicates if more speculative requests should be issued.
isThreadInitialized() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
isThreadInitialized() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
isUseTargetEntryLogSizeForGc() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
 
isWeighted - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
isZkEnableSecurity() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Are z-node created with strict ACLs.
iterator() - Method in interface org.apache.bookkeeper.client.api.LedgerEntries
Get an iterator over all the ledger entries contained in the LedgerEntries object.
iterator() - Method in interface org.apache.bookkeeper.client.api.ListLedgersResult
Creates a LedgersIterator.
iterator() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
iterator() - Method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl
Get an iterator over all the ledger entries contained in the LedgerEntries object.
ITopologyAwareEnsemblePlacementPolicy<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client
Interface for topology aware ensemble placement policy.
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client
Ensemble used to hold the result of an ensemble selected for placement.
ITopologyAwareEnsemblePlacementPolicy.Predicate<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client
Predicate used when choosing an ensemble.

J

jmx - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
JOURNAL_ADAPTIVE_GROUP_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_ALIGNMENT_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_ENTRIES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_WRITES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_CHANNEL_PROVIDER - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_DIR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FLUSH_WHEN_QUEUE_EMPTY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FORMAT_VERSION_TO_WRITE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_MAX_GROUP_WAIT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_MAX_MEMORY_SIZE_MB - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_PAGECACHE_FLUSH_INTERVAL_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_PRE_ALLOC_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_QUEUE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_REMOVE_FROM_PAGE_CACHE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_REUSE_FILES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_SYNC_DATA - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_WRITE_DATA - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

K

knownBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 

L

lac - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
LAC_UPDATE_HITS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LAC_UPDATE_MISSES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
lacUpdateHitsCounter - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
lacUpdateMissesCounter - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
lastAddConfirmed - Variable in class org.apache.bookkeeper.client.LedgerHandle
Last entryId which has been confirmed to be written durably to the bookies.
LastAddConfirmedCallback() - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.LastAddConfirmedCallback
 
lastAddPushed - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
LastConfirmedAndEntry - Interface in org.apache.bookkeeper.client.api
This contains LastAddConfirmed entryId and a LedgerEntry wanted to read.
LastConfirmedAndEntryImpl - Class in org.apache.bookkeeper.client.impl
This contains LastAddConfirmed entryId and a LedgerEntry wanted to read.
LastConfirmedAndEntryImpl(Recycler.Handle<LastConfirmedAndEntryImpl>) - Constructor for class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
 
LastConfirmedCtx() - Constructor for class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
lastEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
lastEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
lastSeenError - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
lastSeenError - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
lastSeenError - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
LEDGER_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LEDGER_ENSEMBLE_BOOKIE_DISTRIBUTION - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_MANAGER_FACTORY_DISABLE_CLASS_CHECK - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_MANAGER_TYPE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_METADATA_ROCKSDB_CONF - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LEDGER_RECOVER_ADD_ENTRIES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LEDGER_RECOVER_READ_ENTRIES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LEDGER_STORAGE_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LEDGER_STORAGE_CLASS_KEY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LedgerChecker - Class in org.apache.bookkeeper.client
A utility class to check the complete ledger and finds the UnderReplicated fragments if any.
LedgerChecker(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerChecker(BookKeeper, int) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerChecker(BookieClient, BookieWatcher) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerChecker(BookieClient, BookieWatcher, int) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerChecker.InvalidFragmentException - Exception in org.apache.bookkeeper.client
 
LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Executing operations on a closed ledger handle.
LedgerCreateOp - Class in org.apache.bookkeeper.client
Encapsulates asynchronous ledger create operation.
LedgerCreateOp(BookKeeper, int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>, EnumSet<WriteFlag>, BookKeeperClientStats) - Constructor for class org.apache.bookkeeper.client.LedgerCreateOp
Constructor.
LedgerCreateOp.CreateBuilderImpl - Class in org.apache.bookkeeper.client
 
LedgerDeleteOp - Class in org.apache.bookkeeper.client
Encapsulates asynchronous ledger delete operation.
LedgerDeleteOp(BookKeeper, BookKeeperClientStats, long, AsyncCallback.DeleteCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerDeleteOp
Constructor.
LedgerDeleteOp.DeleteBuilderImpl - Class in org.apache.bookkeeper.client
 
LedgerEntries - Interface in org.apache.bookkeeper.client.api
Interface to wrap a sequence of entries.
LedgerEntriesImpl - Class in org.apache.bookkeeper.client.impl
Ledger entries implementation.
LedgerEntriesIterable(long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
LedgerEntriesIterable(long, long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
LedgerEntriesIterator(long, long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
LedgerEntry - Class in org.apache.bookkeeper.client
Ledger entry.
LedgerEntry - Interface in org.apache.bookkeeper.client.api
An entry in a ledger.
LedgerEntry(LedgerEntryImpl) - Constructor for class org.apache.bookkeeper.client.LedgerEntry
 
LedgerEntryImpl - Class in org.apache.bookkeeper.client.impl
Ledger entry.
LedgerEntryRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
LedgerExistException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Ledger already exists.
LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Operations failed due to ledgers are fenced.
LedgerFragment - Class in org.apache.bookkeeper.client
Represents the entries of a segment of a ledger which are stored on subset of bookies in the segments bookie ensemble.
LedgerFragment(LedgerFragment, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerFragment
 
LedgerFragment(LedgerHandle, long, long, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerFragment
 
LedgerFragment.ReplicateType - Enum in org.apache.bookkeeper.client
ReplicateType.
LedgerFragmentReplicator - Class in org.apache.bookkeeper.client
This is the helper class for replicating the fragments from one bookie to another.
LedgerFragmentReplicator(BookKeeper, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator
 
LedgerFragmentReplicator(BookKeeper, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator
 
LedgerFragmentReplicator.SingleFragmentCallback - Class in org.apache.bookkeeper.client
Callback for recovery of a single ledger fragment.
LedgerFragmentReplicator.Throttler - Class in org.apache.bookkeeper.client
 
ledgerFragmentsMcb - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
LedgerHandle - Class in org.apache.bookkeeper.client
Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.
LedgerHandle(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], EnumSet<WriteFlag>) - Constructor for class org.apache.bookkeeper.client.LedgerHandle
 
LedgerHandle.LastConfirmedCtx - Class in org.apache.bookkeeper.client
Context objects for synchronous call to read last confirmed.
LedgerHandle.NoopCloseCallback - Class in org.apache.bookkeeper.client
 
LedgerHandleAdv - Class in org.apache.bookkeeper.client
Ledger Advanced handle extends LedgerHandle to provide API to add entries with user supplied entryIds.
LedgerHandleAdv(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], EnumSet<WriteFlag>) - Constructor for class org.apache.bookkeeper.client.LedgerHandleAdv
 
LedgerHandleAdv.PendingOpsComparator - Class in org.apache.bookkeeper.client
 
ledgerId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable
 
ledgerId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
ledgerId - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
ledgerId - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
ledgerId - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
ledgerId - Variable in class org.apache.bookkeeper.client.LedgerEntry
 
ledgerId - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
ledgerId - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
LEDGERID_FORMATTER_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ledgerIdGenerator - Variable in class org.apache.bookkeeper.client.BookKeeper
 
LedgerIdOverflowException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Ledger id overflow happens on ledger manager.
ledgerKey - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
ledgerManager - Variable in class org.apache.bookkeeper.client.BookKeeper
 
ledgerManager - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
ledgerManagerFactory - Variable in class org.apache.bookkeeper.client.BookKeeper
 
LedgerMetadata - Interface in org.apache.bookkeeper.client.api
Represents the client-side metadata of a ledger.
LedgerMetadata.State - Enum in org.apache.bookkeeper.client.api
Possible metadata states.
LedgerMetadataBuilder - Class in org.apache.bookkeeper.client
Builder for building LedgerMetadata objects.
LedgerMetadataBuilder() - Constructor for class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
LedgerMetadataImpl - Class in org.apache.bookkeeper.client
This class encapsulates all the ledger metadata that is persistently stored in metadata store.
LedgerMetadataImpl(long, int, int, int, int, LedgerMetadata.State, Optional<Long>, Optional<Long>, Map<Long, List<BookieId>>, Optional<DigestType>, Optional<byte[]>, long, boolean, long, Map<String, byte[]>) - Constructor for class org.apache.bookkeeper.client.LedgerMetadataImpl
 
LedgerMetadataUtils - Class in org.apache.bookkeeper.client
Utilities for working with ledger metadata.
LedgerMetadataUtils() - Constructor for class org.apache.bookkeeper.client.LedgerMetadataUtils
 
LedgerOpenOp - Class in org.apache.bookkeeper.client
Encapsulates the ledger open operation.
LedgerOpenOp(BookKeeper, BookKeeperClientStats, long, AsyncCallback.OpenCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp
 
LedgerOpenOp(BookKeeper, BookKeeperClientStats, long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp
Constructor.
LedgerOpenOp.OpenBuilderImpl - Class in org.apache.bookkeeper.client
 
LedgerRecoveryException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Ledger recovery operations failed.
LedgerRecoveryOp - Class in org.apache.bookkeeper.client
This class encapsulated the ledger recovery operation.
LedgerRecoveryOp(LedgerHandle, ClientContext) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp
 
LedgerRecoveryOp.RecoveryReadOp - Class in org.apache.bookkeeper.client
 
LedgersIterator - Interface in org.apache.bookkeeper.client.api
Iterator for ledgers.
length - Variable in class org.apache.bookkeeper.client.LedgerEntry
 
length - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
lh - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
lh - Variable in class org.apache.bookkeeper.client.ForceLedgerOp
 
lh - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
lh - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
lh - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
lh - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
lh - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
lh - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
lh - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
lh - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
lh - Variable in class org.apache.bookkeeper.client.SyncCounter
 
lh - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
LIMIT_STATS_LOGGING - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
listener - Variable in class org.apache.bookkeeper.client.ListenerBasedPendingReadOp
 
ListenerBasedPendingReadOp - Class in org.apache.bookkeeper.client
 
ListenerBasedPendingReadOp(LedgerHandle, ClientContext, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object, boolean) - Constructor for class org.apache.bookkeeper.client.ListenerBasedPendingReadOp
 
LISTENING_INTERFACE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
listLedgers() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.
ListLedgersResult - Interface in org.apache.bookkeeper.client.api
Utility container for listing ledgers.
ListLedgersResultBuilder - Interface in org.apache.bookkeeper.client.api
Builder-style interface to list exiting ledgers.
loadConf(URL) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configurations in precedence order.
loadConf(CompositeConfiguration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configuration from other configuration.
loadStatsProvider(String) - Static method in class org.apache.bookkeeper.stats.Stats
 
loadStatsProvider(Configuration) - Static method in class org.apache.bookkeeper.stats.Stats
 
LOCAL_CONSISTENCY_CHECK_ON_STARTUP - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LOCAL_FAIL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
LOCAL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
LOCAL_SCRUB_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LOCAL_SCRUB_RATE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
localNode - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
LOCK_RELEASE_OF_FAILED_LEDGER_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LOG - Static variable in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
LOG - Static variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
LOG - Static variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
LOG - Static variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerDeleteOp
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerHandle
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerHandleAdv
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerMetadataImpl
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerMetadataUtils
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
LOG - Static variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
LOG - Static variable in class org.apache.bookkeeper.client.MetadataUpdateLoop
 
LOG - Static variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
LOG - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
LOG - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
LOG - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
LOG - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
LOG - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
LOG - Static variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
LOG - Static variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
LOG - Static variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
LOG - Static variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
LOG - Static variable in class org.apache.bookkeeper.stats.Stats
 
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Log error errMsg and reattempt read from host.
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest
 
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest
 
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Log error errMsg and reattempt read from host.
logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
LongAdderCounter - Class in org.apache.bookkeeper.stats.prometheus
Counter implementation based on LongAdder.
LongAdderCounter(Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.LongAdderCounter
 
LOST_BOOKIE_RECOVERY_DELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

M

MAC - org.apache.bookkeeper.client.api.DigestType
Entries are verified by applied MAC algorithm.
MAC - org.apache.bookkeeper.client.BookKeeper.DigestType
 
macManager - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
mainWorkerPool - Variable in class org.apache.bookkeeper.client.BookKeeper
 
MAJOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAJOR_COMPACTION_MAX_TIME_MILLIS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAJOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
makeAdv() - Method in interface org.apache.bookkeeper.client.api.CreateBuilder
Switch the ledger into 'Advanced' mode.
makeAdv() - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl
 
makeFeature(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
makeFeature(String) - Method in class org.apache.bookkeeper.feature.SettableFeatureProvider
 
makeName(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
makeProvider(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
makeProvider(String) - Method in class org.apache.bookkeeper.feature.SettableFeatureProvider
 
map - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
MASK_BITS - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
MAX_ADDS_IN_PROGRESS_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_ALLOWED_ENSEMBLE_CHANGES - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
MAX_BACKUP_JOURNALS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_JOURNAL_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_OPERATION_NUMBERS_IN_SINGLE_ROCKSDB_WRITE_BATCH - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_PENDING_ADD_REQUESTS_PER_THREAD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_PENDING_READ_REQUESTS_PER_THREAD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_READS_IN_PROGRESS_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_SPECULATIVE_READ_LAC_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
MAX_SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
maxAllowedEnsembleChanges - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
MAXIMUM_NUMBER_OF_ACTIVE_ENTRYLOGS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
maxLac - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
maxMissedReadsAllowed - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
maxProbabilityMultiplier - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
maxProbabilityMultiplier - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
maxRecoveredData - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
maxSpeculativeRequestTimeout - Variable in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy
 
maxWeightMultiple - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
maxWeightMultiple - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
maybeHandleDelayedWriteBookieFailure() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Send to next replica speculatively, if required and possible.
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest
 
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
Send to next replica speculatively, if required and possible.
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest
 
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Send to next replica speculatively, if required and possible.
maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
Send to next replica speculatively, if required and possible.
maybeTimeout() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
MEETS_SOFT - org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence
 
MEETS_STRICT - org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence
 
metadata - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
METADATA_SERVICE_URI - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
metadataDriver - Variable in class org.apache.bookkeeper.client.BookKeeper
 
metadataFormatVersion - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
metadataForRecovery - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
metadataLock - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
MetadataSerializationException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Failure to serialize metadata.
MetadataUpdateLoop - Class in org.apache.bookkeeper.client
Mechanism to safely update the metadata of a ledger.
MetadataUpdateLoop(LedgerManager, long, Supplier<Versioned<LedgerMetadata>>, MetadataUpdateLoop.NeedsUpdatePredicate, MetadataUpdateLoop.MetadataTransform, MetadataUpdateLoop.LocalValueUpdater) - Constructor for class org.apache.bookkeeper.client.MetadataUpdateLoop
 
MetadataUpdateLoop(LedgerManager, long, Supplier<Versioned<LedgerMetadata>>, MetadataUpdateLoop.NeedsUpdatePredicate, MetadataUpdateLoop.MetadataTransform, MetadataUpdateLoop.LocalValueUpdater, RateLimiter) - Constructor for class org.apache.bookkeeper.client.MetadataUpdateLoop
Construct the loop.
MetadataUpdateLoop.LocalValueUpdater - Interface in org.apache.bookkeeper.client
 
MetadataUpdateLoop.MetadataTransform - Interface in org.apache.bookkeeper.client
 
MetadataUpdateLoop.NeedsUpdatePredicate - Interface in org.apache.bookkeeper.client
 
MetadataUpdater(Versioned<LedgerMetadata>) - Constructor for class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater
 
MetadataVersionException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Bad version on executing metadata operations.
METASTORE_IMPL_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
METASTORE_MAX_ENTRIES_PER_SCAN - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
MetaStoreException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Meta store operations failed.
MetaStoreException() - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException
 
MetaStoreException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException
 
meter - Variable in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider
 
metricNameSet - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat
 
metrics - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
metrics - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
MIN_NUM_RACKS_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
MIN_NUM_ZONES_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
MIN_USABLESIZE_FOR_ENTRYLOG_CREATION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MIN_USABLESIZE_FOR_HIGH_PRIORITY_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MIN_USABLESIZE_FOR_INDEXFILE_CREATION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MINIMUM_REGIONS_FOR_DURABILITY_DEFAULT - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
minNumRacksPerWriteQuorum - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
minNumRacksPerWriteQuorum - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
minNumZonesPerWriteQuorum - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
MINOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MINOR_COMPACTION_MAX_TIME_MILLIS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MINOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
minRacksOrRegionsForDurability - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
minRegionsForDurability - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
moveAndShift(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Move an index from one position to another, shifting the other indices accordingly.
myNode - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
myRegion - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
myZone - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 

N

name - Variable in class org.apache.bookkeeper.feature.FixedValueFeature
 
name() - Method in interface org.apache.bookkeeper.feature.Feature
Returns a textual representation of the feature.
name() - Method in class org.apache.bookkeeper.feature.FixedValueFeature
 
name() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The name of this stats.
needsUpdate(LedgerMetadata) - Method in interface org.apache.bookkeeper.client.MetadataUpdateLoop.NeedsUpdatePredicate
 
NETTY_EXCEPTION_CNT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
NETTY_MAX_FRAME_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
NETTY_OPS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
NETTY_USE_POOLED_BUFFERS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NETWORK_TOPOLOGY_STABILIZE_PERIOD_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
newBuilder(ClientConfiguration) - Static method in interface org.apache.bookkeeper.client.api.BookKeeper
Create a new builder which can be used to boot a new BookKeeper client.
newCreateLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Start the creation of a new ledger.
newCreateLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper
 
newDeleteLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Delete an existing ledger.
newDeleteLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper
 
newEnsemble(int, int, int, Map<String, byte[]>) - Method in interface org.apache.bookkeeper.client.BookieWatcher
Create an ensemble with given ensembleSize and writeQuorumSize.
newEnsemble(int, int, int, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose numBookies bookies for ensemble.
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Create an ensemble with parent ensemble.
newEnsembleEntry(long, List<BookieId>) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
newEnsembleInternal(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
newInstance(StatsLogger) - Static method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
newListLedgersOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
List ledgers.
newListLedgersOp() - Method in class org.apache.bookkeeper.client.BookKeeper
 
newMetadata - Variable in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater
 
newOpenLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Open an existing ledger.
newOpenLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper
 
next() - Method in interface org.apache.bookkeeper.client.api.LedgersIterator
Return next ledger id.
next() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
nextEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
nextReplicaIndexToReadFrom - Variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
nextReplicaIndexToReadFrom - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
NoBookieAvailableException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Unused.
none - org.apache.bookkeeper.stats.codahale.FastTimer.Buckets
 
NONE - Static variable in enum org.apache.bookkeeper.client.api.WriteFlag
No flag is set, use default behaviour.
NoopCloseCallback() - Constructor for class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback
 
NoSuchEntryException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
No such entry exists.
NoSuchLedgerExistsException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
No such ledger exists.
NoSuchLedgerExistsOnMetadataServerException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
No such ledger exists one metadata server.
NOT_FOUND - Static variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
NOT_FOUND - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
NotEnoughBookiesException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Not enough bookies available to form an ensemble.
notifyWriteFailed(int, BookieId) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
nukeExistingCluster(ServerConfiguration, String, String, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Nukes existing cluster metadata.
NULL_WRITE_SET - Static variable in interface org.apache.bookkeeper.client.DistributionSchedule
 
nullCounter - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger
 
NullCounter() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter
 
nullOpStats - Variable in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
nullOpStatsLogger - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger
 
NullOpStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
nullStatsLogger - Variable in class org.apache.bookkeeper.stats.NullStatsProvider
 
NullStatsLogger - Class in org.apache.bookkeeper.stats
A no-op StatsLogger.
NullStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger
 
NullStatsLogger.NullCounter - Class in org.apache.bookkeeper.stats
A no-op Counter.
NullStatsLogger.NullOpStatsLogger - Class in org.apache.bookkeeper.stats
A no-op OpStatsLogger.
NullStatsProvider - Class in org.apache.bookkeeper.stats
A no-op stats provider implementation.
NullStatsProvider() - Constructor for class org.apache.bookkeeper.stats.NullStatsProvider
 
NUM_ADD_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_CHANNELS_PER_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUM_HIGH_PRIORITY_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_IO_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUM_JOURNAL_CALLBACK_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_LONG_POLL_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_READ_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUM_WRITABLE_BOOKIES_IN_DEFAULT_FAULTDOMAIN - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
NUM_WRITABLE_BOOKIES_IN_DEFAULT_RACK - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
NUMBER_OF_MEMTABLE_FLUSH_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
numBookiesMissingEntry - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
numEnsembleChanges - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
numMissedEntryReads - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
numPendingEntries - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
numPendings - Variable in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest
 
numPendings - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest
 
numResponsesPending - Variable in class org.apache.bookkeeper.client.PendingReadLacOp
 
numResponsesPending - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
numWritableBookiesInDefaultFaultDomain - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
numWritableBookiesInDefaultRack - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 

O

of(T, EnsemblePlacementPolicy.PlacementPolicyAdherence) - Static method in class org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementResult
 
OK - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Everything is OK.
oldBookie2NewBookie - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
onBookieRackChange(List<BookieId>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Handle rack change for the bookies.
onBookieRackChange(List<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
onBookieRackChange(List<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
onChanged(long, Versioned<LedgerMetadata>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
onEntryComplete(int, LedgerHandle, LedgerEntry, Object) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
onExit() - Method in class org.apache.bookkeeper.client.BookieInfoReader
 
OpBuilder<T> - Interface in org.apache.bookkeeper.client.api
Base interface for builders.
OPEN - org.apache.bookkeeper.client.api.LedgerMetadata.State
The ledger is open.
OPEN_FILE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_LEDGER_REREPLICATION_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
OpenBuilder - Interface in org.apache.bookkeeper.client.api
Builder-style interface to open exiting ledgers.
OpenBuilderBase - Class in org.apache.bookkeeper.client.impl
Base class for open builders which does the mundane builder stuff.
OpenBuilderBase() - Constructor for class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
OpenBuilderImpl(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp.OpenBuilderImpl
 
openComplete(int, LedgerHandle) - Method in class org.apache.bookkeeper.client.LedgerOpenOp
 
openComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback
Callback for asynchronous call to open ledger.
openComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncOpenCallback
Callback method for synchronous open operation.
openLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator.
openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous open ledger call.
openLedgerNoRecovery(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator without recovering the ledger.
openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous, unsafe open ledger call.
openOpLogger - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
OPPORTUNISTIC_STRIPING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
opStats - Variable in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider
 
opStats - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
OpStatsData - Class in org.apache.bookkeeper.stats
This class provides a read view of operation specific stats.
OpStatsData(long, long, double, long[]) - Constructor for class org.apache.bookkeeper.stats.OpStatsData
 
OpStatsLogger - Interface in org.apache.bookkeeper.stats
This interface handles logging of statistics related to each operation.
opStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger
 
orderedEnsemble - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
ordinal - Variable in class org.apache.bookkeeper.stats.ThreadRegistry.ThreadPoolThread
 
org.apache.bookkeeper.client - package org.apache.bookkeeper.client
BookKeeper Client.
org.apache.bookkeeper.client.api - package org.apache.bookkeeper.client.api
BookKeeper Client Public API.
org.apache.bookkeeper.client.impl - package org.apache.bookkeeper.client.impl
BookKeeper Client implementation package.
org.apache.bookkeeper.common.annotation - package org.apache.bookkeeper.common.annotation
Annotations used across the whole project.
org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf
Configurations used by bookkeeper.
org.apache.bookkeeper.feature - package org.apache.bookkeeper.feature
A feature-flag system that is used to proportionally control what features are enabled for the system.
org.apache.bookkeeper.stats - package org.apache.bookkeeper.stats
A lightweight stats library used for exporting bookkeeper stats.
org.apache.bookkeeper.stats.annotations - package org.apache.bookkeeper.stats.annotations
Annotations for bookkeeper stats api.
org.apache.bookkeeper.stats.codahale - package org.apache.bookkeeper.stats.codahale
A lightweight stats library implemention based on Codahale metrics library.
org.apache.bookkeeper.stats.otel - package org.apache.bookkeeper.stats.otel
A stats provider implementation based on OpenTelemetry.
org.apache.bookkeeper.stats.prometheus - package org.apache.bookkeeper.stats.prometheus
A stats provider implementation based on {@link https://prometheus.io/}.
OtelCounter - Class in org.apache.bookkeeper.stats.otel
 
OtelCounter(Meter, ScopeContext) - Constructor for class org.apache.bookkeeper.stats.otel.OtelCounter
 
OtelMetricsProvider - Class in org.apache.bookkeeper.stats.otel
 
OtelMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.otel.OtelMetricsProvider
 
OtelOpStatsLogger - Class in org.apache.bookkeeper.stats.otel
 
OtelOpStatsLogger(Meter, ScopeContext) - Constructor for class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
OtelStatsLogger - Class in org.apache.bookkeeper.stats.otel
 
OtelStatsLogger(OtelMetricsProvider, String, Attributes) - Constructor for class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
ownEventLoopGroup - Variable in class org.apache.bookkeeper.client.BookKeeper
 
ownTimer - Variable in class org.apache.bookkeeper.client.BookKeeper
 

P

PAGE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
PAGE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
parallelRead - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
parallelRead - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
parallelRead(boolean) - Method in class org.apache.bookkeeper.client.PendingReadOp
 
parallelRead(boolean) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
ParallelReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest
 
ParallelReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest
 
parent() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The parent metric name.
parentEnsemble - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
parentPredicate - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
parseBookieRegion(BookieId) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
PARTIAL - org.apache.bookkeeper.client.BookieInfoReader.State
 
passwd - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
passwd - Variable in class org.apache.bookkeeper.client.LedgerOpenOp
 
PASSWD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
password - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
payload - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
PCBC_TIMEOUT_TIMER_NUM_TICKS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PCBC_TIMEOUT_TIMER_TICK_DURATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PENDING_ADDS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
PendingAddOp - Class in org.apache.bookkeeper.client
This represents a pending add operation.
pendingAddOps - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
pendingAddsSequenceHead - Variable in class org.apache.bookkeeper.client.LedgerHandle
Next entryId which is expected to move forward during LedgerHandle.sendAddSuccessCallbacks().
PendingOpsComparator() - Constructor for class org.apache.bookkeeper.client.LedgerHandleAdv.PendingOpsComparator
 
PendingReadLacOp - Class in org.apache.bookkeeper.client
This represents a pending ReadLac operation.
PendingReadLacOp(LedgerHandle, BookieClient, List<BookieId>, PendingReadLacOp.LacCallback) - Constructor for class org.apache.bookkeeper.client.PendingReadLacOp
 
PendingReadLacOp.LacCallback - Interface in org.apache.bookkeeper.client
 
PendingReadOp - Class in org.apache.bookkeeper.client
Sequence of entries of a ledger that represents a pending read operation.
PendingReadOp(LedgerHandle, ClientContext, long, long, boolean) - Constructor for class org.apache.bookkeeper.client.PendingReadOp
 
PendingReadOp.LedgerEntryRequest - Class in org.apache.bookkeeper.client
 
PendingReadOp.ParallelReadRequest - Class in org.apache.bookkeeper.client
 
PendingReadOp.SequenceReadRequest - Class in org.apache.bookkeeper.client
 
PendingWriteLacOp - Class in org.apache.bookkeeper.client
This represents a pending WriteLac operation.
PendingWriteLacOp(LedgerHandle, ClientContext, List<BookieId>, AsyncCallback.AddLacCallback, Object) - Constructor for class org.apache.bookkeeper.client.PendingWriteLacOp
 
pendingWriteRequests - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
PERMITTED_STARTUP_USERS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
perRegionPlacement - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
PERSIST_BOOKIE_STATUS_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
piggyBackedLac - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
placementPolicy - Variable in class org.apache.bookkeeper.client.BookKeeper
 
PRESERVE_MDC_FOR_TASK_EXECUTION - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
processResult(int, String, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.ResultCallBack
 
processResult(int, String, Object) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback
 
PROMETHEUS_STATS_HTTP_ADDRESS - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PROMETHEUS_STATS_HTTP_ENABLE - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PROMETHEUS_STATS_HTTP_PORT - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PROMETHEUS_STATS_LATENCY_ROLLOVER_SECONDS - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PrometheusMetricsProvider - Class in org.apache.bookkeeper.stats.prometheus
A Prometheus based StatsProvider implementation.
PrometheusMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PrometheusMetricsProvider(CollectorRegistry) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
PrometheusServlet - Class in org.apache.bookkeeper.stats.prometheus
Servlet used to export metrics in prometheus text format.
PrometheusServlet(PrometheusMetricsProvider) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusServlet
 
PrometheusStatsLogger - Class in org.apache.bookkeeper.stats.prometheus
A Prometheus based StatsLogger implementation.
PrometheusStatsLogger(PrometheusMetricsProvider, String, Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
PrometheusTextFormat - Class in org.apache.bookkeeper.stats.prometheus
Logic to write metrics in Prometheus text format.
PrometheusTextFormat() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat
 
promise - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Protocol version is wrong (operations are absolutely not executed).
prov - Static variable in class org.apache.bookkeeper.stats.Stats
 

Q

quarantineBookie(BookieId) - Method in interface org.apache.bookkeeper.client.BookieWatcher
Quarantine bookie so it will not be preferred to be chosen for new ensembles.
quarantineBookie(BookieId) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
Quarantine bookie so it will not be preferred to be chosen for new ensembles.
quarantinedBookies - Variable in class org.apache.bookkeeper.client.BookieWatcherImpl
 
QuorumException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Unused.
qwcLatency - Variable in class org.apache.bookkeeper.client.PendingAddOp
 

R

RackawareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
A placement policy implementation use rack information for placing ensembles.
RackawareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
RackawareEnsemblePlacementPolicy(boolean) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
RackawareEnsemblePlacementPolicyImpl - Class in org.apache.bookkeeper.client
Simple rackware ensemble placement policy.
RackawareEnsemblePlacementPolicyImpl() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
RackawareEnsemblePlacementPolicyImpl(boolean) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
RackChangeNotifier - Interface in org.apache.bookkeeper.client
Notifier used by the RackawareEnsemblePlacementPolicy to get notified if a rack changes for a bookie.
RACKNAME_DISTANCE_FROM_LEAVES - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
RackOrRegionDurabilityCoverageSet() - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet
 
RackQuorumCoverageSet(int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
racksOrRegions - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
racksOrRegionsInQuorum - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
raise(String, Object...) - Method in class org.apache.bookkeeper.stats.AlertStatsLogger
Report an alertable condition".
rand - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
randomMax - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 
rc - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.SyncObject
 
rc - Variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
rc - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
rc - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
rc - Variable in class org.apache.bookkeeper.client.SyncCounter
 
read() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
Execute the read request.
read() - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest
 
read() - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest
 
read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
Execute the read request.
read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
read(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Read a sequence of entries synchronously.
READ_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
READ_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_LAST_CONFIRMED_AND_ENTRY - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_LAST_CONFIRMED_AND_ENTRY_RESPONSE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_ONLY_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
READ_ONLY_MODE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_ONLY_MODE_ON_ANY_DISK_FULL_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_OP_DM - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_OP_OUTSTANDING - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_REORDER_THRESHOLD_PENDING_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
READ_REQUESTS_REORDERED - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_SYSTEM_PROPERTIES_PROPERTY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
READ_WORKER_THREADS_THROTTLING_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
readAsync(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Read a sequence of entries asynchronously.
readAsync(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries asynchronously.
readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadCallback
Callback declaration.
readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncReadCallback
Implementation of callback interface for synchronous read method.
readCount - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
readDone - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
readEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries synchronously.
readEntries(long, long, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Read entries from a ledger synchronously.
readEntriesInternalAsync(long, long, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.PendingReadOp
 
readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.TryReadLastConfirmedOp
 
ReadException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Read operations failed (bookie error).
readExplicitLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
ReadHandle - Interface in org.apache.bookkeeper.client.api
Provide read access to a ledger.
ReadLACAndEntryRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
readLacComplete(int, long, ByteBuf, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.PendingReadLacOp
 
readLACSpeculativeRequestPolicy - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
readLastAddConfirmed() - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
readLastAddConfirmedAndEntry(long, long, boolean) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Asynchronous read specific entry and the latest last add confirmed.
readLastAddConfirmedAndEntryAsync(long, long, boolean) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Asynchronous read specific entry and the latest last add confirmed.
readLastAddConfirmedAndEntryAsync(long, long, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous read specific entry and the latest last add confirmed.
readLastAddConfirmedAsync() - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
readLastAddConfirmedAsync() - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
readLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains synchronously the last confirmed write from a quorum of bookies.
readLastConfirmedAndEntryComplete(int, long, LedgerEntry) - Method in interface org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback
 
readLastConfirmedAndEntryComplete(int, long, LedgerEntry, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedAndEntryCallback
Callback definition for bookie operation that allows reading the last add confirmed along with an entry within the last add confirmed range.
readLastConfirmedAndEntryComplete(int, long, LedgerEntry, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmedAndEntry
 
ReadLastConfirmedAndEntryOp - Class in org.apache.bookkeeper.client
Long poll read operation.
ReadLastConfirmedAndEntryOp(LedgerHandle, ClientContext, List<BookieId>, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback - Interface in org.apache.bookkeeper.client
Wrapper to get all recovered data from the request.
ReadLastConfirmedAndEntryOp.ParallelReadRequest - Class in org.apache.bookkeeper.client
 
ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest - Class in org.apache.bookkeeper.client
 
ReadLastConfirmedAndEntryOp.SequenceReadRequest - Class in org.apache.bookkeeper.client
 
readLastConfirmedComplete(int, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedCallback
Callback definition for bookie recover operations.
readLastConfirmedComplete(int, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmed
 
readLastConfirmedComplete(int, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncReadLastConfirmedCallback
Implementation of callback interface for synchronous read last confirmed method.
readLastConfirmedDataComplete(int, DigestManager.RecoveryData) - Method in interface org.apache.bookkeeper.client.ReadLastConfirmedOp.LastConfirmedDataCallback
 
ReadLastConfirmedOp - Class in org.apache.bookkeeper.client
This class encapsulated the read last confirmed operation.
ReadLastConfirmedOp(BookieClient, DistributionSchedule, DigestManager, long, List<BookieId>, byte[], ReadLastConfirmedOp.LastConfirmedDataCallback) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedOp
 
ReadLastConfirmedOp.LastConfirmedDataCallback - Interface in org.apache.bookkeeper.client
Wrapper to get all recovered data from the request.
readLastEntry() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
readOnlyBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
ReadOnlyLedgerHandle - Class in org.apache.bookkeeper.client
Read only ledger handle.
ReadOnlyLedgerHandle(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], boolean) - Constructor for class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
ReadOnlyLedgerHandle.MetadataUpdater - Class in org.apache.bookkeeper.client
 
readReorderedCounter - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
readSpeculativeRequestPolicy - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
readUnconfirmed(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Read a sequence of entries synchronously.
readUnconfirmedAsync(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle
Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.
readUnconfirmedAsync(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.
readUnconfirmedEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range.
This is the same of LedgerHandle.asyncReadUnconfirmedEntries(long, long, ReadCallback, Object)
ready() - Method in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
receivedResponseSet - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
recordReadErrorOnBookie(int) - Method in class org.apache.bookkeeper.client.LedgerHandle
Notify the LedgerHandle that a read operation was failed on a particular bookie.
recover(BookkeeperInternalCallbacks.GenericCallback<Void>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
recover(BookkeeperInternalCallbacks.GenericCallback<Void>, BookkeeperInternalCallbacks.ReadEntryListener, boolean) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
Recover the ledger.
RECOVER_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
recoverBookieData(long, Set<BookieId>, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
recoverBookieData(Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
recoverBookieData(Set<BookieId>, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
recoverBookieData(Set<BookieId>, boolean, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
recoverBookieData(BookieId) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback
Callback definition for bookie recover operations.
recovery - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase
 
RECOVERY_READ_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
recoveryReadBatchSize - Variable in class org.apache.bookkeeper.client.ClientInternalConf
 
RecoveryReadOp(LedgerHandle, ClientContext, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp
 
recycle() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet
Recycle this ack set when not used anymore.
recycle() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Recycle write set object when not in use.
recyclePendAddOpObject() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
REGION_AWARE_ANOMALOUS_ENSEMBLE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
RegionAwareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
A placement policy use region information in the network topology for placing ensembles.
RegionAwareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REGIONID_DISTANCE_FROM_LEAVES - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
register(String, int) - Static method in class org.apache.bookkeeper.stats.ThreadRegistry
 
register(String, int, long) - Static method in class org.apache.bookkeeper.stats.ThreadRegistry
 
registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
registerFailedEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
Increment the failed op counter with the given eventLatency.
registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger
 
registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
registerFailedValue(long) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
An operation with the given value failed.
registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger
 
registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
registerGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger
Register given gauge as name name.
registerOperationFailureOnBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
registerPendingAddsGauge(Gauge<Integer>) - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
registerPendingAddsGauge(Gauge<Integer>) - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl
 
registerRackChangeListener(ITopologyAwareEnsemblePlacementPolicy<BookieNode>) - Method in interface org.apache.bookkeeper.client.RackChangeNotifier
Register a listener for the rack-aware placement policy.
registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
registerSlowBookie(BookieId, long) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Register a bookie as slow so that it is tried after available and read-only bookies.
registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
registerSuccessfulEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
An operation succeeded with the given eventLatency.
registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger
 
registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger
 
registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger
 
registerSuccessfulValue(long) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger
An operation with the given value succeeded.
registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger
 
registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger
 
REGISTRATION_CLIENT_CLASS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
REGISTRATION_MANAGER_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
registry - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
releaseAllQuarantinedBookies() - Method in interface org.apache.bookkeeper.client.BookieWatcher
Release all quarantined bookies, let it can be chosen for new ensembles.
releaseAllQuarantinedBookies() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
releasePermit() - Method in class org.apache.bookkeeper.client.LedgerChecker
Release a given permit.
reloadCachedMappings() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver
 
reloadCachedMappings() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
REMOTE_FAIL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
REMOTE_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
REMOTE_NODE_IN_REORDER_SEQUENCE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
remove() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator
 
removeBookieAndCheck(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet
Invalidate a previous bookie response.
removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
removeScope(String, StatsLogger) - Method in interface org.apache.bookkeeper.stats.StatsLogger
Remove the given statsLogger for scope name.
REORDER_READ_SEQUENCE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Reorder the read last add confirmed sequence of a given write quorum writeSet.
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Reorder the read sequence of a given write quorum writeSet.
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
reorderReadSequenceWithRegion(List<BookieId>, DistributionSchedule.WriteSet, Map<Integer, String>, BookiesHealthInfo, boolean, String, int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
This function orders the read sequence with a given region.
reorderReadsRandom - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
reorderReadsRandom - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
reorderThresholdPendingRequests - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
reorderThresholdPendingRequests - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
REPAIRED_PLACEMENT_POLICY_NOT_ADHERING_BOOKIE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, int, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.BookieWatcher
Choose a bookie to replace bookie bookieIdx in existingBookies.
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, int, Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose a new bookie to replace bookieToReplace.
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy
 
replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
replaceBookiesInEnsemble(BookieWatcher, LedgerMetadata, List<BookieId>, Map<Integer, BookieId>, String) - Static method in class org.apache.bookkeeper.client.EnsembleUtils
 
replaceEnsembleEntry(long, List<BookieId>) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder
 
replaceFromRack(BookieNode, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
replaceNotAdheringPlacementPolicyBookie(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Returns placement result.
replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
replicate(LedgerHandle, LedgerFragment, AsyncCallback.VoidCallback, Set<BookieId>, BiConsumer<Long, Long>) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator
This method replicate a ledger fragment which is a contiguous portion of a ledger that was stored in an ensemble that included the failed bookie.
replicateLedgerFragment(LedgerHandle, LedgerFragment, BiConsumer<Long, Long>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Replicate the Ledger fragment to target Bookie passed.
REPLICATION_RATE_BY_BYTES - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ReplicationException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Generic exception code used to propagate in replication pipeline.
replicationThrottle - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator
 
reporters - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider
 
REPP_DISABLE_DURABILITY_ENFORCEMENT_FEATURE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_DISABLE_DURABILITY_FEATURE_NAME - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_DISALLOW_BOOKIE_PLACEMENT_IN_REGION_FEATURE_NAME - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_DNS_RESOLVER_CLASS - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
REPP_ENABLE_DURABILITY_ENFORCEMENT_IN_REPLACE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_ENABLE_VALIDATION - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_MINIMUM_REGIONS_FOR_DURABILITY - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
REPP_RANDOM_READ_REORDERING - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
REPP_REGIONS_TO_WRITE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
request - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
REQUEST_TIMER_NO_OF_TICKS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
REQUEST_TIMER_TICK_DURATION_MILLISEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
requestComplete - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
requestTimeNano - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
requestTimeNanos - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
requestTimeNanos - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
requestTimer - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder
 
requestTimer - Variable in class org.apache.bookkeeper.client.BookKeeper
 
requestTimer(HashedWheelTimer) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder
Configure the bookkeeper client to use a provided Netty HashedWheelTimer.
requestTimer(HashedWheelTimer) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
Configure the bookkeeper client to use a provided HashedWheelTimer.
requestTimer(HashedWheelTimer) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl
 
requiredBookiesMissingEntryForRecovery - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
REREPLICATION_ENTRY_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
resetRate(int) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler
 
resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver
 
resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
resolve(BookieId) - Method in class org.apache.bookkeeper.client.BookieAddressResolverDisabled
 
resolve(BookieId) - Method in class org.apache.bookkeeper.client.DefaultBookieAddressResolver
 
resolveNetworkLocation(BookieId) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
resolver - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
response - Variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx
 
ResultCallBack(CompletableFuture<Void>) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.ResultCallBack
 
rotateLatencyCollection() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger
 
rotateLatencyCollection() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
RoundRobinDistributionSchedule - Class in org.apache.bookkeeper.client
A specific DistributionSchedule that places entries in round-robin fashion.
RoundRobinDistributionSchedule(int, int, int) - Constructor for class org.apache.bookkeeper.client.RoundRobinDistributionSchedule
 
RRTopologyAwareCoverageEnsemble(int, int, int, int, Set<String>, int, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, Set<String>, int, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble
 
run() - Method in class org.apache.bookkeeper.client.ForceLedgerOp
 
run() - Method in class org.apache.bookkeeper.client.MetadataUpdateLoop
 
run() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
run() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater
 
RW_REREPLICATE_BACKOFF_MS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
rwLock - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl
 
rwLock - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy
 
rwLock - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl
 

S

SANITY_CHECK_METRICS_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
scheduleBookieHealthCheckIfEnabled(ClientConfiguration) - Method in class org.apache.bookkeeper.client.BookKeeper
 
scheduledFuture - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
scheduler - Variable in class org.apache.bookkeeper.client.BookKeeper
 
scope - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
scope() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc
The scope of this stats.
scope(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
scope(String) - Method in interface org.apache.bookkeeper.feature.FeatureProvider
Provide the feature provider under scope name.
scope(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger
 
scope(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger
 
scope(String) - Method in class org.apache.bookkeeper.stats.codahale.FastCodahaleStatsLogger
 
scope(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger
 
scope(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
scope(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
scope(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
Provide the stats logger under scope name.
ScopeContext - Class in org.apache.bookkeeper.stats.otel
Holder for a scope and a set of associated labels.
ScopeContext - Class in org.apache.bookkeeper.stats.prometheus
Holder for a scope and a set of associated labels.
ScopeContext(String, Attributes) - Constructor for class org.apache.bookkeeper.stats.otel.ScopeContext
 
ScopeContext(String, Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.ScopeContext
 
scopeLabel(String, String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger
 
scopeLabel(String, String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger
 
scopeLabel(String, String) - Method in interface org.apache.bookkeeper.stats.StatsLogger
Provide the stats logger with an attached label.
scopes - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider
 
scopeStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger
 
SecurityException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
 
seenBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet
 
selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Select a node from networkLoc rack excluding excludeBookies.
selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Select a node from a given network location.
selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy
Select a node from cluster excluding excludeBookies and bookie nodes of excludeRacks.
selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
It randomly selects a BookieNode that is not on the excludeRacks set, excluding the nodes in excludeBookies set.
selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl
 
selectRandom(int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
Choose a random node from whole cluster.
selectRandomFromRack(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
Choose random node under a given network path.
selectRandomFromRegions(Set<String>, int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy
 
selectRandomInternal(List<BookieNode>, int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
 
semaphore - Variable in class org.apache.bookkeeper.client.LedgerChecker
 
sendAddSuccessCallbacks() - Method in class org.apache.bookkeeper.client.LedgerHandle
 
sendAddSuccessCallbacks() - Method in class org.apache.bookkeeper.client.PendingAddOp
 
sendForceLedgerRequest(int) - Method in class org.apache.bookkeeper.client.ForceLedgerOp
 
sendNextRead() - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
sendNextRead() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
sendReadTo(int, BookieId, PendingReadOp.LedgerEntryRequest) - Method in class org.apache.bookkeeper.client.PendingReadOp
 
sendReadTo(int, BookieId, ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp
 
sendWriteLacRequest(int) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp
 
sentReplicas - Variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
sentReplicas - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
seq - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
seq - Variable in class org.apache.bookkeeper.client.SyncCounter
 
SequenceReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest
 
SequenceReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest
 
server - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider
 
SERVER_NUM_ACCEPTOR_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_NUM_IO_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_SOCK_KEEPALIVE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_SOCK_LINGER - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
SERVER_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ServerConfiguration - Class in org.apache.bookkeeper.conf
Configuration manages server-side settings.
ServerConfiguration() - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration
Construct a default configuration object.
ServerConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration
Construct a configuration based on other configuration.
set(boolean) - Method in class org.apache.bookkeeper.feature.SettableFeature
 
set(int) - Method in class org.apache.bookkeeper.feature.SettableFeature
 
set(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Set the index at index i.
setAddEntryQuorumTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set timeout for top-level add entry request.
setAddEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set timeout for add entry request.
setAdvertisedAddress(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to advertise a specific address.
setAllocatorLeakDetectionPolicy(LeakDetectionPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Enable the leak detection for the allocator.
setAllocatorOutOfMemoryPolicy(OutOfMemoryPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Define the memory allocator out of memory policy.
setAllocatorPoolingConcurrenncy(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Controls the amount of concurrency for the memory pool.
setAllocatorPoolingPolicy(PoolingPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Define the memory pooling policy.
setAllowEphemeralPorts(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to allow using an ephemeral port.
setAllowLoopback(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to allow loopback interfaces to be used as the primary bookie interface.
setAllowMultipleDirsUnderSameDiskPartition(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the Bookie to allow/disallow multiple ledger/index/journal directories in the same filesystem diskpartition.
setAllowShadedLedgerManagerFactoryClass(boolean) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set the flag to allow using shaded ledger manager factory class for instantiating a ledger manager factory.
setAllowStorageExpansion(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Change the setting of whether or not we should allow ledger/index dirs to be added to the current set of dirs.
setAuditorAcquireConcurrentOpenLedgerOperationsTimeoutMSec(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the acquire concurrent open ledger operations timeout.
setAuditorLedgerVerificationPercentage(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set what percentage of a ledger (fragment)'s entries will be verified.
setAuditorMaxNumberOfConcurrentOpenLedgerOperations(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the semaphore limit value for getting ledger from zookeeper in auto recovery.
setAuditorPeriodicBookieCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the interval between auditor bookie checks.
setAuditorPeriodicCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the regularity at which the auditor will run a check of all ledgers.
setAuditorPeriodicPlacementPolicyCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Sets the regularity/interval at which the auditor will run a placement policy check of all ledgers, which are closed.
setAuditorPeriodicReplicasCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Sets the interval at which the auditor will run a replicas check of all ledgers.
setAuthorizedRoles(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set authorized roles.
setAutoRecoveryDaemonEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Sets that whether the auto-recovery service can start along with Bookie server itself or not.
setBookieAddressResolver(BookieAddressResolver) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator
 
setBookieAddressResolverEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Enable/Disable BookieAddressResolver.
setBookieAuthProviderFactoryClass(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the bookie authentication provider factory class name.
setBookieErrorThresholdPerInterval(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the error threshold per interval (ClientConfiguration.getBookieHealthCheckIntervalSeconds()) for a bookie before it is quarantined.
setBookieFailureHistoryExpirationMSec(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the bookie failure tracking expiration timeout.
setBookieHealthCheckInterval(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the bookie health check interval.
setBookieId(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to advertise a specific BookieId.
setBookieMaxWeightMultipleForWeightBasedPlacement(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the max multiple to use for nodes with very high weight.
setBookiePort(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set new bookie port that bookie server listen on.
setBookieQuarantineRatio(double) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
set the bookie quarantine ratio.
setBookieQuarantineTime(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the time for which a bookie will be quarantined.
setBookieRecoveryDigestType(BookKeeper.DigestType) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set digest type used in bookkeeper admin.
setBookieRecoveryPasswd(byte[]) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set passwd used in bookkeeper admin.
setBusyWaitEnabled(boolean) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Option to enable busy-wait settings.
setClientAuthProviderFactoryClass(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set the client authentication provider factory class name.
setClientConnectBookieUnavailableLogThrottling(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the log frequency when a bookie is unavailable, in order to limit log filesize.
setClientConnectTimeoutMillis(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty connect timeout in millis.
setClientReceiveBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel receive buffer size.
setClientRole(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the client role.
setClientSendBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel send buffer size.
setClientSockKeepalive(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set socket keepalive setting.
setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set socket nodelay setting.
setClientWriteBufferHighWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel write buffer high water mark.
setClientWriteBufferLowWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel write buffer low water mark.
setCloseChannelOnResponseTimeout(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configures action in case if server timed out sending response to the client.
setCompactionMaxOutstandingRequests(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the maximum number of entries which can be compacted without flushing.
setCompactionRate(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the rate of compaction adds.
setCompactionRateByBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the rate of compaction adds.
setCompactionRateByEntries(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the rate of compaction adds.
setConf(Configuration) - Method in interface org.apache.bookkeeper.conf.Configurable
Set the configuration to be used by this object.
setDataIntegrityCheckingEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Enabled data integrity checker.
setDataIntegrityStampMissingCookiesEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
When this config is set to true and the data integrity checker is also enabled then any missing cookie files in the ledger directories do not prevent the bookie from booting.
setDefaultRocksDBConf(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set default rocksdb conf.
setDelayEnsembleChange(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Enable/Disable delaying ensemble change.
setDesiredNumZonesPerWriteQuorum(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set the desired number of zones per write quorum in ZoneAwarePlacementPolicy.
setDisableEnsembleChangeFeatureName(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the name of the dynamic feature that disables ensemble change.
setDisableServerSocketBind(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to disable bind on network interfaces, this bookie will be available only to BookKeeper clients executed on the local JVM.
setDiskCheckInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the disk checker interval to monitor ledger disk space.
setDiskLowWaterMarkUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the disk free space low water mark threshold.
setDiskUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the Disk free space threshold as a fraction of the total after which disk will be considered as full during disk check.
setDiskUsageWarnThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the warning threshold for disk usage.
setDiskWeightBasedPlacementEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set whether or not disk weight based placement is enabled.
setEnableBookieAddressTracking(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Enable/Disable bookie address changes tracking.
setEnableBookieFailureTracking(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration