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

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.

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(long, byte[]) - 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.LedgerHandle

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[]) - 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.LedgerHandleAdv

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.ReadOnlyLedgerHandle

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.

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(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.

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

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

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

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

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

Configure the bookkeeper client with a provided ByteBufAllocator.

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

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(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.

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.

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

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.

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 class org.apache.bookkeeper.client.LedgerHandle

Add entry asynchronously to an open ledger.

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

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

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

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, LedgerManager) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin

areEntriesOfLedgerStoredInTheBookie(long, BookieId, LedgerMetadata) - 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[], 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.LedgerHandle

Add entry asynchronously to an open ledger.

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(ByteBuf, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle

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.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.LedgerHandle

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.LedgerHandleAdv

Add entry asynchronously to an open ledger.

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.LedgerHandleAdv

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.LedgerHandleAdv

LedgerHandleAdv will not allow addEntry without providing an entryId.

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[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

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

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, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger asynchronously.

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.

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, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper

Open existing ledger asynchronously for reading.

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

Open a ledger as an administrator.

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.

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

Open a ledger as an administrator without recovering the ledger.

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(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.

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

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

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

Recover a specific ledger.

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() - Method in interface org.apache.bookkeeper.feature.Feature

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

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

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

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

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

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

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

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

B

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

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(int) - Constructor for exception org.apache.bookkeeper.client.api.BKException

Create a new exception.

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

Create a new exception with the cause.

BKException - Exception in org.apache.bookkeeper.client

Class the enumerates all the possible error conditions.

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

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 - 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 - Variable in class org.apache.bookkeeper.client.BookKeeper

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 - Interface in org.apache.bookkeeper.client

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

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

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 - Interface in org.apache.bookkeeper.client

Watch for Bookkeeper cluster status.

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

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

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 - Interface in org.apache.bookkeeper.client.api

This is the entry point for BookKeeper client side API.

BookKeeper - Class in org.apache.bookkeeper.client

BookKeeper client.

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() - Constructor for class org.apache.bookkeeper.client.BookKeeper

Allow to extend BookKeeper for mocking in unit tests.

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(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(BookKeeper, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin

Constructor that takes in a BookKeeper instance .

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

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

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

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

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

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

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

closeRecovered() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

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(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 - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

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.

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

create(int) - Static method in exception org.apache.bookkeeper.client.BKException

Create an exception from an error code.

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(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() - Static method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

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(BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Creates a new ledger.

createLedger(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[]) - 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.

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

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

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_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

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 - Enum in org.apache.bookkeeper.client.api

Digest type.

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

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

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 - Interface in org.apache.bookkeeper.client

This interface determins how entries are distributed among bookies.

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

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(DNSToSwitchMapping) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client to use the provided dns resolver DNSToSwitchMapping.

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

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

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

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.

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

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

duplicate() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry

Returns a duplicate of this entry.

duplicate(LedgerEntry) - Static method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl

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

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.PendingAddOp

equals(Object) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation

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(EventLoopGroup) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client with a provided Netty EventLoopGroup.

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

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

Configure the bookkeeper client with a provided EventLoopGroup.

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

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.

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

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

ExplicitLacFlushPolicy - Interface in org.apache.bookkeeper.client

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

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(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.

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

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(FeatureProvider) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client to use a provided FeatureProvider.

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

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

Feature Provider.

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

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

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

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

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, int) - Constructor for class org.apache.bookkeeper.feature.FixedValueFeature

FixedValueFeature(String, boolean) - 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

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

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(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.

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.

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

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.

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(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils

getCurrentEnsemble() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

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.

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(long) - Method in interface org.apache.bookkeeper.client.api.LedgerEntries

Gets a specific LedgerEntry by entryId.

getEntry() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl

Gets wanted LedgerEntry.

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

Gets a specific LedgerEntry by entryId.

getEntry() - Method in class org.apache.bookkeeper.client.LedgerEntry

Returns the content of the entry.

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, 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.

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.

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, Feature) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

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.

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.

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.

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(long) - Method in interface org.apache.bookkeeper.client.api.BookKeeper

Get ledger metadata of a given ledger id.

getLedgerMetadata() - Method in interface org.apache.bookkeeper.client.api.Handle

Returns the metadata of this ledger.

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

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

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

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.

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.

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.

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.

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).

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(Collection<T>) - Method in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

getNextRandom() - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection

getNextRandom(Collection<T>) - 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.WeightedRandomSelectionImpl

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

Get the number of threads that should handle write requests.

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.

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

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.

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.

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.

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

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

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.SyncCounter

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.

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

getScheduler() - Method in interface org.apache.bookkeeper.client.ClientContext

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).

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

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

Get the stats provider used by bookie.

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.

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

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

Get throttle value.

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

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).

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(int) - Static method in enum org.apache.bookkeeper.client.api.WriteFlag

Converts a set of flags from a binary representation.

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

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

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 - Interface in org.apache.bookkeeper.client.api

Handle to manage an open ledger.

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

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

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(long, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule

Whether entry presents on given bookie index.

hasEntry() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl

Whether this entity contains an entry.

hasEntry(long, int) - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule

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

hashCode() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation

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

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

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

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(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.

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

initializeEnsemblePlacementPolicy(ClientConfiguration, DNSToSwitchMapping, HashedWheelTimer, FeatureProvider, StatsLogger, BookieAddressResolver) - Method in class org.apache.bookkeeper.client.BookKeeper

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(ByteBufList) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

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

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.

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

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(long) - Method in class org.apache.bookkeeper.client.BookKeeper

Check whether the ledger with identifier lId has been closed.

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

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.

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.

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.

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

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(BookieClient, BookieWatcher) - Constructor for class org.apache.bookkeeper.client.LedgerChecker

LedgerChecker(BookKeeper, int) - 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 - Interface in org.apache.bookkeeper.client.api

An entry in a ledger.

LedgerEntry - Class in org.apache.bookkeeper.client

Ledger entry.

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(LedgerHandle, long, long, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerFragment

LedgerFragment(LedgerFragment, 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, StatsLogger, ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator

LedgerFragmentReplicator(BookKeeper, 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, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Constructor for class org.apache.bookkeeper.client.LedgerOpenOp

Constructor.

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

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.

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

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

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

M

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_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

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

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() - Method in interface org.apache.bookkeeper.feature.Feature

Returns a textual representation of the feature.

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

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

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, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Create an ensemble with parent ensemble.

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - 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.RackawareEnsemblePlacementPolicy

newEnsemble(int, int, int, Map<String, byte[]>, Set<BookieId>) - 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.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, Set<BookieId>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

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

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 - 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

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_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, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback

Callback for asynchronous call to open ledger.

openComplete(int, LedgerHandle) - Method in class org.apache.bookkeeper.client.LedgerOpenOp

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

Callback method for synchronous open operation.

openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous open ledger call.

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

Open a ledger as an administrator.

openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper

Synchronous, unsafe open ledger call.

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

Open a ledger as an administrator without recovering the ledger.

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

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

orderedEnsemble - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

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.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.

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(boolean) - Method 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.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

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

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

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).

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

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(long, long) - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Read a sequence of entries synchronously.

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_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, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Read entries from a ledger synchronously.

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

Read a sequence of entries 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, 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) - Method in interface org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback

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 #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(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.

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(long, Set<BookieId>, boolean, boolean) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

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

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

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

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

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.

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

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(HashedWheelTimer) - Method in interface org.apache.bookkeeper.client.api.BookKeeperBuilder

Configure the bookkeeper client to use a provided Netty HashedWheelTimer.

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

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

Configure the bookkeeper client to use a provided HashedWheelTimer.

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

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(BookieId) - Method in class org.apache.bookkeeper.client.BookieAddressResolverDisabled

resolve(BookieId) - Method in class org.apache.bookkeeper.client.DefaultBookieAddressResolver

resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DefaultResolver

resolve(List<String>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

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

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(TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

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

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

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(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.

scopes - Variable in class org.apache.bookkeeper.feature.CacheableFeatureProvider

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<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(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<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.RackawareEnsemblePlacementPolicy

selectFromNetworkLocation(String, Set<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<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

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(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(Set<String>, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

selectFromNetworkLocation(String, 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_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(int, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.WriteSet

Set the index at index i.

set(int) - Method in class org.apache.bookkeeper.feature.SettableFeature

set(boolean) - Method in class org.apache.bookkeeper.feature.SettableFeature

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

Enable/Disable bookie failure tracking.

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

Enable autodetection of digest type.

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

Configure the bookie to listen for BookKeeper clients executed on the local JVM.

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

Enable/Disable parallel reading in recovery read.

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

Enable/Disable recording task execution stats.

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

Enable/Disable recording task execution stats.

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

Set the flag to enforce minimum number of fault domains for write.

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

Set the flag to enforce minimum number of racks per write quorum.

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

Set the flag to enforce strict zoneaware placement.

setEnsemblePlacementPolicy(Class<? extends EnsemblePlacementPolicy>) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set Ensemble Placement Policy Class.

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

Enable/Disable ordering slow bookies in placement policy.

setEntryBuf(ByteBuf) - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl

setEntryFormatterClass(Class<? extends EntryFormatter>) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set entry formatter Class.

setEntryId(long) - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl

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

setEntryListener(BookkeeperInternalCallbacks.ReadEntryListener) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp

Set an entry listener to listen on individual recovery reads during recovery procedure.

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

Set entry Location rocksdb conf.

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

Enable/disable entry log file preallocation.

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

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

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

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

Set entry logger size limitation.

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

Deprecated.

since 4.5, use BookKeeper.Builder.eventLoopGroup(EventLoopGroup)

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

Set the interval to check the need for sending an explicit LAC.

setExtraServerComponents(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the extra list of server lifecycle components to enable on a bookie server.

setFeature(String, Feature) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

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

Set the minimum total size for the internal file info cache tables for initialization.

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

Set fileinfo format version to write.

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

Set the max idle time allowed for a open file info existed in file info cache.

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

Set the period of time after which the first speculative read last add confirmed and entry should be triggered.

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

Set the first speculative read timeout.

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

Set flush interval.

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

Set entry log flush interval in bytes.

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

Allow manually force compact the entry log or not.

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

Sets that whether force start a bookie in readonly mode.

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

Set whether the bookie is configured to use persistent entrylogMetadataMap.

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

Set directory to persist Entrylog metadata if gcPersistentEntrylogMetadataMapEnabled is true.

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

Max number of concurrent requests in garbage collection of overreplicated ledgers.

setGcOverreplicatedLedgerWaitTime(long, TimeUnit) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set wait time for garbage collection of overreplicated ledgers.

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

Set garbage collection wait time.

setGetBookieInfoIntervalSeconds(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the time interval between successive polls for bookie get info.

setGetBookieInfoRetryIntervalSeconds(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Set the time interval between retries on unsuccessful GetInfo requests.

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

Set the timeout value in secs for the GET_BOOKIE_INFO request.

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

Enable/Disable hostname verification for tls connection.

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

Set whether to start the http server or not.

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

Set Http server host listening on.

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

Set Http server keyStore password.

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

Set Http server keystore path.

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

Set Http server port listening on.

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

Set if Http Server Tls enable.

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

Set Http server trustStore password.

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

Set Http server trustStore path.

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

Set the flag whether to ignore startup failures on loading server components specified at ServerConfiguration.getExtraServerComponents().

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

Sets the flag to ignore usage of localnode in placement policy.

setIndexDirName(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set dir name to store index files.

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

Set whether force GC is allowed when disk full or almost full.

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

Set whether use bytes to throttle garbage collector compaction or not.

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

Enable/disable group journal force writes.

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

Set journal alignment size.

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

Set maximum entries to buffer to impose on a journal write to achieve grouping.

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

Set maximum bytes to buffer to impose on a journal write to achieve grouping.

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

Set JournalChannelProvider classname.

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

Set dir name to store journal files.

setJournalDirsName(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set dir names to store journal files.

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

Set if we should flush the journal when queue is empty.

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

Set journal format version to write.

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

Sets the maximum latency to impose on a journal write to achieve grouping.

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

Set the max amount of memory that can be used by the journal.

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

Set PageCache flush interval in second.

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

Set the size of the journal queue.

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

Sets that whether should we remove pages from page cache after force write.

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

Set reuse journal files.

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

Enable or disable journal syncs.

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

Set the size of the write buffers used for the journal.

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

Should the data be written to journal before acknowledgment.

setLac(long) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

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

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

setLedgerDirNames(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set dir names to store ledger data.

setLedgerIdFormatterClass(Class<? extends LedgerIdFormatter>) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set Ledger id formatter Class.

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

setLedgerManagerFactoryClass(Class<? extends LedgerManagerFactory>) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration

Set Ledger Manager Factory Class.

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

Set Ledger Manager Factory Class Name.

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

Deprecated.

replaced by AbstractConfiguration.setLedgerManagerFactoryClass(java.lang.Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>)

setLedgerMetadata(Versioned<LedgerMetadata>, Versioned<LedgerMetadata>) - Method in class org.apache.bookkeeper.client.LedgerHandle

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

Set Ledger metadata format version.

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

Set ledger metadata rocksdb conf.

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

Set the LedgerStorage implementation class name.

setLength(long) - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl

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

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

Sets flag to limit the stats logging.

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

Set the network interface that the bookie should listen on.

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

Set local scrub period in seconds (<=0 for disabled).

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

Get local scrub rate limit (entries/second).

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

Set the grace period, in milliseconds, which the replication worker has to wait before releasing the lock after it failed to replicate a ledger.

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

Setter for LostBookieRecoveryDelay value (in seconds) in Zookeeper.

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

Set the delay interval for starting recovery of a lost bookie.

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

Set interval to run major compaction.

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

Set the maximum milliseconds to run major compaction.

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

Set threshold of major compaction.

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

Set max number of adds in progress.

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

Set the max allowed ensemble change number.

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

Set max number of older journal files to kept.

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

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

Set new max journal file size.

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

Set the max number of pending add requests for each add worker thread.

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

Set the max number of pending read requests for each read worker thread.

setMaxProbabilityMultiplier(int) - Method in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

setMaxProbabilityMultiplier(int) - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection

setMaxProbabilityMultiplier(int) - Method in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

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

Set max number of reads in progress.

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

Set the maximum interval between successive speculative read last add confirmed and entry requests.

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

Set the max speculative read timeout.

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

Set the metadata service uri.

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

Set metastore implementation class.

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

Set max entries per scan in metastore.

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

Set the minimum number of racks per write quorum.

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

Set the minimum number of zones per write quorum in ZoneAwarePlacementPolicy.

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

Set interval to run minor compaction.

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

Set the maximum milliseconds to run minor compaction.

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

Set threshold of minor compaction.

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

Sets the minimum safe usable size to be available in ledger directory for Bookie to create entry log files.

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

Sets the minimum safe usable size to be available in ledger directory for Bookie to accept high priority writes.

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

Sets 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).

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

Set the max number of bytes a single message can be that is read by the bookie.

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

Set the max number of bytes a single message can be that is read by the bookie.

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

Set the max number of bytes a single message can be that is read by the bookie.

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

Deprecated.

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

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

Set the network topology stabilize period in seconds.

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

Set the number of threads that would handle write requests.

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

Set num channels per bookie.

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

Set the number of threads that should be used for high priority requests (i.e.

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

Set the number of IO threads.

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

Deprecated.

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

Set the number of threads that should handle long poll requests.

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

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

Set the number of threads that would handle read requests.

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

Set the number of worker threads.

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

Set limitation of number of open files.

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

Set the grace period which the rereplication worker will wait before fencing and rereplicating a ledger fragment which is still being written to, on bookie failure.

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

Enable/Disable opportunistic striping.

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

Set limitation number of index pages in ledger cache.

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

Set page size.

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

Deprecated.

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

Deprecated.

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

Limit who can start the application to prevent future permission errors.

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

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

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

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

Whether to preserve MDC for tasks in Executor.

setRC(int) - Method in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

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

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

Set the number of bytes we should use as capacity for org.apache.bookkeeper.bookie.BufferedReadChannel.

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

Set the timeout for read entry request.

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

Set whether the bookie is able to go into read-only mode.

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

Set whether the bookie is able to go into read-only mode when any disk is full.

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

Deprecated.

use ClientConfiguration.setReadEntryTimeout(int) or ClientConfiguration.setAddEntryTimeout(int) instead

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

Use auto-throttling of the read-worker threads.

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

Set Recovery Read Batch Size.

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

Set Recv ByteBuf allocator initial buf size.

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

Set Recv ByteBuf allocator max buf size.

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

Set Recv ByteBuf allocator min buf size.

setRegistrationClientClass(Class<? extends RegistrationClient>) - Method in class org.apache.bookkeeper.conf.ClientConfiguration

Deprecated.

since 4.7.0

setRegistrationManagerClass(Class<? extends RegistrationManager>) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Deprecated.

since 4.7.0, in favor of using AbstractConfiguration.setMetadataServiceUri(String)

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

Enable/disable reordering read sequence on reading entries.

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

Set the threshold for the number of pending requests beyond which to reorder reads.

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

setReplicateType(LedgerFragment.ReplicateType) - Method in class org.apache.bookkeeper.client.LedgerFragment

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

Set the bytes rate of re-replication.

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

Set the number of ticks per wheel for the request timer.

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

Set the tick duration in milliseconds.

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

Set the max entries to keep in fragment for re-replication.

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

Set how long to backoff when encountering exception on rereplicating a ledger.

setSequence(Enumeration<LedgerEntry>) - Method in class org.apache.bookkeeper.client.SyncCounter

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

Set the number of IO threads.

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

Set socket keepalive setting.

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

Set socket linger timeout on close.

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

Set socket nodelay setting.

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

Set server netty channel write buffer high water mark.

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

Set server netty channel write buffer low water mark.

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

Set the class prefix of the shaded ledger manager factory class for instantiating a ledger manager factory.

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

Set the number of bytes we used as chunk allocation for org.apache.bookkeeper.bookie.SkipListArena.

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

Set the max size we should allocate from the skiplist arena.

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

Set skip list size limit.

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

Deprecated.

Use ServerConfiguration.setLedgerStorageClass(String) to configure the implementation class

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

Set the multipler to use when determining time between successive speculative read LAC requests.

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

Set the speculative read timeout.

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

Set the multipler to use when determining time between successive speculative read requests.

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

Set the timeout value in secs for the START_TLS request.

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

Turn on/off statistics.

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

Deprecated.

since 4.5, use BookKeeper.Builder.statsLogger(StatsLogger)

setStatsProviderClass(Class<? extends StatsProvider>) - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Set the stats provider used by bookie.

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

Enable/disable having read operations for a ledger to be sticky to a single bookie.

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

Enable the client to use system time as the ledger creation time.

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

Enable the Auditor to use system time as underreplicated ledger mark time.

SettableFeature - Class in org.apache.bookkeeper.feature

A feature implementation that allow changing availability programmatically.

SettableFeature(String, int) - Constructor for class org.apache.bookkeeper.feature.SettableFeature

SettableFeature(String, boolean) - Constructor for class org.apache.bookkeeper.feature.SettableFeature

SettableFeatureProvider - Class in org.apache.bookkeeper.feature

A provider will provide settable features.

SettableFeatureProvider(String, int) - Constructor for class org.apache.bookkeeper.feature.SettableFeatureProvider

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

Set task execution duration which triggers a warning.

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

Set client netty TCP user timeout in millis (only for Epoll channels).

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

Set throttle value.

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

Set the interval between successive executions of the operation timeout monitor.

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

Deprecated.

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

Set number of ticks that used for timeout timer.

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

Set the tick duration in milliseconds that used for timeout timer.

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

Set tls certificate files refresh duration in seconds.

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

Set the path to file containing TLS Certificate.

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

Set the path to file containing TLS Certificate.

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

Specify whether the client will send an TLS certificate on TLS-handshake.

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

Set the list of enabled TLS cipher suites.

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

Set the list of enabled TLS protocols.

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

Set the keystore path for the client.

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

Set the keystore path for the client.

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

Set the path to file containing keystore password, if the client keystore is password protected.

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

Set the path to file containing keystore password, if the client keystore is password protected.

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

Set the keystore type for client.

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

Set the keystore type for client.

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

Set TLS Provider (JDK or OpenSSL).

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

Set the client security provider factory class name.

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

Set the truststore path for the client.

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

Set the truststore path for the client.

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

Set the path to file containing truststore password, if the client truststore is password protected.

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

Set the path to file containing truststore password, if the client truststore is password protected.

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

Set the truststore type for client.

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

Set the truststore type for client.

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

Sets the grace period (in seconds) for underreplicated ledgers recovery.

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

Configure the bookie to use its hostname to register with the co-ordination service(eg: zookeeper) and in ledger metadata.

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

Configure the bookie to use its short hostname or FQDN hostname to register with the co-ordination service(eg: zookeeper) and in ledger metadata.

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

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

Set whether to use transactional compaction and using a separate log for compaction or not.

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

Set whether or not to use older Bookkeeper wire protocol (no protobuf).

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

Set whether the bookie is configured to double check prior to gc.

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

Timeout controlling wait on request send in case of unresponsive bookie(s) (i.e.

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

Timeout controlling wait on response send in case of unresponsive client (i.e.

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

Set the number of bytes used as capacity for the write buffer.

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

Set the usage of ACLs of new z-nodes.

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

Deprecated.

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

Set zookeeper access request rate limit.

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

Set zookeeper client backoff retry max time in millis.

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

Set zookeeper client backoff max retry times.

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

Set zookeeper client backoff retry start time in millis.

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

Deprecated.

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

Set zookeeper timeout.

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

Deprecated.

since 4.5, use BookKeeper.Builder.zk(ZooKeeper)

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

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

shouldStoreCtime(LedgerMetadata) - Static method in class org.apache.bookkeeper.client.LedgerMetadataUtils

shuffleWithMask(DistributionSchedule.WriteSet, int, int) - Static method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

Shuffle all the entries of an array that matches a mask.

SingleFragmentCallback(AsyncCallback.VoidCallback, LedgerHandle, LedgerManager, long, Map<BookieId, BookieId>) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

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

The number of indexes in the write set.

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

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

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

slave - Variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

slave - Variable in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy

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

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

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

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

Sort the indices.

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

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

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

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

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

SpeculativeRequestExecutionPolicy - Interface in org.apache.bookkeeper.client

Define a policy for speculative request execution.

SpeculativeRequestExecutor - Interface in org.apache.bookkeeper.client

Define an executor for issuing speculative requests.

splitIntoSubFragments(LedgerHandle, LedgerFragment, long) - Static method in class org.apache.bookkeeper.client.LedgerFragmentReplicator

Split the full fragment into batched entry fragments by keeping rereplicationEntryBatchSize of entries in each one and can treat them as sub fragments.

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

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

start() - Method in class org.apache.bookkeeper.client.BookieInfoReader

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

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

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

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

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

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

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

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

Configure the bookkeeper client with a provided StatsLogger.

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

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

Configure the bookkeeper client with a provided StatsLogger.

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

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

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

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

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

stopExplicitLacFlush() - Method in interface org.apache.bookkeeper.client.ExplicitLacFlushPolicy

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

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

storeCtime - Variable in class org.apache.bookkeeper.client.LedgerMetadataImpl

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

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

submitCallback(int) - Method in class org.apache.bookkeeper.client.ListenerBasedPendingReadOp

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

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

subset(Set<Integer>) - Method in class org.apache.bookkeeper.client.LedgerFragment

Return a ledger fragment contains subset of bookies.

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

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

SyncCallbackUtils - Class in org.apache.bookkeeper.client

Utility for callbacks.

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

SyncCallbackUtils.FutureReadLastConfirmed - Class in org.apache.bookkeeper.client

SyncCallbackUtils.FutureReadLastConfirmedAndEntry - Class in org.apache.bookkeeper.client

SyncCallbackUtils.LastAddConfirmedCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncAddCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncCloseCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncCreateAdvCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncCreateCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncDeleteCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncOpenCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncReadCallback - Class in org.apache.bookkeeper.client

SyncCallbackUtils.SyncReadLastConfirmedCallback - Class in org.apache.bookkeeper.client

SyncCloseCallback(CompletableFuture<Void>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCloseCallback

SyncCounter - Class in org.apache.bookkeeper.client

Implements objects to help with the synchronization of asynchronous calls.

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

SyncCreateAdvCallback(CompletableFuture<? super LedgerHandleAdv>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCreateAdvCallback

SyncCreateCallback(CompletableFuture<? super LedgerHandle>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCreateCallback

SyncDeleteCallback(CompletableFuture<Void>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncDeleteCallback

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

SyncOpenCallback(CompletableFuture<? super LedgerHandle>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncOpenCallback

SyncReadCallback(CompletableFuture<Enumeration<LedgerEntry>>) - Constructor for class org.apache.bookkeeper.client.SyncCallbackUtils.SyncReadCallback

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

T

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

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

Throttler(int) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator.Throttler

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

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

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

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

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

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

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

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

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

Operations timeouts.

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

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

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

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

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

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

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

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

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

This list will be passed to SSLEngine.setEnabledCipherSuites(java.lang.String[]).

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

This list will be passed to SSLEngine.setEnabledProtocols(java.lang.String[]).

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

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

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

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

TLS KeyStore, TrustStore, Password files and Certificate Paths.

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

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

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

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

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

toApiDigestType() - Method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

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

Creates a Iterable, which wraps a LedgersIterator.

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

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

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

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

Operations failed due to too many requests in the queue.

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

TopologyAwareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

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

TopologyAwareEnsemblePlacementPolicy.DefaultResolver - Class in org.apache.bookkeeper.client

TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator - Class in org.apache.bookkeeper.client

Decorator for any existing dsn resolver.

TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints - Class in org.apache.bookkeeper.client

TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble - Class in org.apache.bookkeeper.client

A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.

TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.CoverageSet - Interface in org.apache.bookkeeper.client

TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackOrRegionDurabilityCoverageSet - Class in org.apache.bookkeeper.client

TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet - Class in org.apache.bookkeeper.client

TopologyAwareEnsemblePlacementPolicy.TruePredicate - Class in org.apache.bookkeeper.client

toProtoDigestType(BookKeeper.DigestType) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

toSafeString() - Method in interface org.apache.bookkeeper.client.api.LedgerMetadata

Similar to #toString(), but omits the password of the ledger, so that it is safe to log the output.

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

Returns a string representation of this LedgerMetadata object by filtering out the password field.

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

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

toString() - Method in class org.apache.bookkeeper.client.BookieInfoReader.BookieInfo

toString() - Method in class org.apache.bookkeeper.client.LedgerDeleteOp

toString() - Method in class org.apache.bookkeeper.client.LedgerFragment

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

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

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

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

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

toString() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater

toString() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

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

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

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

transform(LedgerMetadata) - Method in interface org.apache.bookkeeper.client.MetadataUpdateLoop.MetadataTransform

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

Trigger AuditTask by resetting lostBookieRecoveryDelay to its current value.

TruePredicate() - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.TruePredicate

tryReadLastAddConfirmed() - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Obtains asynchronously the last confirmed write from a quorum of bookies but it doesn't wait all the responses from the quorum.

tryReadLastAddConfirmedAsync() - Method in interface org.apache.bookkeeper.client.api.ReadHandle

Obtains asynchronously the last confirmed write from a quorum of bookies but it doesn't wait all the responses from the quorum.

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

Obtains asynchronously the last confirmed write from a quorum of bookies but it doesn't wait all the responses from the quorum.

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

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

TryReadLastConfirmedOp - Class in org.apache.bookkeeper.client

This op is try to read last confirmed without involving quorum coverage checking.

TryReadLastConfirmedOp(LedgerHandle, BookieClient, List<BookieId>, ReadLastConfirmedOp.LastConfirmedDataCallback, long) - Constructor for class org.apache.bookkeeper.client.TryReadLastConfirmedOp

U

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

Operations failed due to unauthorized.

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

UncheckedConfigurationException - Exception in org.apache.bookkeeper.conf

Wraps a ConfigurationException with an unchecked exception.

UncheckedConfigurationException(String, ConfigurationException) - Constructor for exception org.apache.bookkeeper.conf.UncheckedConfigurationException

Constructs an instance of this class.

UncheckedConfigurationException(ConfigurationException) - Constructor for exception org.apache.bookkeeper.conf.UncheckedConfigurationException

Constructs an instance of this class.

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

Replication failed due to unclosed fragments.

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

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

Unexpected condition.

uninitalize() - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

uninitalize() - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Uninitialize the policy.

uninitalize() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

uninitalize() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

uninitalize() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicy

uninitalize() - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

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

A placer holder (unused).

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

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

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

unsetSuccessAndSendWriteRequest(List<BookieId>, Set<Integer>) - Method in class org.apache.bookkeeper.client.LedgerHandle

unsetSuccessAndSendWriteRequest(List<BookieId>, int) - Method in class org.apache.bookkeeper.client.PendingAddOp

updateBookieIdInLedgers(BookieId, BookieId, int, int, int, BookieShell.UpdateLedgerNotifier) - Method in class org.apache.bookkeeper.client.UpdateLedgerOp

Update the bookie id present in the ledger metadata.

updateBookieInfo(Map<BookieId, BookieInfoReader.BookieInfo>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

updateBookieInfo(Map<BookieId, BookieInfoReader.BookieInfo>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Send the bookie info details.

updateBookieInfo(Map<BookieId, BookieInfoReader.BookieInfo>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

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

UpdateLedgerOp - Class in org.apache.bookkeeper.client

Encapsulates updating the ledger metadata operation.

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

updateMap(Map<T, WeightedRandomSelection.WeightedObject>) - Method in class org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl

updateMap(Map<T, WeightedRandomSelection.WeightedObject>) - Method in interface org.apache.bookkeeper.client.WeightedRandomSelection

updateMap(Map<T, WeightedRandomSelection.WeightedObject>) - Method in class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

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

updatePiggyBackedLac(long) - Method in interface org.apache.bookkeeper.client.ExplicitLacFlushPolicy

updateValue(Versioned<LedgerMetadata>, Versioned<LedgerMetadata>) - Method in interface org.apache.bookkeeper.client.MetadataUpdateLoop.LocalValueUpdater

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

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

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

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

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

useHostName() - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator

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

V

validate() - Method in class org.apache.bookkeeper.client.impl.OpenBuilderBase

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

Validates if an ensemble is valid.

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

Validates if an ensemble is valid.

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

Validates if an ensemble is valid.

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

Validate the configuration.

value - Variable in class org.apache.bookkeeper.client.BookKeeperAdmin.SyncObject

valueOf(String) - Static method in enum org.apache.bookkeeper.client.api.DigestType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.api.LedgerMetadata.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.api.WriteFlag

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.BookieInfoReader.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.bookkeeper.client.LedgerFragment.ReplicateType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.bookkeeper.client.api.DigestType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.api.LedgerMetadata.State

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.api.WriteFlag

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.BookieInfoReader.State

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.EnsemblePlacementPolicy.PlacementPolicyAdherence

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.bookkeeper.client.LedgerFragment.ReplicateType

Returns an array containing the constants of this enum type, in the order they are declared.

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

VOID_EXPLICITLAC_FLUSH_POLICY - Static variable in interface org.apache.bookkeeper.client.ExplicitLacFlushPolicy

W

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

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

waitForResult(CompletableFuture<T>) - Static method in class org.apache.bookkeeper.client.SyncCallbackUtils

Wait for a result.

waitForWritable(DistributionSchedule.WriteSet, int, long) - Method in class org.apache.bookkeeper.client.LedgerHandle

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

watchReadOnlyBookiesChanged(RegistrationClient.RegistrationListener) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Notify when the available list of read only bookies changes.

watchWritableBookiesChanged(RegistrationClient.RegistrationListener) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Notify when the available list of bookies changes.

WeightedRandomSelection<T> - Interface in org.apache.bookkeeper.client

WeightedRandomSelection.WeightedObject - Interface in org.apache.bookkeeper.client

WeightedRandomSelectionImpl<T> - Class in org.apache.bookkeeper.client

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

WeightedRandomSelectionImpl(int) - Constructor for class org.apache.bookkeeper.client.WeightedRandomSelectionImpl

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

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

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

Set the number of acknowledgements to wait before considering a write to be completed with success.

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

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

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

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

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

withCustomMetadata(Map<String, byte[]>) - Method in interface org.apache.bookkeeper.client.api.CreateBuilder

Set a map a custom data to be attached to the ledger.

withCustomMetadata(Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl

withCustomMetadata(Map<String, byte[]>) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

withDefaultFaultDomain(String) - Method in class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl

withDefaultRack(String) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

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

Set the Digest type used to guard data against corruption.

withDigestType(DigestType) - Method in interface org.apache.bookkeeper.client.api.OpenBuilder

Sets the expected digest type used to check the contents of the ledger.

withDigestType(DigestType) - Method in class org.apache.bookkeeper.client.impl.OpenBuilderBase

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

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

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

Set the number of bookies which will receive data for this ledger.

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

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

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

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

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

withLedgerId(long) - Method in interface org.apache.bookkeeper.client.api.CreateAdvBuilder

Set a fixed ledgerId for the newly created ledger.

withLedgerId(long) - Method in interface org.apache.bookkeeper.client.api.DeleteBuilder

Set the id of the ledger to be deleted.

withLedgerId(long) - Method in interface org.apache.bookkeeper.client.api.OpenBuilder

Set the id of the ledger to be opened.

withLedgerId(long) - Method in class org.apache.bookkeeper.client.impl.OpenBuilderBase

withLedgerId(long) - Method in class org.apache.bookkeeper.client.LedgerDeleteOp.DeleteBuilderImpl

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

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

withPassword(byte[]) - Method in interface org.apache.bookkeeper.client.api.CreateBuilder

Set a password for the ledger.

withPassword(byte[]) - Method in interface org.apache.bookkeeper.client.api.OpenBuilder

Sets the password to be used to open the ledger.

withPassword(byte[]) - Method in class org.apache.bookkeeper.client.impl.OpenBuilderBase

withPassword(byte[]) - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl

withPassword(byte[]) - Method in class org.apache.bookkeeper.client.LedgerMetadataBuilder

withRecovery(boolean) - Method in interface org.apache.bookkeeper.client.api.OpenBuilder

Define to open the ledger in recovery mode or in readonly mode.

withRecovery(boolean) - Method in class org.apache.bookkeeper.client.impl.OpenBuilderBase

withWriteFlags(EnumSet<WriteFlag>) - Method in interface org.apache.bookkeeper.client.api.CreateBuilder

Set write flags.

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

Set write flags.

withWriteFlags(EnumSet<WriteFlag>) - Method in class org.apache.bookkeeper.client.LedgerCreateOp.CreateBuilderImpl

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

Set the number of bookies which receive every single entry.

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

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

write(long, ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry synchronously to an open ledger.

write(long, byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry synchronously to an open ledger.

write(long, byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry synchronously to an open ledger.

write(long, ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry asynchronously to an open ledger.

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

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

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

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

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

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

Provide write access to a ledger.

writeAsync(long, ByteBuffer) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry asynchronously to an open ledger.

writeAsync(long, byte[]) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry asynchronously to an open ledger.

writeAsync(long, byte[], int, int) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry asynchronously to an open ledger.

writeAsync(long, ByteBuf) - Method in interface org.apache.bookkeeper.client.api.WriteAdvHandle

Add entry asynchronously to an open ledger.

writeAsync(long, ByteBuf) - Method in class org.apache.bookkeeper.client.LedgerHandleAdv

writeComplete(int, long, long, BookieId, Object) - Method in class org.apache.bookkeeper.client.PendingAddOp

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

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

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

Write operations failed (bookie error).

WriteFlag - Enum in org.apache.bookkeeper.client.api

Flags to specify the behaviour of writes.

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

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

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

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

Provide write access to a ledger.

writeLacComplete(int, long, BookieId, Object) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

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

Write operations failed due to bookies are readonly.

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

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

writeSet - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

writeSet - Variable in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

writeSetFromValues(Integer...) - Static method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule

Z

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

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

Deprecated.

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

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

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

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

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

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

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

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

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

ZooKeeper operations failed.

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

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

ZoneawareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

A placement policy implementation use zone information for placing ensembles.

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

ZoneawareEnsemblePlacementPolicyImpl - Class in org.apache.bookkeeper.client

Simple zoneaware ensemble placement policy.

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

ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation - Class in org.apache.bookkeeper.client

Zone and UpgradeDomain pair of a node.

ZoneAwareNodeLocation(String, String) - Constructor for class org.apache.bookkeeper.client.ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation

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