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
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 otherStatsLogger
. - 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 existingStatsProvider
. - 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
-
Deprecated.
- CLIENT_TLS_KEYSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- CLIENT_TLS_KEYSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- CLIENT_TLS_TRUSTSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- CLIENT_TLS_TRUSTSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- CLIENT_TLS_TRUSTSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
Deprecated.
- 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
-
Deprecated.replaced by
ServerConfiguration.getCompactionRateByEntries()
- 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
-
Deprecated.
- 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
-
Deprecated.
- 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
-
Deprecated.
- 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 onLongAdder
. - 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
basedStatsLogger
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 ofLedgerHandle.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