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

A

AbstractConfiguration<T extends AbstractConfiguration> - Class in org.apache.bookkeeper.conf

Abstract configuration.

AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration

ackQuorumSize - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

ackQuorumSize - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

ackSet - Variable in class org.apache.bookkeeper.client.ForceLedgerOp

ackSet - Variable in class org.apache.bookkeeper.client.PendingAddOp

ackSet - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

acquire(int) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler

acquirePermit() - Method in class org.apache.bookkeeper.client.LedgerChecker

Acquires a permit from permit manager, blocking until all are available.

ACTIVE_NON_TLS_CHANNEL_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

ACTIVE_TLS_CHANNEL_COUNTER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

ADD_ENTRY_QUORUM_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ADD_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

ADD_OP_OUTSTANDING - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

ADD_OP_UR - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

addBookie(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.QuorumCoverageSet

Add a bookie to the result set.

addBookie(BookieNode) - Method in interface org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet

addBookie(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet

addBookie(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

addComplete(int, LedgerHandle, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback

Callback to implement if latency information is not desired.

addComplete(int, LedgerHandle, long, Object) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp

addComplete(int, LedgerHandle, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncAddCallback

Implementation of callback interface for synchronous read method.

addCompleteWithLatency(int, LedgerHandle, long, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback

Callback declaration which additionally passes quorum write complete latency.

addCompleteWithLatency(int, LedgerHandle, long, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallbackWithLatency

Callback declaration which additionally passes quorum write complete latency.

addCount(long) - Method in interface org.apache.bookkeeper.stats.Counter

Add delta to the value associated with this stat.

addCount(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter

addCount(long) - Method in class org.apache.bookkeeper.stats.otel.OtelCounter

addCount(long) - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter

addCount(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter

addDefaultFaultDomainBookies(Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

addDefaultRackBookiesIfMinNumRacksIsEnforced(Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

addEntry(byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addEntry(byte[]) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

addEntry(long, byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addEntry(long, byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry synchronously to an open ledger.

addEntry(long, byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry synchronously to an open ledger.

addEntry(long, byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry synchronously to an open ledger.

AddEntryQuorumTimeoutException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Add entry operation timeouts on waiting quorum responses.

addEntryQuorumTimeoutNanos - Variable in class org.apache.bookkeeper.client.ClientInternalConf

addEntrySuccessBookies - Variable in class org.apache.bookkeeper.client.PendingAddOp

addLacComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddLacCallback

Callback declaration.

addLacComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.LastAddConfirmedCallback

Implementation of callback interface for synchronous read method.

addLatency(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.Counter

An operation succeeded with the given eventLatency.

addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter

addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelCounter

addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter

When counter is used to count time.

addLatency(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter

addMissingIndices(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet

If we want a write set to cover all bookies in an ensemble of size X, then all of the index from 0..X must exist in the write set.

addNode(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints

addNode(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

addNode(T) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Ensemble

Append the new bookie node to the ensemble only if the ensemble doesnt already contain the same bookie.

address2NodePlacement - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

address2Region - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

addToLength(long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add to the length of the ledger in bytes.

administrativeOpen - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

adv - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

ADVERTISED_ADDRESS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

alertStatName - Variable in class org.apache.bookkeeper.stats.AlertStatsLogger

AlertStatsLogger - Class in org.apache.bookkeeper.stats

This class is used to raise alert when we detect an event that should never happen in production.

AlertStatsLogger(StatsLogger, String) - Constructor for class org.apache.bookkeeper.stats.AlertStatsLogger

AlertStatsLogger(StatsLogger, String, String) - Constructor for class org.apache.bookkeeper.stats.AlertStatsLogger

allocationToRacksOrRegions - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet

allocator - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder

allocator(ByteBufAllocator) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client with a provided ByteBufAllocator.

allocator(ByteBufAllocator) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder

Configure the bookkeeper client with a provided ByteBufAllocator.

allocator(ByteBufAllocator) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl

ALLOCATOR_LEAK_DETECTION_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ALLOCATOR_OOM_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ALLOCATOR_POOLING_CONCURRENCY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ALLOCATOR_POOLING_POLICY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ALLOW_EPHEMERAL_PORTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ALLOW_LOOPBACK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ALLOW_MULTIPLEDIRS_UNDER_SAME_DISKPARTITION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ALLOW_SHADED_LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ALLOW_STORAGE_EXPANSION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

allowFailFast - Variable in class org.apache.bookkeeper.client.PendingAddOp

allowFailFast - Variable in class org.apache.bookkeeper.client.PendingReadOp

allowFailFastOnUnwritableChannel() - Method in class org.apache.bookkeeper.client.PendingAddOp

allowFailFastOnUnwritableChannel() - Method in class org.apache.bookkeeper.client.PendingReadOp

append(byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add an entry synchronously to an open ledger.

append(byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add an entry synchronously to an open ledger.

append(ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add entry synchronously to an open ledger.

append(ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add entry synchronously to an open ledger.

appendAsync(byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add an entry asynchronously to an open ledger.

appendAsync(byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add an entry asynchronously to an open ledger.

appendAsync(ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add entry asynchronously to an open ledger.

appendAsync(ByteBuf) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger.

appendAsync(ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteHandle

Add entry asynchronously to an open ledger.

apply(BookieNode) - Method in interface org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet

apply(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet

apply(BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

apply(BookieNode, ITopologyAwareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.TruePredicate

apply(BookieNode, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

apply(T, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Predicate

areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Returns true if the bookies that have acknowledged a write adhere to the minimum fault domains as defined in the placement policy in use.

areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

areAckedBookiesAdheringToPlacementPolicy(Set<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

areEntriesOfLedgerStoredInTheBookie(long, BookieId, LedgerMetadata) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin

areEntriesOfLedgerStoredInTheBookie(long, BookieId, LedgerManager) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin

asJson() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

returns the string representation of json format of this config.

asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

LedgerHandleAdv will not allow addEntry without providing an entryId.

asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger.

asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(long, byte[], int, int, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(long, byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger.

asyncAddEntry(long, byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry asynchronously to an open ledger.

asyncAddEntry(long, ByteBuf, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(long, ByteBuf, AsyncCallback.AddCallbackWithLatency, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

Add entry asynchronously to an open ledger, using an offset and range.

asyncAddEntry(ByteBuf, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

asyncAddEntry(ByteBuf, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

LedgerHandleAdv will not allow addEntry without providing an entryId.

AsyncCallback - Interface in org.apache.bookkeeper.client

Defines all the callback interfaces for the async operations in bookkeeper client.

AsyncCallback.AddCallback - Interface in org.apache.bookkeeper.client

Async Callback for adding entries to ledgers.

AsyncCallback.AddCallbackWithLatency - Interface in org.apache.bookkeeper.client

Async Callback for adding entries to ledgers with latency information.

AsyncCallback.AddLacCallback - Interface in org.apache.bookkeeper.client

Async Callback for updating LAC for ledgers.

AsyncCallback.CloseCallback - Interface in org.apache.bookkeeper.client

Async Callback for closing ledgers.

AsyncCallback.CreateCallback - Interface in org.apache.bookkeeper.client

Async Callback for creating ledgers.

AsyncCallback.DeleteCallback - Interface in org.apache.bookkeeper.client

Async Callback for deleting ledgers.

AsyncCallback.IsClosedCallback - Interface in org.apache.bookkeeper.client

Async Callback for checking if a ledger is closed.

AsyncCallback.OpenCallback - Interface in org.apache.bookkeeper.client

Async Callback for opening ledgers.

AsyncCallback.ReadCallback - Interface in org.apache.bookkeeper.client

Async Callback for reading entries from ledgers.

AsyncCallback.ReadLastConfirmedAndEntryCallback - Interface in org.apache.bookkeeper.client

Async Callback for long polling read request.

AsyncCallback.ReadLastConfirmedCallback - Interface in org.apache.bookkeeper.client

Async Callback for reading LAC for ledgers.

AsyncCallback.RecoverCallback - Interface in org.apache.bookkeeper.client

Async Callback for recovering ledgers.

asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Asynchronous close, any adds in flight will return errors.

asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

asyncCloseInternal(AsyncCallback.CloseCallback, Object, int) - Method in class org.apache.bookkeeper.client.LedgerHandle

asyncCreateLedger(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger asynchronously.

asyncCreateLedger(int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger asynchronously.

asyncCreateLedgerAdv(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger asynchronously and returns LedgerHandleAdv which can accept entryId.

asyncCreateLedgerAdv(long, int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookKeeper

Asynchronously creates a new ledger using the interface which accepts a ledgerId as input.

asyncDeleteLedger(long, AsyncCallback.DeleteCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Deletes a ledger asynchronously.

asyncExplicitLacFlush(long) - Method in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

Make a LastAddUpdate request.

asyncGetLedgersContainBookies(Set<BookieId>, BookkeeperInternalCallbacks.GenericCallback<SortedMap<Long, LedgerMetadata>>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

asyncGetListOfEntriesOfLedger(BookieId, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.

asyncIsClosed(long, AsyncCallback.IsClosedCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Check asynchronously whether the ledger with identifier lId has been closed.

asyncOpenLedger(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Open a ledger as an administrator.

asyncOpenLedger(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Open existing ledger asynchronously for reading.

asyncOpenLedgerNoRecovery(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Open a ledger as an administrator without recovering the ledger.

asyncOpenLedgerNoRecovery(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Open existing ledger asynchronously for reading, but it does not try to recover the ledger if it is not yet closed.

asyncReadEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries asynchronously.

asyncReadEntriesInternal(long, long, AsyncCallback.ReadCallback, Object, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle

asyncReadExplicitLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains asynchronously the explicit last add confirmed from a quorum of bookies.

asyncReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains asynchronously the last confirmed write from a quorum of bookies.

asyncReadLastConfirmedAndEntry(long, long, boolean, AsyncCallback.ReadLastConfirmedAndEntryCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Asynchronous read next entry and the latest last add confirmed.

asyncReadLastEntry(AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

asyncReadLastEntry(AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

asyncReadUnconfirmedEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.

asyncRecoverBookieData(long, Set<BookieId>, boolean, boolean, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Recover a specific ledger.

asyncRecoverBookieData(Set<BookieId>, boolean, boolean, boolean, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

asyncRecoverBookieData(Set<BookieId>, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

asyncRecoverBookieData(BookieId, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.

asyncRecoveryAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Make a recovery add entry request.

asyncTryReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains asynchronously the last confirmed write from a quorum of bookies.

AUDITOR_ACQUIRE_CONCURRENT_OPEN_LEDGER_OPERATIONS_TIMEOUT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_LEDGER_VERIFICATION_PERCENTAGE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_MAX_NUMBER_OF_CONCURRENT_OPEN_LEDGER_OPERATIONS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_PERIODIC_BOOKIE_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_PERIODIC_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_PERIODIC_PLACEMENT_POLICY_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUDITOR_REPLICAS_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUTHORIZED_ROLES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

AUTO_RECOVERY_DAEMON_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

availability - Variable in class org.apache.bookkeeper.feature.FixedValueFeature

availability - Variable in class org.apache.bookkeeper.feature.SettableFeatureProvider

availability() - Method in interface org.apache.bookkeeper.feature.Feature

Returns the availability of this feature, an integer between 0 and 100.

availability() - Method in class org.apache.bookkeeper.feature.FixedValueFeature

AVAILABLE_NODE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

availableBookiesChanged() - Method in interface org.apache.bookkeeper.client.BookiesListener

Callback method triggered when the list of available bookies are changed.

availableBookiesChanged(Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookieInfoReader

B

backoffMultiplier - Variable in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy

basename - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger

bk - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

bk - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp

bk - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

BKAddEntryQuorumTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKAddEntryQuorumTimeoutException

BKBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieException

BKBookieHandleNotAvailableException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieHandleNotAvailableException

BKClientClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKClientClosedException

BKDataUnknownException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDataUnknownException

BKDigestMatchException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestMatchException

BKDigestNotInitializedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestNotInitializedException

BKDuplicateEntryIdException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDuplicateEntryIdException

BKException - Exception in org.apache.bookkeeper.client.api

Super class for all errors which occur using BookKeeper client.

BKException - Exception in org.apache.bookkeeper.client

Class the enumerates all the possible error conditions.

BKException(int) - Constructor for exception org.apache.bookkeeper.client.api.BKException

Create a new exception.

BKException(int) - Constructor for exception org.apache.bookkeeper.client.BKException

BKException(int, Throwable) - Constructor for exception org.apache.bookkeeper.client.api.BKException

Create a new exception with the cause.

BKException(int, Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException

BKException.BKAddEntryQuorumTimeoutException - Exception in org.apache.bookkeeper.client

Bookkeeper add entry quorum timeout exception.

BKException.BKBookieException - Exception in org.apache.bookkeeper.client

Bookkeeper bookie exception.

BKException.BKBookieHandleNotAvailableException - Exception in org.apache.bookkeeper.client

Bookkeeper bookie handle not available exception.

BKException.BKClientClosedException - Exception in org.apache.bookkeeper.client

Bookkeeper client closed exception.

BKException.BKDataUnknownException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger in limbo and data may or may not exist.

BKException.BKDigestMatchException - Exception in org.apache.bookkeeper.client

Bookkeeper digest match exception.

BKException.BKDigestNotInitializedException - Exception in org.apache.bookkeeper.client

Bookkeeper digest not initialized exception.

BKException.BKDuplicateEntryIdException - Exception in org.apache.bookkeeper.client

Bookkeeper duplicate entry id exception.

BKException.BKIllegalOpException - Exception in org.apache.bookkeeper.client

Bookkeeper illegal operation exception.

BKException.BKIncorrectParameterException - Exception in org.apache.bookkeeper.client

Bookkeeper incorrect parameter exception.

BKException.BKInterruptedException - Exception in org.apache.bookkeeper.client

Bookkeeper interrupted exception.

BKException.BKLedgerClosedException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger closed exception.

BKException.BKLedgerExistException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger exist exception.

BKException.BKLedgerFencedException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger fenced exception.

BKException.BKLedgerIdOverflowException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger id overflow exception.

BKException.BKLedgerRecoveryException - Exception in org.apache.bookkeeper.client

Bookkeeper ledger recovery exception.

BKException.BKMetadataSerializationException - Exception in org.apache.bookkeeper.client

Bookkeeper metadata serialization exception.

BKException.BKMetadataVersionException - Exception in org.apache.bookkeeper.client

Bookkeeper metadata version exception.

BKException.BKNoSuchEntryException - Exception in org.apache.bookkeeper.client

Bookkeeper no such entry exception.

BKException.BKNoSuchLedgerExistsException - Exception in org.apache.bookkeeper.client

Bookkeeper no such ledger exists exception.

BKException.BKNoSuchLedgerExistsOnMetadataServerException - Exception in org.apache.bookkeeper.client

Bookkeeper no such ledger exists on metadata server exception.

BKException.BKNotEnoughBookiesException - Exception in org.apache.bookkeeper.client

Bookkeeper not enough bookies exception.

BKException.BKProtocolVersionException - Exception in org.apache.bookkeeper.client

Bookkeeper protocol version exception.

BKException.BKQuorumException - Exception in org.apache.bookkeeper.client

Bookkeeper quorum exception.

BKException.BKReadException - Exception in org.apache.bookkeeper.client

Bookkeeper read exception.

BKException.BKReplicationException - Exception in org.apache.bookkeeper.client

Bookkeeper replication exception.

BKException.BKSecurityException - Exception in org.apache.bookkeeper.client

Bookkeeper security exception.

BKException.BKTimeoutException - Exception in org.apache.bookkeeper.client

Bookkeeper timeout exception.

BKException.BKTooManyRequestsException - Exception in org.apache.bookkeeper.client

Bookkeeper too many requests exception.

BKException.BKUnauthorizedAccessException - Exception in org.apache.bookkeeper.client

Bookkeeper unauthorized access exception.

BKException.BKUnclosedFragmentException - Exception in org.apache.bookkeeper.client

Bookkeeper unclosed fragment exception.

BKException.BKUnexpectedConditionException - Exception in org.apache.bookkeeper.client

Bookkeeper unexpected condition exception.

BKException.BKWriteException - Exception in org.apache.bookkeeper.client

Bookkeeper write exception.

BKException.BKWriteOnReadOnlyBookieException - Exception in org.apache.bookkeeper.client

Bookkeeper write on readonly bookie exception.

BKException.Code - Interface in org.apache.bookkeeper.client.api

Codes which represent the various exception types.

BKException.Code - Interface in org.apache.bookkeeper.client

Legacy interface which holds constants for BookKeeper error codes.

BKException.MetaStoreException - Exception in org.apache.bookkeeper.client

Metastore exception.

BKException.ZKException - Exception in org.apache.bookkeeper.client

Zookeeper exception.

BKIllegalOpException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIllegalOpException

BKIncorrectParameterException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIncorrectParameterException

BKInterruptedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKInterruptedException

BKLedgerClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerClosedException

BKLedgerExistException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerExistException

BKLedgerFencedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerFencedException

BKLedgerIdOverflowException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerIdOverflowException

BKLedgerRecoveryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerRecoveryException

BKMetadataSerializationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataSerializationException

BKMetadataSerializationException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataSerializationException

BKMetadataVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataVersionException

BKNoSuchEntryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchEntryException

BKNoSuchLedgerExistsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsException

BKNoSuchLedgerExistsOnMetadataServerException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsOnMetadataServerException

BKNotEnoughBookiesException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException

BKNotEnoughBookiesException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException

BKProtocolVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKProtocolVersionException

BKQuorumException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKQuorumException

BKReadException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReadException

BKReplicationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReplicationException

BKSecurityException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKSecurityException

BKTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKTimeoutException

BKTooManyRequestsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKTooManyRequestsException

BKUnauthorizedAccessException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnauthorizedAccessException

BKUnclosedFragmentException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnclosedFragmentException

BKUnexpectedConditionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnexpectedConditionException

BKWriteException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteException

BKWriteOnReadOnlyBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteOnReadOnlyBookieException

block(int) - Method in class org.apache.bookkeeper.client.SyncCounter

BOOKIE_ADDRESS_RESOLVER_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BOOKIE_ERROR_THRESHOLD_PER_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_FAILURE_HISTORY_EXPIRATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_HEALTH_CHECK_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_HEALTH_CHECK_INTERVAL_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_ID - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BOOKIE_LABEL - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

BOOKIE_MAX_MULTIPLE_FOR_WEIGHTED_PLACEMENT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BOOKIE_QUARANTINE_RATIO - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

BOOKIE_QUARANTINE_TIME_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

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

BookieAddressResolverDisabled - Class in org.apache.bookkeeper.client

Resolve legacy style BookieIDs to Network addresses.

BookieAddressResolverDisabled() - Constructor for class org.apache.bookkeeper.client.BookieAddressResolverDisabled

bookieClient - Variable in class org.apache.bookkeeper.client.BookKeeper

bookieClient - Variable in class org.apache.bookkeeper.client.ForceLedgerOp

bookieClient - Variable in class org.apache.bookkeeper.client.LedgerChecker

bookieClient - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

bookieClient - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

bookieFailureHistory - Variable in class org.apache.bookkeeper.client.LedgerHandle

bookieFailureHistoryExpirationMSec - Variable in class org.apache.bookkeeper.client.ClientInternalConf

BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Bookies are not available.

BookieInfo() - Constructor for class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo

BookieInfo(long, long) - Constructor for class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo

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

bookieInfoReader - Variable in class org.apache.bookkeeper.client.BookKeeper

BookieInfoReader - Class in org.apache.bookkeeper.client

A utility class to read BookieInfoReader.BookieInfo from bookies.

BookieInfoReader(BookKeeper, ClientConfiguration, ScheduledExecutorService) - Constructor for class org.apache.bookkeeper.client.BookieInfoReader

BookieInfoReader.BookieInfo - Class in org.apache.bookkeeper.client

A class represents the information (e.g.

BookieInfoReader.State - Enum in org.apache.bookkeeper.client

Tracks whether there is an execution in progress as well as whether another is pending.

bookieInfoScheduler - Variable in class org.apache.bookkeeper.client.BookKeeper

bookiesHealthInfo - Variable in class org.apache.bookkeeper.client.LedgerHandle

BookiesHealthInfo - Interface in org.apache.bookkeeper.client

This interface returns heuristics used to determine the health of a Bookkeeper server for read ordering.

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

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

BookiesListener - Interface in org.apache.bookkeeper.client

Listener for the available bookies changes.

bookieWatcher - Variable in class org.apache.bookkeeper.client.BookKeeper

bookieWatcher - Variable in class org.apache.bookkeeper.client.LedgerChecker

BookieWatcher - Interface in org.apache.bookkeeper.client

Watch for Bookkeeper cluster status.

BookieWatcherImpl - Class in org.apache.bookkeeper.client

This class is responsible for maintaining a consistent view of what bookies are available by reading Zookeeper (and setting watches on the bookie nodes).

BookieWatcherImpl(ClientConfiguration, EnsemblePlacementPolicy, RegistrationClient, BookieAddressResolver, StatsLogger) - Constructor for class org.apache.bookkeeper.client.BookieWatcherImpl

BookKeeper - Class in org.apache.bookkeeper.client

BookKeeper client.

BookKeeper - Interface in org.apache.bookkeeper.client.api

This is the entry point for BookKeeper client side API.

BookKeeper() - Constructor for class org.apache.bookkeeper.client.BookKeeper

Allow to extend BookKeeper for mocking in unit tests.

BookKeeper(String) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client.

BookKeeper(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client using a configuration object.

BookKeeper(ClientConfiguration, ZooKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.

BookKeeper(ClientConfiguration, ZooKeeper, EventLoopGroup) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Create a bookkeeper client but use the passed in zookeeper client and client event loop group instead of instantiating those.

BookKeeper(ClientConfiguration, ZooKeeper, EventLoopGroup, ByteBufAllocator, StatsLogger, DNSToSwitchMapping, HashedWheelTimer, FeatureProvider) - Constructor for class org.apache.bookkeeper.client.BookKeeper

Constructor for use with the builder.

BookKeeper.Builder - Class in org.apache.bookkeeper.client

BookKeeper Client Builder to build client instances.

BookKeeper.DigestType - Enum in org.apache.bookkeeper.client

There are 3 digest types that can be used for verification.

BookKeeperAdmin - Class in org.apache.bookkeeper.client

Admin client for BookKeeper clusters.

BookKeeperAdmin(String) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.

BookKeeperAdmin(BookKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

BookKeeperAdmin(BookKeeper, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

BookKeeperAdmin(BookKeeper, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a BookKeeper instance .

BookKeeperAdmin(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.

BookKeeperAdmin.LedgerEntriesIterable - Class in org.apache.bookkeeper.client

BookKeeperAdmin.LedgerEntriesIterator - Class in org.apache.bookkeeper.client

BookKeeperAdmin.ResultCallBack - Class in org.apache.bookkeeper.client

This is the class for getting the replication result.

BookKeeperAdmin.SyncObject - Class in org.apache.bookkeeper.client

BookKeeperBuilder - Interface in org.apache.bookkeeper.client.api

BookKeeper Client Builder to build client instances.

BookKeeperBuilderImpl - Class in org.apache.bookkeeper.client.impl

Internal builder for BookKeeper client.

BookKeeperBuilderImpl(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl

BookKeeperClientStats - Interface in org.apache.bookkeeper.client

List of constants for defining client stats names.

BookKeeperClientStatsImpl - Class in org.apache.bookkeeper.client.impl

The default implementation of BookKeeperClientStats.

BookKeeperClientStatsImpl(StatsLogger) - Constructor for class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl

build() - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Start and initialize a new BookKeeper client.

build() - Method in class org.apache.bookkeeper.client.BookKeeper.Builder

build() - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl

build() - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

Builder(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper.Builder

BYTEBUF_ALLOCATOR_SIZE_INITIAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BYTEBUF_ALLOCATOR_SIZE_MAX - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

BYTEBUF_ALLOCATOR_SIZE_MIN - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

C

CacheableFeatureProvider<T extends Feature> - Class in org.apache.bookkeeper.feature

Cacheable Feature Provider.

CacheableFeatureProvider(String) - Constructor for class org.apache.bookkeeper.feature.CacheableFeatureProvider

CachingStatsLogger - Class in org.apache.bookkeeper.stats

A StatsLogger that caches the stats objects created by other StatsLogger.

CachingStatsLogger(StatsLogger) - Constructor for class org.apache.bookkeeper.stats.CachingStatsLogger

CachingStatsProvider - Class in org.apache.bookkeeper.stats

A CachingStatsProvider adds the caching functionality to an existing StatsProvider.

CachingStatsProvider(StatsProvider) - Constructor for class org.apache.bookkeeper.stats.CachingStatsProvider

callbackTriggered - Variable in class org.apache.bookkeeper.client.PendingAddOp

cancelSpeculativeTask(boolean) - Method in class org.apache.bookkeeper.client.PendingReadOp

cancelSpeculativeTask(boolean) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

canEqual(Object) - Method in class org.apache.bookkeeper.client.LedgerMetadataImpl

canEqual(Object) - Method in class org.apache.bookkeeper.stats.otel.ScopeContext

category() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc

The name of the category to group stats together.

CATEGORY_CLIENT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

cb - Variable in class org.apache.bookkeeper.client.ForceLedgerOp

cb - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

cb - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp

cb - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

cb - Variable in class org.apache.bookkeeper.client.PendingAddOp

cb - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

cb - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

cb - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

changingEnsemble - Variable in class org.apache.bookkeeper.client.LedgerHandle

CHANNEL_ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_FORCE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_READ_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_START_TLS_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_ADD - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_FORCE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_READ - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_READ_LAC - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_START_TLS_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_TIMEOUT_WRITE_LAC - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CHANNEL_WRITE_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

checkCovered() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.QuorumCoverageSet

check if all quorum in the set have had the action performed for it.

checkForFaultyBookies() - Method in class org.apache.bookkeeper.client.BookKeeper

checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>) - Method in class org.apache.bookkeeper.client.LedgerChecker

Check that all the fragments in the passed in ledger, and report those which are missing.

checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>, long) - Method in class org.apache.bookkeeper.client.LedgerChecker

chosenNodes - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

clear() - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger

clear() - Method in interface org.apache.bookkeeper.stats.Counter

Clear this stat.

clear() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter

clear() - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

clear() - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

Clear stats for this operation.

clear() - Method in class org.apache.bookkeeper.stats.otel.OtelCounter

clear() - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

clear() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

clear() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter

clear() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger

clear() - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedLongAdderCounter

clear() - Static method in class org.apache.bookkeeper.stats.ThreadRegistry

CLIENT_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_CHANNEL_WRITE_WAIT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CLIENT_CONNECT_BOOKIE_UNAVAILABLE_LOG_THROTTLING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_CONNECT_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_CONNECT_TIMER - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CLIENT_RECEIVEBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_ROLE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_ROLE_STANDARD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

This client will act as a standard client.

CLIENT_ROLE_SYSTEM - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

This client will act as a system client, like the Auditor.

CLIENT_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

CLIENT_SENDBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_SOCK_KEEPALIVE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_TCP_USER_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

CLIENT_TLS_KEYSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_KEYSTORE

CLIENT_TLS_KEYSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_KEYSTORE_PASSWORD_PATH

CLIENT_TLS_KEYSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_KEYSTORE_TYPE

CLIENT_TLS_TRUSTSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_TRUSTSTORE

CLIENT_TLS_TRUSTSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_TRUSTSTORE_PASSWORD_PATH

CLIENT_TLS_TRUSTSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

Use AbstractConfiguration.TLS_TRUSTSTORE_TYPE

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.

replaced by AbstractConfiguration.getLedgerManagerFactoryClass()

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.

use ClientConfiguration.getReadEntryTimeout() or ClientConfiguration.getAddEntryTimeout() instead

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.

see BookKeeperBuilder.allocator(io.netty.buffer.ByteBufAllocator)

isPersistBookieStatusEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get whether to persist the bookie status so that when bookie server restarts, it will continue using the previous status.

isReadOnlyModeEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get whether read-only mode is enabled.

isReadOnlyModeOnAnyDiskFullEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get whether read-only mode is enable when any disk is full.

isReadWorkerThreadsThrottlingEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Get the auto-throttling status of the read-worker threads.

isRecoveryAdd - Variable in class org.apache.bookkeeper.client.PendingAddOp

isRecoveryRead - Variable in class org.apache.bookkeeper.client.PendingReadOp

isReorderReadSequenceEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

If reorder read sequence enabled or not.

isRepairedPlacementPolicyNotAdheringBookieEnable() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Now the feature only support RackawareEnsemblePlacementPolicy.

isSanityCheckMetricsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Flag to enable sanity check metrics in bookie stats.

isShadedLedgerManagerFactoryClassAllowed() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Is shaded ledger manager factory class name allowed to be used for instantiating ledger manager factory.

isSkipReplayJournalInvalidRecord() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

isStatisticsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Is statistics enabled.

isStickyReadsEnabled() - Method in class org.apache.bookkeeper.conf.ClientConfiguration

If read operation should be sticky to a single bookie or not.

isStoredEntryId(long, int) - Method in class org.apache.bookkeeper.client.LedgerFragment

issueSpeculativeRequest() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

Issues a speculative request and indicates if more speculative requests should be issued.

issueSpeculativeRequest() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

Speculative Read Logic.

issueSpeculativeRequest() - Method in interface org.apache.bookkeeper.client.SpeculativeRequestExecutor

Issues a speculative request and indicates if more speculative requests should be issued.

isThreadInitialized() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

isThreadInitialized() - Method in class org.apache.bookkeeper.stats.prometheus.LongAdderCounter

isUseTargetEntryLogSizeForGc() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

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

isZkEnableSecurity() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Are z-node created with strict ACLs.

iterator() - Method in interface org.apache.bookkeeper.client.api.LedgerEntries

Get an iterator over all the ledger entries contained in the LedgerEntries object.

iterator() - Method in interface org.apache.bookkeeper.client.api.ListLedgersResult

Creates a LedgersIterator.

iterator() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable

iterator() - Method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl

Get an iterator over all the ledger entries contained in the LedgerEntries object.

ITopologyAwareEnsemblePlacementPolicy<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client

Interface for topology aware ensemble placement policy.

ITopologyAwareEnsemblePlacementPolicy.Ensemble<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client

Ensemble used to hold the result of an ensemble selected for placement.

ITopologyAwareEnsemblePlacementPolicy.Predicate<T extends org.apache.bookkeeper.net.Node> - Interface in org.apache.bookkeeper.client

Predicate used when choosing an ensemble.

J

jmx - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider

JOURNAL_ADAPTIVE_GROUP_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_ALIGNMENT_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_BUFFERED_ENTRIES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_BUFFERED_WRITES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_CHANNEL_PROVIDER - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_DIR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_FLUSH_WHEN_QUEUE_EMPTY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_FORMAT_VERSION_TO_WRITE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_MAX_GROUP_WAIT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_MAX_MEMORY_SIZE_MB - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_PAGECACHE_FLUSH_INTERVAL_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_PRE_ALLOC_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_QUEUE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_REMOVE_FROM_PAGE_CACHE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_REUSE_FILES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_SYNC_DATA - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

JOURNAL_WRITE_DATA - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

K

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

L

lac - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

LAC_UPDATE_HITS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

LAC_UPDATE_MISSES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

lacUpdateHitsCounter - Variable in class org.apache.bookkeeper.client.LedgerHandle

lacUpdateMissesCounter - Variable in class org.apache.bookkeeper.client.LedgerHandle

lastAddConfirmed - Variable in class org.apache.bookkeeper.client.LedgerHandle

Last entryId which has been confirmed to be written durably to the bookies.

LastAddConfirmedCallback() - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.LastAddConfirmedCallback

lastAddPushed - Variable in class org.apache.bookkeeper.client.LedgerHandle

LastConfirmedAndEntry - Interface in org.apache.bookkeeper.client.api

This contains LastAddConfirmed entryId and a LedgerEntry wanted to read.

LastConfirmedAndEntryImpl - Class in org.apache.bookkeeper.client.impl

This contains LastAddConfirmed entryId and a LedgerEntry wanted to read.

LastConfirmedAndEntryImpl(Recycler.Handle<LastConfirmedAndEntryImpl>) - Constructor for class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl

LastConfirmedCtx() - Constructor for class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

lastEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable

lastEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

lastSeenError - Variable in class org.apache.bookkeeper.client.ForceLedgerOp

lastSeenError - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

lastSeenError - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

LEDGER_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LEDGER_ENSEMBLE_BOOKIE_DISTRIBUTION - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

LEDGER_MANAGER_FACTORY_DISABLE_CLASS_CHECK - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

LEDGER_MANAGER_TYPE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

LEDGER_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

LEDGER_METADATA_ROCKSDB_CONF - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LEDGER_RECOVER_ADD_ENTRIES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

LEDGER_RECOVER_READ_ENTRIES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

LEDGER_STORAGE_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LEDGER_STORAGE_CLASS_KEY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LedgerChecker - Class in org.apache.bookkeeper.client

A utility class to check the complete ledger and finds the UnderReplicated fragments if any.

LedgerChecker(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerChecker

LedgerChecker(BookKeeper, int) - Constructor for class org.apache.bookkeeper.client.LedgerChecker

LedgerChecker(BookieClient, BookieWatcher) - Constructor for class org.apache.bookkeeper.client.LedgerChecker

LedgerChecker(BookieClient, BookieWatcher, int) - Constructor for class org.apache.bookkeeper.client.LedgerChecker

LedgerChecker.InvalidFragmentException - Exception in org.apache.bookkeeper.client

LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Executing operations on a closed ledger handle.

LedgerCreateOp - Class in org.apache.bookkeeper.client

Encapsulates asynchronous ledger create operation.

LedgerCreateOp(BookKeeper, int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object, Map<String, byte[]>, EnumSet<WriteFlag>, BookKeeperClientStats) - Constructor for class org.apache.bookkeeper.client.LedgerCreateOp

Constructor.

LedgerCreateOp.CreateBuilderImpl - Class in org.apache.bookkeeper.client

LedgerDeleteOp - Class in org.apache.bookkeeper.client

Encapsulates asynchronous ledger delete operation.

LedgerDeleteOp(BookKeeper, BookKeeperClientStats, long, AsyncCallback.DeleteCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerDeleteOp

Constructor.

LedgerDeleteOp.DeleteBuilderImpl - Class in org.apache.bookkeeper.client

LedgerEntries - Interface in org.apache.bookkeeper.client.api

Interface to wrap a sequence of entries.

LedgerEntriesImpl - Class in org.apache.bookkeeper.client.impl

Ledger entries implementation.

LedgerEntriesIterable(long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable

LedgerEntriesIterable(long, long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable

LedgerEntriesIterator(long, long, long) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

LedgerEntry - Class in org.apache.bookkeeper.client

Ledger entry.

LedgerEntry - Interface in org.apache.bookkeeper.client.api

An entry in a ledger.

LedgerEntry(LedgerEntryImpl) - Constructor for class org.apache.bookkeeper.client.LedgerEntry

LedgerEntryImpl - Class in org.apache.bookkeeper.client.impl

Ledger entry.

LedgerEntryRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

LedgerExistException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Ledger already exists.

LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Operations failed due to ledgers are fenced.

LedgerFragment - Class in org.apache.bookkeeper.client

Represents the entries of a segment of a ledger which are stored on subset of bookies in the segments bookie ensemble.

LedgerFragment(LedgerFragment, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerFragment

LedgerFragment(LedgerHandle, long, long, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerFragment

LedgerFragment.ReplicateType - Enum in org.apache.bookkeeper.client

ReplicateType.

LedgerFragmentReplicator - Class in org.apache.bookkeeper.client

This is the helper class for replicating the fragments from one bookie to another.

LedgerFragmentReplicator(BookKeeper, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator

LedgerFragmentReplicator(BookKeeper, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator

LedgerFragmentReplicator.SingleFragmentCallback - Class in org.apache.bookkeeper.client

Callback for recovery of a single ledger fragment.

LedgerFragmentReplicator.Throttler - Class in org.apache.bookkeeper.client

ledgerFragmentsMcb - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

LedgerHandle - Class in org.apache.bookkeeper.client

Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.

LedgerHandle(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], EnumSet<WriteFlag>) - Constructor for class org.apache.bookkeeper.client.LedgerHandle

LedgerHandle.LastConfirmedCtx - Class in org.apache.bookkeeper.client

Context objects for synchronous call to read last confirmed.

LedgerHandle.NoopCloseCallback - Class in org.apache.bookkeeper.client

LedgerHandleAdv - Class in org.apache.bookkeeper.client

Ledger Advanced handle extends LedgerHandle to provide API to add entries with user supplied entryIds.

LedgerHandleAdv(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], EnumSet<WriteFlag>) - Constructor for class org.apache.bookkeeper.client.LedgerHandleAdv

LedgerHandleAdv.PendingOpsComparator - Class in org.apache.bookkeeper.client

ledgerId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterable

ledgerId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

ledgerId - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase

ledgerId - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

ledgerId - Variable in class org.apache.bookkeeper.client.LedgerDeleteOp

ledgerId - Variable in class org.apache.bookkeeper.client.LedgerEntry

ledgerId - Variable in class org.apache.bookkeeper.client.LedgerHandle

ledgerId - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

LEDGERID_FORMATTER_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ledgerIdGenerator - Variable in class org.apache.bookkeeper.client.BookKeeper

LedgerIdOverflowException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Ledger id overflow happens on ledger manager.

ledgerKey - Variable in class org.apache.bookkeeper.client.LedgerHandle

ledgerManager - Variable in class org.apache.bookkeeper.client.BookKeeper

ledgerManager - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

ledgerManagerFactory - Variable in class org.apache.bookkeeper.client.BookKeeper

LedgerMetadata - Interface in org.apache.bookkeeper.client.api

Represents the client-side metadata of a ledger.

LedgerMetadata.State - Enum in org.apache.bookkeeper.client.api

Possible metadata states.

LedgerMetadataBuilder - Class in org.apache.bookkeeper.client

Builder for building LedgerMetadata objects.

LedgerMetadataBuilder() - Constructor for class org.apache.bookkeeper.client.LedgerMetadataBuilder

LedgerMetadataImpl - Class in org.apache.bookkeeper.client

This class encapsulates all the ledger metadata that is persistently stored in metadata store.

LedgerMetadataImpl(long, int, int, int, int, LedgerMetadata.State, Optional<Long>, Optional<Long>, Map<Long, List<BookieId>>, Optional<DigestType>, Optional<byte[]>, long, boolean, long, Map<String, byte[]>) - Constructor for class org.apache.bookkeeper.client.LedgerMetadataImpl

LedgerMetadataUtils - Class in org.apache.bookkeeper.client

Utilities for working with ledger metadata.

LedgerMetadataUtils() - Constructor for class org.apache.bookkeeper.client.LedgerMetadataUtils

LedgerOpenOp - Class in org.apache.bookkeeper.client

Encapsulates the ledger open operation.

LedgerOpenOp(BookKeeper, BookKeeperClientStats, long, AsyncCallback.OpenCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp

LedgerOpenOp(BookKeeper, BookKeeperClientStats, long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp

Constructor.

LedgerOpenOp.OpenBuilderImpl - Class in org.apache.bookkeeper.client

LedgerRecoveryException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Ledger recovery operations failed.

LedgerRecoveryOp - Class in org.apache.bookkeeper.client

This class encapsulated the ledger recovery operation.

LedgerRecoveryOp(LedgerHandle, ClientContext) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp

LedgerRecoveryOp.RecoveryReadOp - Class in org.apache.bookkeeper.client

LedgersIterator - Interface in org.apache.bookkeeper.client.api

Iterator for ledgers.

length - Variable in class org.apache.bookkeeper.client.LedgerEntry

length - Variable in class org.apache.bookkeeper.client.LedgerHandle

lh - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

lh - Variable in class org.apache.bookkeeper.client.ForceLedgerOp

lh - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

lh - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

lh - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

lh - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

lh - Variable in class org.apache.bookkeeper.client.PendingAddOp

lh - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

lh - Variable in class org.apache.bookkeeper.client.PendingReadOp

lh - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

lh - Variable in class org.apache.bookkeeper.client.SyncCounter

lh - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

LIMIT_STATS_LOGGING - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

listener - Variable in class org.apache.bookkeeper.client.ListenerBasedPendingReadOp

ListenerBasedPendingReadOp - Class in org.apache.bookkeeper.client

ListenerBasedPendingReadOp(LedgerHandle, ClientContext, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object, boolean) - Constructor for class org.apache.bookkeeper.client.ListenerBasedPendingReadOp

LISTENING_INTERFACE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

listLedgers() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.

ListLedgersResult - Interface in org.apache.bookkeeper.client.api

Utility container for listing ledgers.

ListLedgersResultBuilder - Interface in org.apache.bookkeeper.client.api

Builder-style interface to list exiting ledgers.

loadConf(URL) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

You can load configurations in precedence order.

loadConf(CompositeConfiguration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

You can load configuration from other configuration.

loadStatsProvider(String) - Static method in class org.apache.bookkeeper.stats.Stats

loadStatsProvider(Configuration) - Static method in class org.apache.bookkeeper.stats.Stats

LOCAL_CONSISTENCY_CHECK_ON_STARTUP - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LOCAL_FAIL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

LOCAL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

LOCAL_SCRUB_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LOCAL_SCRUB_RATE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

localNode - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

LOCK_RELEASE_OF_FAILED_LEDGER_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

LOG - Static variable in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

LOG - Static variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

LOG - Static variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

LOG - Static variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase

LOG - Static variable in class org.apache.bookkeeper.client.LedgerCreateOp

LOG - Static variable in class org.apache.bookkeeper.client.LedgerDeleteOp

LOG - Static variable in class org.apache.bookkeeper.client.LedgerHandle

LOG - Static variable in class org.apache.bookkeeper.client.LedgerHandleAdv

LOG - Static variable in class org.apache.bookkeeper.client.LedgerMetadataImpl

LOG - Static variable in class org.apache.bookkeeper.client.LedgerMetadataUtils

LOG - Static variable in class org.apache.bookkeeper.client.LedgerOpenOp

LOG - Static variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

LOG - Static variable in class org.apache.bookkeeper.client.MetadataUpdateLoop

LOG - Static variable in class org.apache.bookkeeper.client.PendingReadLacOp

LOG - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

LOG - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

LOG - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedOp

LOG - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

LOG - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

LOG - Static variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

LOG - Static variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

LOG - Static variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

LOG - Static variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider

LOG - Static variable in class org.apache.bookkeeper.stats.Stats

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

Log error errMsg and reattempt read from host.

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Log error errMsg and reattempt read from host.

logErrorAndReattemptRead(int, BookieId, String, int) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

LongAdderCounter - Class in org.apache.bookkeeper.stats.prometheus

Counter implementation based on LongAdder.

LongAdderCounter(Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.LongAdderCounter

LOST_BOOKIE_RECOVERY_DELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

M

MAC - org.apache.bookkeeper.client.api.DigestType

Entries are verified by applied MAC algorithm.

MAC - org.apache.bookkeeper.client.BookKeeper.DigestType

macManager - Variable in class org.apache.bookkeeper.client.LedgerHandle

mainWorkerPool - Variable in class org.apache.bookkeeper.client.BookKeeper

MAJOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAJOR_COMPACTION_MAX_TIME_MILLIS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAJOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

makeAdv() - Method in interface org.apache.bookkeeper.client.api.CreateBuilder

Switch the ledger into 'Advanced' mode.

makeAdv() - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl

makeFeature(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider

makeFeature(String) - Method in class org.apache.bookkeeper.feature.SettableFeatureProvider

makeName(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider

makeProvider(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider

makeProvider(String) - Method in class org.apache.bookkeeper.feature.SettableFeatureProvider

map - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

MASK_BITS - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

MAX_ADDS_IN_PROGRESS_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_ALLOWED_ENSEMBLE_CHANGES - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

MAX_BACKUP_JOURNALS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_JOURNAL_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_OPERATION_NUMBERS_IN_SINGLE_ROCKSDB_WRITE_BATCH - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_PENDING_ADD_REQUESTS_PER_THREAD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_PENDING_READ_REQUESTS_PER_THREAD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_READS_IN_PROGRESS_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MAX_SPECULATIVE_READ_LAC_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

MAX_SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

maxAllowedEnsembleChanges - Variable in class org.apache.bookkeeper.client.ClientInternalConf

MAXIMUM_NUMBER_OF_ACTIVE_ENTRYLOGS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

maxLac - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

maxMissedReadsAllowed - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

maxProbabilityMultiplier - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

maxProbabilityMultiplier - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

maxRecoveredData - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

maxSpeculativeRequestTimeout - Variable in class org.apache.bookkeeper.client.DefaultSpeculativeRequestExecutionPolicy

maxWeightMultiple - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

maxWeightMultiple - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

maybeHandleDelayedWriteBookieFailure() - Method in class org.apache.bookkeeper.client.LedgerHandle

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

Send to next replica speculatively, if required and possible.

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

Send to next replica speculatively, if required and possible.

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Send to next replica speculatively, if required and possible.

maybeSendSpeculativeRead(BitSet) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

Send to next replica speculatively, if required and possible.

maybeTimeout() - Method in class org.apache.bookkeeper.client.PendingAddOp

MEETS_SOFT - org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence

MEETS_STRICT - org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence

metadata - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

METADATA_SERVICE_URI - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

metadataDriver - Variable in class org.apache.bookkeeper.client.BookKeeper

metadataFormatVersion - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

metadataForRecovery - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

metadataLock - Variable in class org.apache.bookkeeper.client.LedgerHandle

MetadataSerializationException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Failure to serialize metadata.

MetadataUpdateLoop - Class in org.apache.bookkeeper.client

Mechanism to safely update the metadata of a ledger.

MetadataUpdateLoop(LedgerManager, long, Supplier<Versioned<LedgerMetadata>>, MetadataUpdateLoop.NeedsUpdatePredicate, MetadataUpdateLoop.MetadataTransform, MetadataUpdateLoop.LocalValueUpdater) - Constructor for class org.apache.bookkeeper.client.MetadataUpdateLoop

MetadataUpdateLoop(LedgerManager, long, Supplier<Versioned<LedgerMetadata>>, MetadataUpdateLoop.NeedsUpdatePredicate, MetadataUpdateLoop.MetadataTransform, MetadataUpdateLoop.LocalValueUpdater, RateLimiter) - Constructor for class org.apache.bookkeeper.client.MetadataUpdateLoop

Construct the loop.

MetadataUpdateLoop.LocalValueUpdater - Interface in org.apache.bookkeeper.client

MetadataUpdateLoop.MetadataTransform - Interface in org.apache.bookkeeper.client

MetadataUpdateLoop.NeedsUpdatePredicate - Interface in org.apache.bookkeeper.client

MetadataUpdater(Versioned<LedgerMetadata>) - Constructor for class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater

MetadataVersionException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Bad version on executing metadata operations.

METASTORE_IMPL_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

METASTORE_MAX_ENTRIES_PER_SCAN - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

MetaStoreException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Meta store operations failed.

MetaStoreException() - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException

MetaStoreException(Throwable) - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException

meter - Variable in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider

metricNameSet - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat

metrics - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider

metrics - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger

MIN_NUM_RACKS_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

MIN_NUM_ZONES_PER_WRITE_QUORUM - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

MIN_USABLESIZE_FOR_ENTRYLOG_CREATION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MIN_USABLESIZE_FOR_HIGH_PRIORITY_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MIN_USABLESIZE_FOR_INDEXFILE_CREATION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MINIMUM_REGIONS_FOR_DURABILITY_DEFAULT - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

minNumRacksPerWriteQuorum - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

minNumRacksPerWriteQuorum - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

minNumZonesPerWriteQuorum - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

MINOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MINOR_COMPACTION_MAX_TIME_MILLIS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

MINOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

minRacksOrRegionsForDurability - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

minRegionsForDurability - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

moveAndShift(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet

Move an index from one position to another, shifting the other indices accordingly.

myNode - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

myRegion - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

myZone - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

N

name - Variable in class org.apache.bookkeeper.feature.FixedValueFeature

name() - Method in interface org.apache.bookkeeper.feature.Feature

Returns a textual representation of the feature.

name() - Method in class org.apache.bookkeeper.feature.FixedValueFeature

name() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc

The name of this stats.

needsUpdate(LedgerMetadata) - Method in interface org.apache.bookkeeper.client.MetadataUpdateLoop.NeedsUpdatePredicate

NETTY_EXCEPTION_CNT - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

NETTY_MAX_FRAME_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

NETTY_OPS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

NETTY_USE_POOLED_BUFFERS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

NETWORK_TOPOLOGY_STABILIZE_PERIOD_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

newBuilder(ClientConfiguration) - Static method in interface org.apache.bookkeeper.client.api.BookKeeper

Create a new builder which can be used to boot a new BookKeeper client.

newCreateLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper

Start the creation of a new ledger.

newCreateLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper

newDeleteLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper

Delete an existing ledger.

newDeleteLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper

newEnsemble(int, int, int, Map<String, byte[]>) - Method in interface org.apache.bookkeeper.client.BookieWatcher

Create an ensemble with given ensembleSize and writeQuorumSize.

newEnsemble(int, int, int, Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Choose numBookies bookies for ensemble.

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

newEnsemble(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Create an ensemble with parent ensemble.

newEnsembleEntry(long, List<BookieId>) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

newEnsembleInternal(int, int, int, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

newInstance(StatsLogger) - Static method in interface org.apache.bookkeeper.client.BookKeeperClientStats

newListLedgersOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper

List ledgers.

newListLedgersOp() - Method in class org.apache.bookkeeper.client.BookKeeper

newMetadata - Variable in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater

newOpenLedgerOp() - Method in interface org.apache.bookkeeper.client.api.BookKeeper

Open an existing ledger.

newOpenLedgerOp() - Method in class org.apache.bookkeeper.client.BookKeeper

next() - Method in interface org.apache.bookkeeper.client.api.LedgersIterator

Return next ledger id.

next() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

nextEntryId - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

nextReplicaIndexToReadFrom - Variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

nextReplicaIndexToReadFrom - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

NoBookieAvailableException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Unused.

none - org.apache.bookkeeper.stats.codahale.FastTimer.Buckets

NONE - Static variable in enum org.apache.bookkeeper.client.api.WriteFlag

No flag is set, use default behaviour.

NoopCloseCallback() - Constructor for class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback

NoSuchEntryException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

No such entry exists.

NoSuchLedgerExistsException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

No such ledger exists.

NoSuchLedgerExistsOnMetadataServerException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

No such ledger exists one metadata server.

NOT_FOUND - Static variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

NOT_FOUND - Static variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

NotEnoughBookiesException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Not enough bookies available to form an ensemble.

notifyWriteFailed(int, BookieId) - Method in class org.apache.bookkeeper.client.LedgerHandle

nukeExistingCluster(ServerConfiguration, String, String, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin

Nukes existing cluster metadata.

NULL_WRITE_SET - Static variable in interface org.apache.bookkeeper.client.DistributionSchedule

nullCounter - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger

NullCounter() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter

nullOpStats - Variable in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

nullOpStatsLogger - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger

NullOpStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

nullStatsLogger - Variable in class org.apache.bookkeeper.stats.NullStatsProvider

NullStatsLogger - Class in org.apache.bookkeeper.stats

A no-op StatsLogger.

NullStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger

NullStatsLogger.NullCounter - Class in org.apache.bookkeeper.stats

A no-op Counter.

NullStatsLogger.NullOpStatsLogger - Class in org.apache.bookkeeper.stats

A no-op OpStatsLogger.

NullStatsProvider - Class in org.apache.bookkeeper.stats

A no-op stats provider implementation.

NullStatsProvider() - Constructor for class org.apache.bookkeeper.stats.NullStatsProvider

NUM_ADD_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

NUM_CHANNELS_PER_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

NUM_HIGH_PRIORITY_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

NUM_IO_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

NUM_JOURNAL_CALLBACK_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

NUM_LONG_POLL_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

NUM_READ_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

NUM_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

NUM_WRITABLE_BOOKIES_IN_DEFAULT_FAULTDOMAIN - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

NUM_WRITABLE_BOOKIES_IN_DEFAULT_RACK - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

NUMBER_OF_MEMTABLE_FLUSH_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

numBookiesMissingEntry - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

numEnsembleChanges - Variable in class org.apache.bookkeeper.client.LedgerHandle

numMissedEntryReads - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

numPendingEntries - Variable in class org.apache.bookkeeper.client.PendingReadOp

numPendings - Variable in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

numPendings - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

numResponsesPending - Variable in class org.apache.bookkeeper.client.PendingReadLacOp

numResponsesPending - Variable in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

numWritableBookiesInDefaultFaultDomain - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

numWritableBookiesInDefaultRack - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

O

of(T, EnsemblePlacementPolicy.PlacementPolicyAdherence) - Static method in class org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementResult

OK - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Everything is OK.

oldBookie2NewBookie - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

onBookieRackChange(List<BookieId>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Handle rack change for the bookies.

onBookieRackChange(List<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

onBookieRackChange(List<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

onChanged(long, Versioned<LedgerMetadata>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.

onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

onClusterChanged(Set<BookieId>, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy

onEntryComplete(int, LedgerHandle, LedgerEntry, Object) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp

onExit() - Method in class org.apache.bookkeeper.client.BookieInfoReader

OpBuilder<T> - Interface in org.apache.bookkeeper.client.api

Base interface for builders.

OPEN - org.apache.bookkeeper.client.api.LedgerMetadata.State

The ledger is open.

OPEN_FILE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

OPEN_LEDGER_REREPLICATION_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

OPEN_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

OpenBuilder - Interface in org.apache.bookkeeper.client.api

Builder-style interface to open exiting ledgers.

OpenBuilderBase - Class in org.apache.bookkeeper.client.impl

Base class for open builders which does the mundane builder stuff.

OpenBuilderBase() - Constructor for class org.apache.bookkeeper.client.impl.OpenBuilderBase

OpenBuilderImpl(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp.OpenBuilderImpl

openComplete(int, LedgerHandle) - Method in class org.apache.bookkeeper.client.LedgerOpenOp

openComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback

Callback for asynchronous call to open ledger.

openComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncOpenCallback

Callback method for synchronous open operation.

openLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Open a ledger as an administrator.

openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous open ledger call.

openLedgerNoRecovery(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Open a ledger as an administrator without recovering the ledger.

openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous, unsafe open ledger call.

openOpLogger - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

OPPORTUNISTIC_STRIPING - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

opStats - Variable in class org.apache.bookkeeper.stats.otel.OtelMetricsProvider

opStats - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

OpStatsData - Class in org.apache.bookkeeper.stats

This class provides a read view of operation specific stats.

OpStatsData(long, long, double, long[]) - Constructor for class org.apache.bookkeeper.stats.OpStatsData

OpStatsLogger - Interface in org.apache.bookkeeper.stats

This interface handles logging of statistics related to each operation.

opStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

orderedEnsemble - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

ordinal - Variable in class org.apache.bookkeeper.stats.ThreadRegistry.ThreadPoolThread

org.apache.bookkeeper.client - package org.apache.bookkeeper.client

BookKeeper Client.

org.apache.bookkeeper.client.api - package org.apache.bookkeeper.client.api

BookKeeper Client Public API.

org.apache.bookkeeper.client.impl - package org.apache.bookkeeper.client.impl

BookKeeper Client implementation package.

org.apache.bookkeeper.common.annotation - package org.apache.bookkeeper.common.annotation

Annotations used across the whole project.

org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf

Configurations used by bookkeeper.

org.apache.bookkeeper.feature - package org.apache.bookkeeper.feature

A feature-flag system that is used to proportionally control what features are enabled for the system.

org.apache.bookkeeper.stats - package org.apache.bookkeeper.stats

A lightweight stats library used for exporting bookkeeper stats.

org.apache.bookkeeper.stats.annotations - package org.apache.bookkeeper.stats.annotations

Annotations for bookkeeper stats api.

org.apache.bookkeeper.stats.codahale - package org.apache.bookkeeper.stats.codahale

A lightweight stats library implemention based on Codahale metrics library.

org.apache.bookkeeper.stats.otel - package org.apache.bookkeeper.stats.otel

A stats provider implementation based on OpenTelemetry.

org.apache.bookkeeper.stats.prometheus - package org.apache.bookkeeper.stats.prometheus

A stats provider implementation based on {@link https://prometheus.io/}.

OtelCounter - Class in org.apache.bookkeeper.stats.otel

OtelCounter(Meter, ScopeContext) - Constructor for class org.apache.bookkeeper.stats.otel.OtelCounter

OtelMetricsProvider - Class in org.apache.bookkeeper.stats.otel

OtelMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.otel.OtelMetricsProvider

OtelOpStatsLogger - Class in org.apache.bookkeeper.stats.otel

OtelOpStatsLogger(Meter, ScopeContext) - Constructor for class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

OtelStatsLogger - Class in org.apache.bookkeeper.stats.otel

OtelStatsLogger(OtelMetricsProvider, String, Attributes) - Constructor for class org.apache.bookkeeper.stats.otel.OtelStatsLogger

ownEventLoopGroup - Variable in class org.apache.bookkeeper.client.BookKeeper

ownTimer - Variable in class org.apache.bookkeeper.client.BookKeeper

P

PAGE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

PAGE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

parallelRead - Variable in class org.apache.bookkeeper.client.PendingReadOp

parallelRead - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

parallelRead(boolean) - Method in class org.apache.bookkeeper.client.PendingReadOp

parallelRead(boolean) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

ParallelReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

ParallelReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

parent() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc

The parent metric name.

parentEnsemble - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

parentPredicate - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

parseBookieRegion(BookieId) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

PARTIAL - org.apache.bookkeeper.client.BookieInfoReader.State

passwd - Variable in class org.apache.bookkeeper.client.LedgerCreateOp

passwd - Variable in class org.apache.bookkeeper.client.LedgerOpenOp

PASSWD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

password - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase

payload - Variable in class org.apache.bookkeeper.client.PendingAddOp

PCBC_TIMEOUT_TIMER_NUM_TICKS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

PCBC_TIMEOUT_TIMER_TICK_DURATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

PENDING_ADDS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

PendingAddOp - Class in org.apache.bookkeeper.client

This represents a pending add operation.

pendingAddOps - Variable in class org.apache.bookkeeper.client.LedgerHandle

pendingAddsSequenceHead - Variable in class org.apache.bookkeeper.client.LedgerHandle

Next entryId which is expected to move forward during LedgerHandle.sendAddSuccessCallbacks().

PendingOpsComparator() - Constructor for class org.apache.bookkeeper.client.LedgerHandleAdv.PendingOpsComparator

PendingReadLacOp - Class in org.apache.bookkeeper.client

This represents a pending ReadLac operation.

PendingReadLacOp(LedgerHandle, BookieClient, List<BookieId>, PendingReadLacOp.LacCallback) - Constructor for class org.apache.bookkeeper.client.PendingReadLacOp

PendingReadLacOp.LacCallback - Interface in org.apache.bookkeeper.client

PendingReadOp - Class in org.apache.bookkeeper.client

Sequence of entries of a ledger that represents a pending read operation.

PendingReadOp(LedgerHandle, ClientContext, long, long, boolean) - Constructor for class org.apache.bookkeeper.client.PendingReadOp

PendingReadOp.LedgerEntryRequest - Class in org.apache.bookkeeper.client

PendingReadOp.ParallelReadRequest - Class in org.apache.bookkeeper.client

PendingReadOp.SequenceReadRequest - Class in org.apache.bookkeeper.client

PendingWriteLacOp - Class in org.apache.bookkeeper.client

This represents a pending WriteLac operation.

PendingWriteLacOp(LedgerHandle, ClientContext, List<BookieId>, AsyncCallback.AddLacCallback, Object) - Constructor for class org.apache.bookkeeper.client.PendingWriteLacOp

pendingWriteRequests - Variable in class org.apache.bookkeeper.client.PendingAddOp

PERMITTED_STARTUP_USERS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

perRegionPlacement - Variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

PERSIST_BOOKIE_STATUS_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

piggyBackedLac - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

placementPolicy - Variable in class org.apache.bookkeeper.client.BookKeeper

PRESERVE_MDC_FOR_TASK_EXECUTION - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

processResult(int, String, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.ResultCallBack

processResult(int, String, Object) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

PROMETHEUS_STATS_HTTP_ADDRESS - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PROMETHEUS_STATS_HTTP_ENABLE - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PROMETHEUS_STATS_HTTP_PORT - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PROMETHEUS_STATS_LATENCY_ROLLOVER_SECONDS - Static variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PrometheusMetricsProvider - Class in org.apache.bookkeeper.stats.prometheus

A Prometheus based StatsProvider implementation.

PrometheusMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PrometheusMetricsProvider(CollectorRegistry) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

PrometheusServlet - Class in org.apache.bookkeeper.stats.prometheus

Servlet used to export metrics in prometheus text format.

PrometheusServlet(PrometheusMetricsProvider) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusServlet

PrometheusStatsLogger - Class in org.apache.bookkeeper.stats.prometheus

A Prometheus based StatsLogger implementation.

PrometheusStatsLogger(PrometheusMetricsProvider, String, Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

PrometheusTextFormat - Class in org.apache.bookkeeper.stats.prometheus

Logic to write metrics in Prometheus text format.

PrometheusTextFormat() - Constructor for class org.apache.bookkeeper.stats.prometheus.PrometheusTextFormat

promise - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Protocol version is wrong (operations are absolutely not executed).

prov - Static variable in class org.apache.bookkeeper.stats.Stats

Q

quarantineBookie(BookieId) - Method in interface org.apache.bookkeeper.client.BookieWatcher

Quarantine bookie so it will not be preferred to be chosen for new ensembles.

quarantineBookie(BookieId) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl

Quarantine bookie so it will not be preferred to be chosen for new ensembles.

quarantinedBookies - Variable in class org.apache.bookkeeper.client.BookieWatcherImpl

QuorumException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Unused.

qwcLatency - Variable in class org.apache.bookkeeper.client.PendingAddOp

R

RackawareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

A placement policy implementation use rack information for placing ensembles.

RackawareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

RackawareEnsemblePlacementPolicy(boolean) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

RackawareEnsemblePlacementPolicyImpl - Class in org.apache.bookkeeper.client

Simple rackware ensemble placement policy.

RackawareEnsemblePlacementPolicyImpl() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

RackawareEnsemblePlacementPolicyImpl(boolean) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

RackChangeNotifier - Interface in org.apache.bookkeeper.client

Notifier used by the RackawareEnsemblePlacementPolicy to get notified if a rack changes for a bookie.

RACKNAME_DISTANCE_FROM_LEAVES - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

RackOrRegionDurabilityCoverageSet() - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet

RackQuorumCoverageSet(int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

racksOrRegions - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

racksOrRegionsInQuorum - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

raise(String, Object...) - Method in class org.apache.bookkeeper.stats.AlertStatsLogger

Report an alertable condition".

rand - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

randomMax - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

rc - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.SyncObject

rc - Variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

rc - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

rc - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

rc - Variable in class org.apache.bookkeeper.client.SyncCounter

read() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

Execute the read request.

read() - Method in class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

read() - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ParallelReadRequest

read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Execute the read request.

read() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

read(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Read a sequence of entries synchronously.

READ_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

READ_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

READ_LAC_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_LAST_CONFIRMED_AND_ENTRY - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_LAST_CONFIRMED_AND_ENTRY_RESPONSE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_ONLY_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

READ_ONLY_MODE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

READ_ONLY_MODE_ON_ANY_DISK_FULL_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_OP_DM - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_OP_OUTSTANDING - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_REORDER_THRESHOLD_PENDING_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

READ_REQUESTS_REORDERED - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

READ_SYSTEM_PROPERTIES_PROPERTY - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

READ_WORKER_THREADS_THROTTLING_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

readAsync(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Read a sequence of entries asynchronously.

readAsync(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries asynchronously.

readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadCallback

Callback declaration.

readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncReadCallback

Implementation of callback interface for synchronous read method.

readCount - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

readDone - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp

readEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries synchronously.

readEntries(long, long, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Read entries from a ledger synchronously.

readEntriesInternalAsync(long, long, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle

readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.PendingReadOp

readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedOp

readEntryComplete(int, long, long, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.TryReadLastConfirmedOp

ReadException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Read operations failed (bookie error).

readExplicitLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle

ReadHandle - Interface in org.apache.bookkeeper.client.api

Provide read access to a ledger.

ReadLACAndEntryRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

readLacComplete(int, long, ByteBuf, ByteBuf, Object) - Method in class org.apache.bookkeeper.client.PendingReadLacOp

readLACSpeculativeRequestPolicy - Variable in class org.apache.bookkeeper.client.ClientInternalConf

readLastAddConfirmed() - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Obtains asynchronously the last confirmed write from a quorum of bookies.

readLastAddConfirmedAndEntry(long, long, boolean) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Asynchronous read specific entry and the latest last add confirmed.

readLastAddConfirmedAndEntryAsync(long, long, boolean) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Asynchronous read specific entry and the latest last add confirmed.

readLastAddConfirmedAndEntryAsync(long, long, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle

Asynchronous read specific entry and the latest last add confirmed.

readLastAddConfirmedAsync() - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Obtains asynchronously the last confirmed write from a quorum of bookies.

readLastAddConfirmedAsync() - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains asynchronously the last confirmed write from a quorum of bookies.

readLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains synchronously the last confirmed write from a quorum of bookies.

readLastConfirmedAndEntryComplete(int, long, LedgerEntry) - Method in interface org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback

readLastConfirmedAndEntryComplete(int, long, LedgerEntry, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedAndEntryCallback

Callback definition for bookie operation that allows reading the last add confirmed along with an entry within the last add confirmed range.

readLastConfirmedAndEntryComplete(int, long, LedgerEntry, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmedAndEntry

ReadLastConfirmedAndEntryOp - Class in org.apache.bookkeeper.client

Long poll read operation.

ReadLastConfirmedAndEntryOp(LedgerHandle, ClientContext, List<BookieId>, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback - Interface in org.apache.bookkeeper.client

Wrapper to get all recovered data from the request.

ReadLastConfirmedAndEntryOp.ParallelReadRequest - Class in org.apache.bookkeeper.client

ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest - Class in org.apache.bookkeeper.client

ReadLastConfirmedAndEntryOp.SequenceReadRequest - Class in org.apache.bookkeeper.client

readLastConfirmedComplete(int, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedCallback

Callback definition for bookie recover operations.

readLastConfirmedComplete(int, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.FutureReadLastConfirmed

readLastConfirmedComplete(int, long, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncReadLastConfirmedCallback

Implementation of callback interface for synchronous read last confirmed method.

readLastConfirmedDataComplete(int, DigestManager.RecoveryData) - Method in interface org.apache.bookkeeper.client.ReadLastConfirmedOp.LastConfirmedDataCallback

ReadLastConfirmedOp - Class in org.apache.bookkeeper.client

This class encapsulated the read last confirmed operation.

ReadLastConfirmedOp(BookieClient, DistributionSchedule, DigestManager, long, List<BookieId>, byte[], ReadLastConfirmedOp.LastConfirmedDataCallback) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedOp

ReadLastConfirmedOp.LastConfirmedDataCallback - Interface in org.apache.bookkeeper.client

Wrapper to get all recovered data from the request.

readLastEntry() - Method in class org.apache.bookkeeper.client.LedgerHandle

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

ReadOnlyLedgerHandle - Class in org.apache.bookkeeper.client

Read only ledger handle.

ReadOnlyLedgerHandle(ClientContext, long, Versioned<LedgerMetadata>, BookKeeper.DigestType, byte[], boolean) - Constructor for class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

ReadOnlyLedgerHandle.MetadataUpdater - Class in org.apache.bookkeeper.client

readReorderedCounter - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

readSpeculativeRequestPolicy - Variable in class org.apache.bookkeeper.client.ClientInternalConf

readUnconfirmed(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Read a sequence of entries synchronously.

readUnconfirmedAsync(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.

readUnconfirmedAsync(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries asynchronously, allowing to read after the LastAddConfirmed range.

readUnconfirmedEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range.
This is the same of LedgerHandle.asyncReadUnconfirmedEntries(long, long, ReadCallback, Object)

ready() - Method in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

receivedResponseSet - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp

recordReadErrorOnBookie(int) - Method in class org.apache.bookkeeper.client.LedgerHandle

Notify the LedgerHandle that a read operation was failed on a particular bookie.

recover(BookkeeperInternalCallbacks.GenericCallback<Void>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

recover(BookkeeperInternalCallbacks.GenericCallback<Void>, BookkeeperInternalCallbacks.ReadEntryListener, boolean) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

Recover the ledger.

RECOVER_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats

recoverBookieData(long, Set<BookieId>, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

recoverBookieData(Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

recoverBookieData(Set<BookieId>, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

recoverBookieData(Set<BookieId>, boolean, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

recoverBookieData(BookieId) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.

recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback

Callback definition for bookie recover operations.

recovery - Variable in class org.apache.bookkeeper.client.impl.OpenBuilderBase

RECOVERY_READ_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

recoveryReadBatchSize - Variable in class org.apache.bookkeeper.client.ClientInternalConf

RecoveryReadOp(LedgerHandle, ClientContext, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp

recycle() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet

Recycle this ack set when not used anymore.

recycle() - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet

Recycle write set object when not in use.

recyclePendAddOpObject() - Method in class org.apache.bookkeeper.client.PendingAddOp

REGION_AWARE_ANOMALOUS_ENSEMBLE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

RegionAwareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

A placement policy use region information in the network topology for placing ensembles.

RegionAwareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REGIONID_DISTANCE_FROM_LEAVES - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

register(String, int) - Static method in class org.apache.bookkeeper.stats.ThreadRegistry

register(String, int, long) - Static method in class org.apache.bookkeeper.stats.ThreadRegistry

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

Increment the failed op counter with the given eventLatency.

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerFailedValue(long) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

An operation with the given value failed.

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

registerGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Register given gauge as name name.

registerOperationFailureOnBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

registerPendingAddsGauge(Gauge<Integer>) - Method in interface org.apache.bookkeeper.client.BookKeeperClientStats

registerPendingAddsGauge(Gauge<Integer>) - Method in class org.apache.bookkeeper.client.impl.BookKeeperClientStatsImpl

registerRackChangeListener(ITopologyAwareEnsemblePlacementPolicy<BookieNode>) - Method in interface org.apache.bookkeeper.client.RackChangeNotifier

Register a listener for the rack-aware placement policy.

registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

registerSlowBookie(BookieId, long) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Register a bookie as slow so that it is tried after available and read-only bookies.

registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

registerSlowBookie(BookieId, long) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

An operation succeeded with the given eventLatency.

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleOpStatsLogger

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerSuccessfulValue(long) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

An operation with the given value succeeded.

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.otel.OtelOpStatsLogger

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.prometheus.ThreadScopedDataSketchesStatsLogger

REGISTRATION_CLIENT_CLASS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

REGISTRATION_MANAGER_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

registry - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

releaseAllQuarantinedBookies() - Method in interface org.apache.bookkeeper.client.BookieWatcher

Release all quarantined bookies, let it can be chosen for new ensembles.

releaseAllQuarantinedBookies() - Method in class org.apache.bookkeeper.client.BookieWatcherImpl

releasePermit() - Method in class org.apache.bookkeeper.client.LedgerChecker

Release a given permit.

reloadCachedMappings() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver

reloadCachedMappings() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

REMOTE_FAIL_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

REMOTE_MASK - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

REMOTE_NODE_IN_REORDER_SEQUENCE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

remove() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.LedgerEntriesIterator

removeBookieAndCheck(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet

Invalidate a previous bookie response.

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

removeScope(String, StatsLogger) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Remove the given statsLogger for scope name.

REORDER_READ_SEQUENCE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Reorder the read last add confirmed sequence of a given write quorum writeSet.

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

reorderReadLACSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Reorder the read sequence of a given write quorum writeSet.

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

reorderReadSequence(List<BookieId>, BookiesHealthInfo, DistributionSchedule.WriteSet) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

reorderReadSequenceWithRegion(List<BookieId>, DistributionSchedule.WriteSet, Map<Integer, String>, BookiesHealthInfo, boolean, String, int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

This function orders the read sequence with a given region.

reorderReadsRandom - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

reorderReadsRandom - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

reorderThresholdPendingRequests - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

reorderThresholdPendingRequests - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

REPAIRED_PLACEMENT_POLICY_NOT_ADHERING_BOOKIE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, int, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.BookieWatcher

Choose a bookie to replace bookie bookieIdx in existingBookies.

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, int, Set<BookieId>) - Method in class org.apache.bookkeeper.client.BookieWatcherImpl

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Choose a new bookie to replace bookieToReplace.

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieId>, BookieId, Set<BookieId>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

replaceBookiesInEnsemble(BookieWatcher, LedgerMetadata, List<BookieId>, Map<Integer, BookieId>, String) - Static method in class org.apache.bookkeeper.client.EnsembleUtils

replaceEnsembleEntry(long, List<BookieId>) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

replaceFromRack(BookieNode, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

replaceNotAdheringPlacementPolicyBookie(List<BookieId>, int, int) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Returns placement result.

replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

replaceToAdherePlacementPolicy(int, int, int, Set<BookieId>, List<BookieId>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

replicate(LedgerHandle, LedgerFragment, AsyncCallback.VoidCallback, Set<BookieId>, BiConsumer<Long, Long>) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator

This method replicate a ledger fragment which is a contiguous portion of a ledger that was stored in an ensemble that included the failed bookie.

replicateLedgerFragment(LedgerHandle, LedgerFragment, BiConsumer<Long, Long>) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Replicate the Ledger fragment to target Bookie passed.

REPLICATION_RATE_BY_BYTES - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ReplicationException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

Generic exception code used to propagate in replication pipeline.

replicationThrottle - Variable in class org.apache.bookkeeper.client.LedgerFragmentReplicator

reporters - Variable in class org.apache.bookkeeper.stats.codahale.CodahaleMetricsProvider

REPP_DISABLE_DURABILITY_ENFORCEMENT_FEATURE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_DISABLE_DURABILITY_FEATURE_NAME - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_DISALLOW_BOOKIE_PLACEMENT_IN_REGION_FEATURE_NAME - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_DNS_RESOLVER_CLASS - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

REPP_ENABLE_DURABILITY_ENFORCEMENT_IN_REPLACE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_ENABLE_VALIDATION - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_MINIMUM_REGIONS_FOR_DURABILITY - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

REPP_RANDOM_READ_REORDERING - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

REPP_REGIONS_TO_WRITE - Static variable in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

request - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

REQUEST_TIMER_NO_OF_TICKS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

REQUEST_TIMER_TICK_DURATION_MILLISEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

requestComplete - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

requestTimeNano - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

requestTimeNanos - Variable in class org.apache.bookkeeper.client.PendingAddOp

requestTimeNanos - Variable in class org.apache.bookkeeper.client.PendingReadOp

requestTimer - Variable in class org.apache.bookkeeper.client.BookKeeper.Builder

requestTimer - Variable in class org.apache.bookkeeper.client.BookKeeper

requestTimer(HashedWheelTimer) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client to use a provided Netty HashedWheelTimer.

requestTimer(HashedWheelTimer) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder

Configure the bookkeeper client to use a provided HashedWheelTimer.

requestTimer(HashedWheelTimer) - Method in class org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl

requiredBookiesMissingEntryForRecovery - Variable in class org.apache.bookkeeper.client.PendingReadOp

REREPLICATION_ENTRY_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

resetRate(int) - Method in class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler

resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver

resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

resolve(BookieId) - Method in class org.apache.bookkeeper.client.BookieAddressResolverDisabled

resolve(BookieId) - Method in class org.apache.bookkeeper.client.DefaultBookieAddressResolver

resolveNetworkLocation(BookieId) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

resolver - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

response - Variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

ResultCallBack(CompletableFuture<Void>) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin.ResultCallBack

rotateLatencyCollection() - Method in class org.apache.bookkeeper.stats.prometheus.DataSketchesOpStatsLogger

rotateLatencyCollection() - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

RoundRobinDistributionSchedule - Class in org.apache.bookkeeper.client

A specific DistributionSchedule that places entries in round-robin fashion.

RoundRobinDistributionSchedule(int, int, int) - Constructor for class org.apache.bookkeeper.client.RoundRobinDistributionSchedule

RRTopologyAwareCoverageEnsemble(int, int, int, int, Set<String>, int, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, Set<String>, int, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

RRTopologyAwareCoverageEnsemble(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

run() - Method in class org.apache.bookkeeper.client.ForceLedgerOp

run() - Method in class org.apache.bookkeeper.client.MetadataUpdateLoop

run() - Method in class org.apache.bookkeeper.client.PendingReadOp

run() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater

RW_REREPLICATE_BACKOFF_MS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

rwLock - Variable in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

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

rwLock - Variable in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

S

SANITY_CHECK_METRICS_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

scheduleBookieHealthCheckIfEnabled(ClientConfiguration) - Method in class org.apache.bookkeeper.client.BookKeeper

scheduledFuture - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

scheduler - Variable in class org.apache.bookkeeper.client.BookKeeper

scope - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider

scope() - Method in annotation type org.apache.bookkeeper.stats.annotations.StatsDoc

The scope of this stats.

scope(String) - Method in class org.apache.bookkeeper.feature.CacheableFeatureProvider

scope(String) - Method in interface org.apache.bookkeeper.feature.FeatureProvider

Provide the feature provider under scope name.

scope(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.codahale.CodahaleStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.codahale.FastCodahaleStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

scope(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Provide the stats logger under scope name.

ScopeContext - Class in org.apache.bookkeeper.stats.otel

Holder for a scope and a set of associated labels.

ScopeContext - Class in org.apache.bookkeeper.stats.prometheus

Holder for a scope and a set of associated labels.

ScopeContext(String, Attributes) - Constructor for class org.apache.bookkeeper.stats.otel.ScopeContext

ScopeContext(String, Map<String, String>) - Constructor for class org.apache.bookkeeper.stats.prometheus.ScopeContext

scopeLabel(String, String) - Method in class org.apache.bookkeeper.stats.otel.OtelStatsLogger

scopeLabel(String, String) - Method in class org.apache.bookkeeper.stats.prometheus.PrometheusStatsLogger

scopeLabel(String, String) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Provide the stats logger with an attached label.

scopes - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider

scopeStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

SecurityException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code

seenBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Select a node from networkLoc rack excluding excludeBookies.

selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(String, Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Select a node from a given network location.

selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Select a node from cluster excluding excludeBookies and bookie nodes of excludeRacks.

selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

It randomly selects a BookieNode that is not on the excludeRacks set, excluding the nodes in excludeBookies set.

selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

selectRandom(int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

Choose a random node from whole cluster.

selectRandomFromRack(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

Choose random node under a given network path.

selectRandomFromRegions(Set<String>, int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

selectRandomInternal(List<BookieNode>, int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

semaphore - Variable in class org.apache.bookkeeper.client.LedgerChecker

sendAddSuccessCallbacks() - Method in class org.apache.bookkeeper.client.LedgerHandle

sendAddSuccessCallbacks() - Method in class org.apache.bookkeeper.client.PendingAddOp

sendForceLedgerRequest(int) - Method in class org.apache.bookkeeper.client.ForceLedgerOp

sendNextRead() - Method in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

sendNextRead() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

sendReadTo(int, BookieId, PendingReadOp.LedgerEntryRequest) - Method in class org.apache.bookkeeper.client.PendingReadOp

sendReadTo(int, BookieId, ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

sendWriteLacRequest(int) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

sentReplicas - Variable in class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

sentReplicas - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

seq - Variable in class org.apache.bookkeeper.client.PendingReadOp

seq - Variable in class org.apache.bookkeeper.client.SyncCounter

SequenceReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

SequenceReadRequest(List<BookieId>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

server - Variable in class org.apache.bookkeeper.stats.prometheus.PrometheusMetricsProvider

SERVER_NUM_ACCEPTOR_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_NUM_IO_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_SOCK_KEEPALIVE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_SOCK_LINGER - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SERVER_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ServerConfiguration - Class in org.apache.bookkeeper.conf

Configuration manages server-side settings.

ServerConfiguration() - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration

Construct a default configuration object.

ServerConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration

Construct a configuration based on other configuration.

set(boolean) - Method in class org.apache.bookkeeper.feature.SettableFeature

set(int) - Method in class org.apache.bookkeeper.feature.SettableFeature

set(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet

Set the index at index i.

setAddEntryQuorumTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set timeout for top-level add entry request.

setAddEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set timeout for add entry request.

setAdvertisedAddress(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the bookie to advertise a specific address.

setAllocatorLeakDetectionPolicy(LeakDetectionPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Enable the leak detection for the allocator.

setAllocatorOutOfMemoryPolicy(OutOfMemoryPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Define the memory allocator out of memory policy.

setAllocatorPoolingConcurrenncy(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Controls the amount of concurrency for the memory pool.

setAllocatorPoolingPolicy(PoolingPolicy) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Define the memory pooling policy.

setAllowEphemeralPorts(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the bookie to allow using an ephemeral port.

setAllowLoopback(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the bookie to allow loopback interfaces to be used as the primary bookie interface.

setAllowMultipleDirsUnderSameDiskPartition(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the Bookie to allow/disallow multiple ledger/index/journal directories in the same filesystem diskpartition.

setAllowShadedLedgerManagerFactoryClass(boolean) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set the flag to allow using shaded ledger manager factory class for instantiating a ledger manager factory.

setAllowStorageExpansion(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Change the setting of whether or not we should allow ledger/index dirs to be added to the current set of dirs.

setAuditorAcquireConcurrentOpenLedgerOperationsTimeoutMSec(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the acquire concurrent open ledger operations timeout.

setAuditorLedgerVerificationPercentage(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set what percentage of a ledger (fragment)'s entries will be verified.

setAuditorMaxNumberOfConcurrentOpenLedgerOperations(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the semaphore limit value for getting ledger from zookeeper in auto recovery.

setAuditorPeriodicBookieCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the interval between auditor bookie checks.

setAuditorPeriodicCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the regularity at which the auditor will run a check of all ledgers.

setAuditorPeriodicPlacementPolicyCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Sets the regularity/interval at which the auditor will run a placement policy check of all ledgers, which are closed.

setAuditorPeriodicReplicasCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Sets the interval at which the auditor will run a replicas check of all ledgers.

setAuthorizedRoles(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set authorized roles.

setAutoRecoveryDaemonEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Sets that whether the auto-recovery service can start along with Bookie server itself or not.

setBookieAddressResolver(BookieAddressResolver) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

setBookieAddressResolverEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Enable/Disable BookieAddressResolver.

setBookieAuthProviderFactoryClass(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the bookie authentication provider factory class name.

setBookieErrorThresholdPerInterval(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the error threshold per interval (ClientConfiguration.getBookieHealthCheckIntervalSeconds()) for a bookie before it is quarantined.

setBookieFailureHistoryExpirationMSec(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the bookie failure tracking expiration timeout.

setBookieHealthCheckInterval(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the bookie health check interval.

setBookieId(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the bookie to advertise a specific BookieId.

setBookieMaxWeightMultipleForWeightBasedPlacement(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the max multiple to use for nodes with very high weight.

setBookiePort(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set new bookie port that bookie server listen on.

setBookieQuarantineRatio(double) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

set the bookie quarantine ratio.

setBookieQuarantineTime(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the time for which a bookie will be quarantined.

setBookieRecoveryDigestType(BookKeeper.DigestType) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set digest type used in bookkeeper admin.

setBookieRecoveryPasswd(byte[]) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set passwd used in bookkeeper admin.

setBusyWaitEnabled(boolean) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Option to enable busy-wait settings.

setClientAuthProviderFactoryClass(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set the client authentication provider factory class name.

setClientConnectBookieUnavailableLogThrottling(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the log frequency when a bookie is unavailable, in order to limit log filesize.

setClientConnectTimeoutMillis(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set client netty connect timeout in millis.

setClientReceiveBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set client netty channel receive buffer size.

setClientRole(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the client role.

setClientSendBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set client netty channel send buffer size.

setClientSockKeepalive(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set socket keepalive setting.

setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set socket nodelay setting.

setClientWriteBufferHighWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set client netty channel write buffer high water mark.

setClientWriteBufferLowWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set client netty channel write buffer low water mark.

setCloseChannelOnResponseTimeout(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configures action in case if server timed out sending response to the client.

setCompactionMaxOutstandingRequests(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the maximum number of entries which can be compacted without flushing.

setCompactionRate(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the rate of compaction adds.

setCompactionRateByBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the rate of compaction adds.

setCompactionRateByEntries(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the rate of compaction adds.

setConf(Configuration) - Method in interface org.apache.bookkeeper.conf.Configurable

Set the configuration to be used by this object.

setDataIntegrityCheckingEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Enabled data integrity checker.

setDataIntegrityStampMissingCookiesEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

When this config is set to true and the data integrity checker is also enabled then any missing cookie files in the ledger directories do not prevent the bookie from booting.

setDefaultRocksDBConf(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set default rocksdb conf.

setDelayEnsembleChange(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Enable/Disable delaying ensemble change.

setDesiredNumZonesPerWriteQuorum(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set the desired number of zones per write quorum in ZoneAwarePlacementPolicy.

setDisableEnsembleChangeFeatureName(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the name of the dynamic feature that disables ensemble change.

setDisableServerSocketBind(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Configure the bookie to disable bind on network interfaces, this bookie will be available only to BookKeeper clients executed on the local JVM.

setDiskCheckInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the disk checker interval to monitor ledger disk space.

setDiskLowWaterMarkUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the disk free space low water mark threshold.

setDiskUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the Disk free space threshold as a fraction of the total after which disk will be considered as full during disk check.

setDiskUsageWarnThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the warning threshold for disk usage.

setDiskWeightBasedPlacementEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set whether or not disk weight based placement is enabled.

setEnableBookieAddressTracking(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Enable/Disable bookie address changes tracking.

setEnableBookieFailureTracking(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration