Skip navigation links
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
 
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.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_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
 
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 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_TLS_KEYSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_KEYSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_KEYSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE_PASSWORD_PATH - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_TLS_TRUSTSTORE_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
CLIENT_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ClientClosedException - Static variable in interface org.apache.bookkeeper.client.api.BKException.Code
Executing operations on a closed client.
ClientConfiguration - Class in org.apache.bookkeeper.conf
Configuration settings for client side.
ClientConfiguration() - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a default client-side configuration.
ClientConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a client-side configuration using a base configuration.
ClientContext - Interface in org.apache.bookkeeper.client
Collection of client objects used by LedgerHandle to interact with the outside world.
clientCtx - Variable in class org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
 
clientCtx - Variable in class org.apache.bookkeeper.client.LedgerHandle
 
clientCtx - Variable in class org.apache.bookkeeper.client.LedgerRecoveryOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingAddOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingReadOp
 
clientCtx - Variable in class org.apache.bookkeeper.client.PendingWriteLacOp
 
ClientInternalConf - Class in org.apache.bookkeeper.client
 
clientStats - Variable in class org.apache.bookkeeper.client.LedgerCreateOp
 
close() - Method in interface org.apache.bookkeeper.client.api.BookKeeper
Close the client and release every resource.
close() - Method in interface org.apache.bookkeeper.client.api.Handle
Close this handle synchronously.
close() - Method in interface org.apache.bookkeeper.client.api.LastConfirmedAndEntry
close() - Method in interface org.apache.bookkeeper.client.api.LedgerEntries
Close to release the resources held by this instance.
close() - Method in interface org.apache.bookkeeper.client.api.LedgerEntry
close() - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Synchronous close the write handle, any adds in flight will return errors.
close() - Method in class org.apache.bookkeeper.client.BookKeeper
Shuts down client.
close() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Gracefully release resources that this client uses.
close() - Method in class org.apache.bookkeeper.client.impl.LastConfirmedAndEntryImpl
close() - Method in class org.apache.bookkeeper.client.impl.LedgerEntriesImpl
 
close() - Method in class org.apache.bookkeeper.client.impl.LedgerEntryImpl
close() - Method in class org.apache.bookkeeper.client.LedgerHandle
Synchronous close the write handle, any adds in flight will return errors.
close() - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest
 
close() - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest
 
close() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle
 
CLOSE_CHANNEL_ON_RESPONSE_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
closeAsync() - Method in interface org.apache.bookkeeper.client.api.Handle
Asynchronous close the handle.
closeAsync() - Method in interface org.apache.bookkeeper.client.api.WriteHandle
Asynchronous close the write handle, any adds in flight will return errors.
closeAsync() - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous close the write handle, any adds in flight will return errors.
closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback
Callback definition.
closeComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback
 
closeComplete(int, LedgerHandle, Object) - Method in class org.apache.bookkeeper.client.SyncCallbackUtils.SyncCloseCallback
Close callback method.
closed - Variable in class org.apache.bookkeeper.client.BookKeeper
 
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
 
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
 
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
 
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
 
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_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_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(SafeRunnable) - 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_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
 
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
 
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(String) - 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
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
 
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.
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.
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?
getHttpServerPort() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the http server port.
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.
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.
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
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
 
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
Get the number of threads that should handle journal callbacks.
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.
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
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
 
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.
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
 
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.
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 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
 
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_PORT - 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
 
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.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
 
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.
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.
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.
isLocalConsistencyCheckOnStartup() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
True if a local consistency check should be performed on startup.
isLocalScrubEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether local scrub is enabled.
isNettyUsePooledBuffers() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
isPersistBookieStatusEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether to persist the bookie status so that when bookie server restarts, it will continue using the previous status.
isReadOnlyModeEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether read-only mode is enabled.
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.
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.
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_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_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_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
 
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
 
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_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
 
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
 
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
 
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.RackawareEnsemblePlacementPolicyImpl
 
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
 
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.MetadataUpdateLoop
 
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

safeRun() - Method in class org.apache.bookkeeper.client.ForceLedgerOp
 
safeRun() - Method in class org.apache.bookkeeper.client.PendingAddOp
Initiate the add operation.
safeRun() - Method in class org.apache.bookkeeper.client.PendingReadOp
 
safeRun() - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle.MetadataUpdater
 
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
 
sendWriteRequest(List<BookieId>, int) - Method in class org.apache.bookkeeper.client.PendingAddOp
 
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_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
 
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.
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.
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
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.
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.
setHttpServerPort(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set Http server port listening on.
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.
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.
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
setLedgerMetadata(Versioned<LedgerMetadata>, Versioned<LedgerMetadata>) - Method in class org.apache.bookkeeper.client.LedgerHandle
 
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
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
Set the number of threads that would handle journal callbacks.
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.
setReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
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.
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.
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
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.
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.
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.
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_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.
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.
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 
Skip navigation links

Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.