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

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

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

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

Add delta to the value associated with this stat.

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

add(long) - Method in class org.apache.bookkeeper.stats.PrometheusCounter

add(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

add(long) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

add(long) - Method in class org.apache.bookkeeper.stats.twitter.science.CounterImpl

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

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

Add a bookie to the result set

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

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

addBookie(TopologyAwareEnsemblePlacementPolicy.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 declaration

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

Implementation of callback interface for synchronous read method.

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

addEnsemble(long, ArrayList<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Add entry operation timeouts on waiting quorum responses.

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

Implementation of callback interface for synchronous read method.

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(TopologyAwareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints

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

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

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

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

Add to the length of the ledger in bytes.

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

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

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

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

AlertStatsLogger - Class in org.apache.bookkeeper.stats

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

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

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

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

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_STORAGE_EXPANSION - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

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

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

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

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

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

areByteArrayValMapsEqual(Map<String, byte[]>, Map<String, byte[]>) - Static method in class org.apache.bookkeeper.client.LedgerMetadata

Routine to compare two Map; Since the values in the map are byte[], we can't use Map.equals

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

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

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(BookieSocketAddress, BookieSocketAddress, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

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

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

Make a recovery add entry request.

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

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

AUDITOR_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

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

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

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

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

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

Class the enumerates all the possible error conditions

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Codes which represent the various BKException types.

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

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

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

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

BKNotEnoughBookiesException() - 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

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

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

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_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_TIME_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

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

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

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

BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.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

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

BookieNode(BookieSocketAddress, String) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.BookieNode

BookiesListener - Interface in org.apache.bookkeeper.client

Listener for the the available bookies changes.

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

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

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

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

BookKeeper Client Builder to build client instances.

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

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

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

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

Constructor that takes in a BookKeeper instance .

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

BookKeeperClientStats - Interface in org.apache.bookkeeper.client

List of constants for defining client stats names.

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

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

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

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

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

C

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

Cacheable Feature Provider

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

CachingStatsLogger - Class in org.apache.bookkeeper.stats

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

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

CachingStatsProvider - Class in org.apache.bookkeeper.stats

A CachingStatsProvider adds the caching functionality to an existing StatsProvider.

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

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

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

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

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

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

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

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

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

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

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

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

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

Clear this stat.

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

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

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

Clear stats for this operation.

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

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

clear() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

clear() - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

clear() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

clear() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

clear() - Method in class org.apache.bookkeeper.stats.twitter.science.CounterImpl

clear() - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

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

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

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

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

Close this ledger synchronously.

close(long) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

Close callback method

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

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

CodahaleMetricsProvider - Class in org.apache.bookkeeper.stats

A StatsProvider implemented based on Codahale metrics library.

CodahaleMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.CodahaleMetricsProvider

CodahaleOpStatsLogger - Class in org.apache.bookkeeper.stats

CodahaleOpStatsLogger(Timer, Timer) - Constructor for class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

CodahaleStatsLogger - Class in org.apache.bookkeeper.stats

A StatsLogger implemented based on Codahale metrics library.

CodahaleStatsLogger(MetricRegistry, String) - Constructor for class org.apache.bookkeeper.stats.CodahaleStatsLogger

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, BookieSocketAddress, ByteBuf) - Method in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

Complete the read request from host.

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

complete(int, BookieSocketAddress, ByteBuf, long) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest

Complete the read request from host.

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

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

computeDigestAndPackageForSending(long, long, long, ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

Computes the digest for an entry and put bytes together for sending.

computeDigestAndPackageForSendingLac(long) - Method in class org.apache.bookkeeper.client.DigestManager

Computes the digest for writeLac for sending.

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.

convertBookiesToNodes(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

Counter - Interface in org.apache.bookkeeper.stats

Simple stats that require only increment and decrement functions on a Long.

CounterImpl - Class in org.apache.bookkeeper.stats.twitter.finagle

Note: this counter doesn't support resetting values or getting the current value.

CounterImpl(String, StatsReceiver) - Constructor for class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

CounterImpl - Class in org.apache.bookkeeper.stats.twitter.ostrich

CounterImpl(Counter) - Constructor for class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

CounterImpl - Class in org.apache.bookkeeper.stats.twitter.science

This will export the value and the rate (per sec) to Stats.

CounterImpl(String) - Constructor for class org.apache.bookkeeper.stats.twitter.science.CounterImpl

counters - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

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

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

CRC32DigestManager - Class in org.apache.bookkeeper.client

CRC32DigestManager(long) - Constructor for class org.apache.bookkeeper.client.CRC32DigestManager

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

Create an exception from an error code

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

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

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

Declaration of callback method

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

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

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

cummulativeMap - Variable in class org.apache.bookkeeper.client.WeightedRandomSelection

CURRENT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

currentEnsemble - Variable in class org.apache.bookkeeper.client.LedgerMetadata

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

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

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

Decrement the value associated with this stat.

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

dec() - Method in class org.apache.bookkeeper.stats.PrometheusCounter

dec() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

dec() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

dec() - Method in class org.apache.bookkeeper.stats.twitter.science.CounterImpl

decommissionBookie(BookieSocketAddress) - 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_NETTY_MAX_FRAME_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

DefaultEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

Default Ensemble Placement Policy, which picks bookies randomly.

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

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

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

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

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

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

deleteComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.DeleteCallback

Callback definition for delete operations

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

DIGEST_ALGORITHM - Static variable in class org.apache.bookkeeper.client.MacDigestManager

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

DigestManager - Class in org.apache.bookkeeper.client

This class takes an entry, attaches a digest to it and packages it with relevant data so that it can be shipped to the bookie.

DigestManager(long) - Constructor for class org.apache.bookkeeper.client.DigestManager

DigestManager.RecoveryData - Class in org.apache.bookkeeper.client

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

Digest doesn't match on returned entries

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

Digest Manager is not initialized (client error)

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

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.

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

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

doAsyncAddEntry(PendingAddOp, ByteBuf, AsyncCallback.AddCallback, Object) - 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

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

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

Duplicated entry id is found when LedgerHandleAdv.addEntry(long, byte[]).

E

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

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

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

Enable the recovery add flag for this operation.

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

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

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

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

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

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

EnsembleInfo(ArrayList<BookieSocketAddress>, Map<Integer, BookieSocketAddress>, Set<Integer>) - Constructor for class org.apache.bookkeeper.client.LedgerHandle.EnsembleInfo

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.

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

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

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

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

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

equals(Object) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.BookieNode

equals(Object) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

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

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

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

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

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

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

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

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

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.

fail - Variable in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

failBookieAndCheck(int, BookieSocketAddress) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet

Received failure response from a bookie and check if ack quorum will be broken.

Feature - Interface in org.apache.bookkeeper.feature

This interface represents a feature.

FEATURE_AVAILABILITY_MAX_VALUE - Static variable in interface org.apache.bookkeeper.feature.Feature

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

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

Feature Provider

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

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

finagleGauges - Variable in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

FinagleStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.finagle

A Finagle Stats library based StatsLogger implementation.

FinagleStatsLoggerImpl(StatsReceiver) - Constructor for class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

FinagleStatsProvider - Class in org.apache.bookkeeper.stats.twitter.finagle

Main entry point to use Finagle stats for Bookkeeper.

FinagleStatsProvider(StatsReceiver) - Constructor for class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsProvider

finish(int, T, CompletableFuture<T>) - Static method in class org.apache.bookkeeper.client.SynchCallbackUtils

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

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

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

forConfig(ClientConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeper

format(ClientConfiguration, boolean, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin

Format the BookKeeper metadata in zookeeper

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

G

Gauge<T extends Number> - Interface in org.apache.bookkeeper.stats

A guage is a value that has only one value at a specific point in time.

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

genDigest(String, byte[]) - Static method in class org.apache.bookkeeper.client.MacDigestManager

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

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

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

Get the value associated with this stat.

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

get() - Method in class org.apache.bookkeeper.stats.PrometheusCounter

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

get() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

get() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

get() - Method in class org.apache.bookkeeper.stats.twitter.science.CounterImpl

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

getAckQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

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

Gets the failedBookie address

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

Get the configured advertised address for the bookie.

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.

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.

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

Get a list of the available bookies.

getAvgLatencyMillis() - Method in class org.apache.bookkeeper.stats.OpStatsData

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.

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

Get the error threshold for a bookie to be quarantined.

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.

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

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

Get bookie port that bookie server listen on

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

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

Gets the failedBookie index

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

Get the client authentication provider factory class name.

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

Get client netty connect timeout in millis.

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

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.

getCode() - Method in exception org.apache.bookkeeper.client.BKException

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

Get the maximum number of entries which can be compacted without flushing.

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

Deprecated.

replaced by ServerConfiguration.getCompactionRateByEntries()

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

Get the rate of compaction adds.

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

Get the rate of compaction adds.

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

getConf() - Method in interface org.apache.bookkeeper.conf.Configurable

Return the configuration used by this object.

getCounter(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

getCounter(String) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

getCounter(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

getCounter(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

getCounter(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger

getCounter(String) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

getCounter(String) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

getCounter(String) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

getCoverageSet() - Method in class org.apache.bookkeeper.client.RoundRobinDistributionSchedule

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

getCtime() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Get the creation timestamp of the ledger

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

Get this ledger's customMetadata map.

getCustomMetadata() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Get bookie death watch interval

getDefaultEventLoopGroup() - Static method in class org.apache.bookkeeper.client.BookKeeper

getDefaultValue() - Method in interface org.apache.bookkeeper.stats.Gauge

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

Whether to delay ensemble change or not?

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

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

Get the DigestManager

getDigestType() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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.

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

Gets the ensemble of fragment

getEnsemble(long) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Get Ensemble Placement Policy Class.

getEnsembles() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Get the Map of bookie ensembles for the various ledger fragments that make up the ledger.

getEnsembleSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Returns the content of the entry.

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

Return the internal buffer that contains the entry payload.

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.

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

Get entry logger size limitation

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

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

Get the configured interval between explicit LACs to bookies.

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.

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

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.

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

getFreeDiskSpace(BookieSocketAddress) - 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.

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

Get the id of the current ledger

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.

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.

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

How much space should we pre-allocate at a time in the journal

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

Should we remove pages from page cache after force write

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

Size of the write buffers used for the journal

getLacComplete(int, long) - Method in interface org.apache.bookkeeper.client.PendingReadLacOp.LacCallback

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

Get the last confirmed entry id on this 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 persited to the ledger)

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

getLastEntryId() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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.

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

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

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

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

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

Get ledger manager factory class.

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

Deprecated.

replaced by AbstractConfiguration.getLedgerManagerFactoryClass()

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

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

Get the LedgerMetadata

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

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

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

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

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

Get the network interface that the bookie should listen for connections on.

getLocalRegion(TopologyAwareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

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.

getMacCodeLength() - Method in class org.apache.bookkeeper.client.CRC32DigestManager

getMacCodeLength() - Method in class org.apache.bookkeeper.client.DigestManager

getMacCodeLength() - Method in class org.apache.bookkeeper.client.MacDigestManager

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

Get interval to run major compaction, in seconds.

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

Get threshold of major compaction.

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

Max number of older journal files kept

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

Max journal file size

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

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

Get metastore implementation class.

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

Get max entries per scan in metastore.

getMetrics() - Method in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

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

Get interval to run minor compaction, in seconds.

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

Get threshold of minor compaction.

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.

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

Get the network topology stabilize period in seconds.

getNextEnsembleChange(long) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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.

getNumFailedEvents() - Method in class org.apache.bookkeeper.stats.OpStatsData

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

Get the number of fragments that makeup this ledger

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.

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

Get the number of threads that should handle read requests.

getNumSuccessfulEvents() - Method in class org.apache.bookkeeper.stats.OpStatsData

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

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

getOpStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

getOpStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

getP10Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

getP50Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

getP90Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

getP9999Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

getP999Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

getP99Latency() - Method in class org.apache.bookkeeper.stats.OpStatsData

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

Get limitation number of index pages in ledger cache

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

Get page size

getPassword() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Get number of ticks that used for org.jboss.netty.util.HashedWheelTimer that used by PCBC to timeout requests.

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

Get the tick duration in milliseconds that used for the org.jboss.netty.util.HashedWheelTimer that used by PCBC to timeout requests.

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 Default is 512 bytes

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

Get the timeout for read entry.

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

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

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

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

getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookieWatcher

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

Get a list of readonly bookies

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

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

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

Deprecated.

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

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

Performs scan described by instanceState using the cached bookie information in bookieInfoMap.

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

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

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

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

getRemoteRack(TopologyAwareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

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

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

getSample() - Method in interface org.apache.bookkeeper.stats.Gauge

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

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.

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 Default is 4 MB

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)

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

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

Return the timeout value for startTLS request

getState() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CachingStatsProvider

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.NullStatsProvider

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider

getStatsLogger(String) - Method in interface org.apache.bookkeeper.stats.StatsProvider

Return the stats logger to a given scope.

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsProvider

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

getStatsLogger(String) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

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

Get the stats provider used by bookie.

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

Get task execution duration which triggers a warning.

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

Get throttle value

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.

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

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

Get whether bookie is using hostname for registration and in ledger metadata.

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

Use older Bookkeeper wire protocol (no protobuf)

getVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Returns the last version.

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.

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

getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

Get the node under which available bookies are stored

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

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

Get Zk Ledgers Root Path.

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.

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

Get zookeeper servers to connect

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

Get zookeeper servers to connect

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

Get zookeeper timeout

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

Get zookeeper timeout

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

Get ZooKeeper used by bookkeeper admin client.

H

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

handleBookieFailure(Map<Integer, BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.LedgerHandle

handleBookieFailure(Map<Integer, BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

handleBookiesThatJoined(Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Handle bookies that joined

handleBookiesThatJoined(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

handleBookiesThatJoined(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

handleBookiesThatJoined(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

handleBookiesThatLeft(Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Handle bookies that left.

handleBookiesThatLeft(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

handleBookiesThatLeft(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

handleBookiesThatLeft(Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

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

hasEntry(long, int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule

Whether entry presents on given bookie index

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

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

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

hashCode() - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

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

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

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

hasPassword() - Method in class org.apache.bookkeeper.client.LedgerMetadata

In versions 4.1.0 and below, the digest type and password were not stored in the metadata.

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

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

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

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

HTTPStatsExporter - Class in org.apache.bookkeeper.stats.twitter.science

Starts a jetty server on a configurable port and the samplers to export stats.

HTTPStatsExporter(int) - Constructor for class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

I

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

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

Operation is illegal.

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

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

Increment the value associated with this stat.

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

inc() - Method in class org.apache.bookkeeper.stats.PrometheusCounter

inc() - Method in class org.apache.bookkeeper.stats.twitter.finagle.CounterImpl

inc() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.CounterImpl

inc() - Method in class org.apache.bookkeeper.stats.twitter.science.CounterImpl

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

Incorrect parameters (operations are absolutely not executed)

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

initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Initialize the policy.

initialize(DNSToSwitchMapping, HashedWheelTimer, boolean, int, boolean, int, StatsLogger) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

initialize(DNSToSwitchMapping, HashedWheelTimer, boolean, int, boolean, int, StatsLogger) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

Initialize the policy.

initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

initialize(ClientConfiguration, Optional<DNSToSwitchMapping>, HashedWheelTimer, FeatureProvider, StatsLogger) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

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

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

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(ByteBuf, int) - Method in class org.apache.bookkeeper.client.PendingAddOp

initiate() - Method in class org.apache.bookkeeper.client.PendingReadLacOp

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

initiate(ByteBuf) - 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

initIfNecessary() - Method in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

INSTANCE - Static variable in class org.apache.bookkeeper.client.LedgerHandle.LastAddConfirmedCallback

instance - Static variable in class org.apache.bookkeeper.client.LedgerHandle.NoopCloseCallback

instance - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints

instance - Static variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.TruePredicate

INSTANCE - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger

instantiate(long, byte[], BookKeeper.DigestType) - Static method in class org.apache.bookkeeper.client.DigestManager

InterfaceAudience - Class in org.apache.bookkeeper.common.annotation

Annotation to inform users of a package, class or method's intended audience.

InterfaceAudience.LimitedPrivate - Annotation Type in org.apache.bookkeeper.common.annotation

Intended for use only within the project(s) specified in the annotation.

InterfaceAudience.Private - Annotation Type in org.apache.bookkeeper.common.annotation

Intended for use only within bookkeeper itself.

InterfaceAudience.Public - Annotation Type in org.apache.bookkeeper.common.annotation

Intended for use by any project or application.

InterfaceStability - Class in org.apache.bookkeeper.common.annotation

Annotation to inform users of how much to rely on a particular package, class or method not changing over time.

InterfaceStability.Evolving - Annotation Type in org.apache.bookkeeper.common.annotation

Evolving, but can break compatibility at minor release (i.e.

InterfaceStability.Stable - Annotation Type in org.apache.bookkeeper.common.annotation

Can evolve while retaining compatibility for minor release boundaries.; can break compatibility only at major release (ie.

InterfaceStability.Unstable - Annotation Type in org.apache.bookkeeper.common.annotation

No guarantee is provided as to reliability or stability across any level of release granularity.

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

Synchronous operations are interrupted

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

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

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.

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

Has the ledger been closed?

isClosed() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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.

isConflictWith(LedgerMetadata) - Method in class org.apache.bookkeeper.client.LedgerMetadata

Is the metadata conflict with new updated metadata.

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.

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

Is entry log file preallocation enabled.

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

Get whether the Bookie is force started in read only mode or not

isInRecovery() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Option to use Netty Pooled ByteBufs

isNewerThan(LedgerMetadata) - Method in class org.apache.bookkeeper.client.LedgerMetadata

Is the metadata newer than given newMeta.

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

Get whether read-only mode is enabled.

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

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

If reorder read sequence enabled or not.

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

Is statistics enabled

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

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

Are z-node created with strict ACLs

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

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

jettyServer - Variable in class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

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

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

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

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

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

JOURNAL_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_PRE_ALLOC_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_WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

K

KEY_ALGORITHM - Static variable in class org.apache.bookkeeper.client.MacDigestManager

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

L

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

LAC_METADATA_LENGTH - Static variable in class org.apache.bookkeeper.client.DigestManager

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

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

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

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

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

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

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

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

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

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

LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.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[]>) - Constructor for class org.apache.bookkeeper.client.LedgerCreateOp

Constructor

LedgerDeleteOp - Class in org.apache.bookkeeper.client

Encapsulates asynchronous ledger delete operation

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

Constructor

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

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

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

LedgerEntry - Class in org.apache.bookkeeper.client

Ledger entry.

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

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

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

Ledger already exists

LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.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 a single bookie in the segments bookie ensemble.

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

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

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

Callback for recovery of a single ledger fragment.

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(BookKeeper, long, LedgerMetadata, BookKeeper.DigestType, byte[]) - Constructor for class org.apache.bookkeeper.client.LedgerHandle

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

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

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

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

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

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

LedgerHandle.SyncReadLastConfirmedCallback - 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(BookKeeper, long, LedgerMetadata, BookKeeper.DigestType, byte[]) - 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.BookKeeperAdmin.ReadMetadataCallback

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

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

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

LedgerIdOverflowException - Static variable in interface org.apache.bookkeeper.client.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

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

LedgerMetadata - Class in org.apache.bookkeeper.client

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

LedgerMetadata(int, int, int, BookKeeper.DigestType, byte[], Map<String, byte[]>) - Constructor for class org.apache.bookkeeper.client.LedgerMetadata

LedgerMetadata(int, int, int, BookKeeper.DigestType, byte[]) - Constructor for class org.apache.bookkeeper.client.LedgerMetadata

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

Copy Constructor.

LedgerOpenOp - Class in org.apache.bookkeeper.client

Encapsulates the ledger open operation

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

Constructor.

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

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

Ledger recovery operations failed

LedgerRecoveryOp - Class in org.apache.bookkeeper.client

This class encapsulated the ledger recovery operation.

LedgerRecoveryOp(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Void>) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp

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

length - Variable in class org.apache.bookkeeper.client.DigestManager.RecoveryData

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

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

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

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

ListenerBasedPendingReadOp - Class in org.apache.bookkeeper.client

ListenerBasedPendingReadOp(LedgerHandle, ScheduledExecutorService, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object) - 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.

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

You can load configurations in precedence order.

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

You can load configuration from other configuration

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

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

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

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

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

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

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

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

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

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

LOG - Static variable in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

LOG - Static variable in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

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

Log error errMsg and reattempt read from host.

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

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

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

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

Log error errMsg and reattempt read from host.

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

logger - Static variable in class org.apache.bookkeeper.client.BookieWatcher

logger - Static variable in class org.apache.bookkeeper.client.DigestManager

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

LOWEST_COMPAT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

M

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

MAC_CODE_LENGTH - Static variable in class org.apache.bookkeeper.client.MacDigestManager

macCodeLength - Variable in class org.apache.bookkeeper.client.DigestManager

MacDigestManager - Class in org.apache.bookkeeper.client

A SHA-1 based digest manager.

MacDigestManager(long, byte[]) - Constructor for class org.apache.bookkeeper.client.MacDigestManager

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_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

markLedgerInRecovery() - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

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

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

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

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

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

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.

mergeEnsembles(SortedMap<Long, ArrayList<BookieSocketAddress>>) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

METADATA_LENGTH - Static variable in class org.apache.bookkeeper.client.DigestManager

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

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

MetadataVersionException - Static variable in interface org.apache.bookkeeper.client.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.BKException.Code

Meta store operations failed

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

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

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

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

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

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

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

name - Variable in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

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

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

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

Create an ensemble with given ensembleSize and writeQuorumSize.

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

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

Choose numBookies bookies for ensemble.

newEnsemble(int, int, int, Set<BookieSocketAddress>, 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<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

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

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

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

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

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

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

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

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

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

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

Unused

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

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

No such entry exists

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

No such ledger exists

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

Not enough bookies available to form an ensemble

notifyBookiesChanged(BookiesListener) - Method in class org.apache.bookkeeper.client.BookieWatcher

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

Notify when the available list of bookies changes.

notifyReadOnlyBookiesChanged(BookiesListener) - Method in class org.apache.bookkeeper.client.BookieWatcher

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

Notify when the available list of read only bookies changes.

nullCounter - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger

NullCounter() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullCounter

nullOpStats - Variable in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

nullOpStatsLogger - Static variable in class org.apache.bookkeeper.stats.NullStatsLogger

NullOpStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

NullStatsLogger - Class in org.apache.bookkeeper.stats

A no-op StatsLogger.

NullStatsLogger() - Constructor for class org.apache.bookkeeper.stats.NullStatsLogger

nullStatsLogger - Variable in class org.apache.bookkeeper.stats.NullStatsProvider

NullStatsLogger.NullCounter - Class in org.apache.bookkeeper.stats

A no-op Counter.

NullStatsLogger.NullOpStatsLogger - Class in org.apache.bookkeeper.stats

A no-op OpStatsLogger.

NullStatsProvider - Class in org.apache.bookkeeper.stats

A no-op stats provider implementation.

NullStatsProvider() - Constructor for class org.apache.bookkeeper.stats.NullStatsProvider

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

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

NUM_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

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

numMissedEntryReads - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

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

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

O

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

Everything is OK

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

onChanged(long, LedgerMetadata) - Method in class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - 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<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

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

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

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

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

Callback for asynchronous call to open ledger

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

Callback method for synchronous open operation

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

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

operationComplete(int, LedgerMetadata) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin.ReadMetadataCallback

operationComplete(int, Void) - Method in class org.apache.bookkeeper.client.LedgerCreateOp

Callback when created ledger.

operationComplete(int, LedgerMetadata) - Method in class org.apache.bookkeeper.client.LedgerOpenOp

Implements Open Ledger Callback.

OpStatsData - Class in org.apache.bookkeeper.stats

This class provides a read view of operation specific stats.

OpStatsData(long, long, double, long[]) - Constructor for class org.apache.bookkeeper.stats.OpStatsData

OpStatsLogger - Interface in org.apache.bookkeeper.stats

This interface handles logging of statistics related to each operation.

OpStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.finagle

A percentile stat that will delegate to Finagle stats' implementation library to compute the percentiles.

OpStatsLoggerImpl(String, StatsReceiver) - Constructor for class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

OpStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.ostrich

OpStatsLoggerImpl(String, StatsProvider) - Constructor for class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

OpStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.science

An implementation of the OpStatsLogger interface that handles per operation type stats.

OpStatsLoggerImpl(String) - Constructor for class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

opStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

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

org.apache.bookkeeper.client - package org.apache.bookkeeper.client

BookKeeper Client.

org.apache.bookkeeper.common.annotation - package org.apache.bookkeeper.common.annotation

Annotations used across the whole project.

org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf

org.apache.bookkeeper.feature - package org.apache.bookkeeper.feature

org.apache.bookkeeper.stats - package org.apache.bookkeeper.stats

A lightweight stats library used for exporting bookkeeper stats.

org.apache.bookkeeper.stats.twitter.finagle - package org.apache.bookkeeper.stats.twitter.finagle

A stats provider implemented based on finagle stats library.

org.apache.bookkeeper.stats.twitter.ostrich - package org.apache.bookkeeper.stats.twitter.ostrich

A stats provider implemented based on Twitter Ostrich library.

org.apache.bookkeeper.stats.twitter.science - package org.apache.bookkeeper.stats.twitter.science

A stats provider implementation based on Twitter Science Stats library.

OstrichProvider - Class in org.apache.bookkeeper.stats.twitter.ostrich

A Twitter Ostrich library based StatsProvider implementation.

OstrichProvider() - Constructor for class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

OstrichProvider(String) - Constructor for class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

ostrichProvider - Variable in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

OstrichStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.ostrich

Implementation of ostrich logger.

OstrichStatsLoggerImpl(String, StatsProvider) - Constructor for class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

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

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

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

parallelRead(boolean) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp

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(ArrayList<BookieSocketAddress>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.ParallelReadRequest

ParallelReadRequest(ArrayList<BookieSocketAddress>, 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

parseConfig(byte[], Version, Optional<Long>) - Static method in class org.apache.bookkeeper.client.LedgerMetadata

Parses a given byte array and transforms into a LedgerConfig object

parseVersion1Config(LedgerMetadata, BufferedReader) - Static method in class org.apache.bookkeeper.client.LedgerMetadata

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

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

passwd - Variable in class org.apache.bookkeeper.client.MacDigestManager

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

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.

PendingAddOp(LedgerHandle, AsyncCallback.AddCallback, Object) - Constructor for class org.apache.bookkeeper.client.PendingAddOp

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

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, 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, ScheduledExecutorService, long, long, AsyncCallback.ReadCallback, Object) - 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, AsyncCallback.AddLacCallback, Object) - Constructor for class org.apache.bookkeeper.client.PendingWriteLacOp

PERCENTILES - Static variable in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

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

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

placementPolicy - Variable in class org.apache.bookkeeper.client.BookieWatcher

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

populateValueAndReset(ByteBuf) - Method in class org.apache.bookkeeper.client.CRC32DigestManager

populateValueAndReset(ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

populateValueAndReset(ByteBuf) - Method in class org.apache.bookkeeper.client.MacDigestManager

port - Variable in class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

process(WatchedEvent) - Method in class org.apache.bookkeeper.client.BookieWatcher

processResult(int, String, Object, List<String>) - Method in class org.apache.bookkeeper.client.BookieWatcher

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

PrometheusCounter - Class in org.apache.bookkeeper.stats

A Counter implementation based on Prometheus metrics library.

PrometheusCounter(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusCounter

PrometheusMetricsProvider - Class in org.apache.bookkeeper.stats

A Prometheus based StatsProvider implementation.

PrometheusMetricsProvider() - Constructor for class org.apache.bookkeeper.stats.PrometheusMetricsProvider

PrometheusOpStatsLogger - Class in org.apache.bookkeeper.stats

A Prometheus based OpStatsLogger implementation.

PrometheusOpStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

PrometheusStatsLogger - Class in org.apache.bookkeeper.stats

A Prometheus based StatsLogger implementation.

PrometheusStatsLogger(CollectorRegistry, String) - Constructor for class org.apache.bookkeeper.stats.PrometheusStatsLogger

PrometheusUtil - Class in org.apache.bookkeeper.stats

Container for Prometheus utility methods.

PrometheusUtil() - Constructor for class org.apache.bookkeeper.stats.PrometheusUtil

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

Protocol version is wrong (operations are absolutely not executed)

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

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

Q

quarantineBookie(BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookieWatcher

Quarantine bookie so it will not be preferred to be chosen for new ensembles.

quarantinedBookies - Variable in class org.apache.bookkeeper.client.BookieWatcher

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

Unused

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

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

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

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

racksOrRegionsInQuorum - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

raise(String, Object...) - Method in class org.apache.bookkeeper.stats.AlertStatsLogger

Report an alertable condition".

randomMax - Variable in class org.apache.bookkeeper.client.WeightedRandomSelection

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

rc - Variable in class org.apache.bookkeeper.client.LedgerHandle.LastConfirmedCtx

rc - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

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

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

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

Execute the read request.

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

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

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

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

Execute the read request.

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

READ_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_MODE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

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

readBatchSize(int) - Method in class org.apache.bookkeeper.client.LedgerRecoveryOp

readBookies() - Method in class org.apache.bookkeeper.client.BookieWatcher

readBookies(AsyncCallback.ChildrenCallback) - Method in class org.apache.bookkeeper.client.BookieWatcher

readBookiesBlocking() - Method in class org.apache.bookkeeper.client.BookieWatcher

Blocks until bookies are read from zookeeper, used in the BookKeeper constructor.

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

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

Read operations failed (bookie error)

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

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

ReadLACAndEntryRequest(ArrayList<BookieSocketAddress>, 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.BookKeeper

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

ReadLastConfirmedAndEntryOp - Class in org.apache.bookkeeper.client

Long poll read operation.

ReadLastConfirmedAndEntryOp(LedgerHandle, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback, long, long, ScheduledExecutorService) - 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.LedgerHandle.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(LedgerHandle, 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

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

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

ReadOnlyLedgerHandle - Class in org.apache.bookkeeper.client

Read only ledger handle.

ReadOnlyLedgerHandle(BookKeeper, long, LedgerMetadata, BookKeeper.DigestType, byte[], boolean) - Constructor for class org.apache.bookkeeper.client.ReadOnlyLedgerHandle

ReadOnlyLedgerHandle.MetadataUpdater - Class in org.apache.bookkeeper.client

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

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

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

Read a sequence of entries synchronously, allowing to read after the LastAddConfirmed range.
This is the same of LedgerHandle.asyncReadUnconfirmedEntries(long, long, org.apache.bookkeeper.client.AsyncCallback.ReadCallback, java.lang.Object)

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

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

recover(BookkeeperInternalCallbacks.GenericCallback<Void>) - Method in class org.apache.bookkeeper.client.LedgerHandle

recover(BookkeeperInternalCallbacks.GenericCallback<Void>, BookkeeperInternalCallbacks.ReadEntryListener, boolean) - Method in class org.apache.bookkeeper.client.LedgerHandle

Recover the ledger.

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

recoverBookieData(BookieSocketAddress, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

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

recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback

Callback definition for bookie recover operations

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

RecoveryData(long, long) - Constructor for class org.apache.bookkeeper.client.DigestManager.RecoveryData

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

RecoveryReadOp(LedgerHandle, ScheduledExecutorService, long, long, BookkeeperInternalCallbacks.ReadEntryListener, Object) - Constructor for class org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp

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

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

Increment the failed op counter with the given eventLatency.

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

registerFailedEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

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

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

An operation with the given value failed.

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

registerFailedValue(long) - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

registerGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Register given gauge as name name.

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

registerGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.NullStatsLogger.NullOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in interface org.apache.bookkeeper.stats.OpStatsLogger

An operation succeeded with the given eventLatency.

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

registerSuccessfulEvent(long, TimeUnit) - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

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

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

An operation with the given value succeeded.

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

registerSuccessfulValue(long) - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

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

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

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

removeBookieAndCheck(int) - Method in interface org.apache.bookkeeper.client.DistributionSchedule.AckSet

Invalidate a previous bookie response.

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

removeScope(String, StatsLogger) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Remove the given statsLogger for scope name.

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

removeScope(String, StatsLogger) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

reorderReadLACSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

reorderReadLACSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Reorder the read last add confirmed sequence of a given write quorum writeSet.

reorderReadLACSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

reorderReadLACSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

reorderReadLACSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

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

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Reorder the read sequence of a given write quorum writeSet.

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

reorderReadSequence(ArrayList<BookieSocketAddress>, List<Integer>, Map<BookieSocketAddress, Long>) - Method in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

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

replaceBookie(int, int, int, Map<String, byte[]>, List<BookieSocketAddress>, int, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.BookieWatcher

Choose a bookie to replace bookie bookieIdx in existingBookies.

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

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

Choose a new bookie to replace bookieToReplace.

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

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

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

replaceBookieInMetadata(Map<Integer, BookieSocketAddress>, int) - Method in class org.apache.bookkeeper.client.LedgerHandle

replacedBookies - Variable in class org.apache.bookkeeper.client.LedgerHandle.EnsembleInfo

replaceFromRack(TopologyAwareEnsemblePlacementPolicy.BookieNode, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode>, boolean) - Method in class org.apache.bookkeeper.client.RegionAwareEnsemblePlacementPolicy

replicate(LedgerHandle, LedgerFragment, AsyncCallback.VoidCallback, BookieSocketAddress) - 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, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin

Replicate the Ledger fragment to target Bookie passed.

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

generic exception code used to propagate in replication pipeline

reporters - Variable in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

rereadMetadata(BookkeeperInternalCallbacks.GenericCallback<LedgerMetadata>) - Method in class org.apache.bookkeeper.client.LedgerHandle

reReadTask - Variable in class org.apache.bookkeeper.client.BookieWatcher

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

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

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

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

RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode>) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

RRTopologyAwareCoverageEnsemble(int, int, int, int, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode>, Set<String>, int) - Constructor for class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble

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

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

rwLock - Variable in class org.apache.bookkeeper.client.WeightedRandomSelection

S

safeOperationComplete(int, Void) - Method in class org.apache.bookkeeper.client.LedgerDeleteOp

Implements Delete Callback.

safeRegister(CollectorRegistry, T) - Static method in class org.apache.bookkeeper.stats.PrometheusUtil

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

scheduleBookieHealthCheckIfEnabled() - 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.BookieWatcher

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.

scope(String) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

scope(String) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

scope(String) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Provide the stats logger under scope name.

scope(String) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

scope - Variable in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

scope(String) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

scope(String) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

scopeStatsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

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

seenBookies - Variable in class org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.RackQuorumCoverageSet

selectFromNetworkLocation(String, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T>) - Method in interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

Select a node from a given network location.

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

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

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

Choose a random node from whole cluster.

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

selectRandomInternal(List<TopologyAwareEnsemblePlacementPolicy.BookieNode>, int, Set<Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<TopologyAwareEnsemblePlacementPolicy.BookieNode>, ITopologyAwareEnsemblePlacementPolicy.Ensemble<TopologyAwareEnsemblePlacementPolicy.BookieNode>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl

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

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

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

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

sendReadTo(int, BookieSocketAddress, PendingReadOp.LedgerEntryRequest) - Method in class org.apache.bookkeeper.client.PendingReadOp

sendReadTo(int, BookieSocketAddress, ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest) - Method in class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp

sendWriteLacRequest(int) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

sendWriteRequest(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(ArrayList<BookieSocketAddress>, long, long) - Constructor for class org.apache.bookkeeper.client.PendingReadOp.SequenceReadRequest

SequenceReadRequest(ArrayList<BookieSocketAddress>, long, long) - Constructor for class org.apache.bookkeeper.client.ReadLastConfirmedAndEntryOp.SequenceReadRequest

serialize() - Method in class org.apache.bookkeeper.client.LedgerMetadata

Generates a byte array of this object

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

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

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

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.

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.

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

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

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.

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

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.

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

Set the client authentication provider factory class name.

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.

setCode(int) - Method in exception org.apache.bookkeeper.client.BKException

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.

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

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

Enable/Disable delaying ensemble change.

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.

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.

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

Set Ensemble Placement Policy Class.

setEnsembles(SortedMap<Long, ArrayList<BookieSocketAddress>>) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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.

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

Set entry logger size limitation

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

Deprecated.

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

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

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

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

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

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

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.

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

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

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

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

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

Set Ledger Manager Factory Class.

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

Set Ledger Manager Factory Class Name.

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

Deprecated.

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

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

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

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

Set the network interface that the bookie should listen on.

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.

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

Set threshold of major compaction.

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

Set max number of older journal files to kept

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

Set new max journal file size

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

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.

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.

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

Set interval to run minor compaction

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

Set threshold of minor compaction

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

Enable/Disable the usage of Pooled Netty buffers.

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.

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

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.

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

Set number of ticks that used for org.jboss.netty.util.HashedWheelTimer that used by PCBC to timeout request.

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

Set the tick duration in milliseconds that used for org.jboss.netty.util.HashedWheelTimer that used by PCBC to timeout requests.

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

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

Deprecated.

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

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

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

Enable/disable reordering read sequence on reading entries.

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.

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

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

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

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

setState(DataFormats.LedgerMetadataFormat.State) - Method in class org.apache.bookkeeper.client.LedgerMetadata

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

Turn on/off statistics

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

Deprecated.

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

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

Set the stats provider used by bookie.

SettableFeature - Class in org.apache.bookkeeper.feature

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.

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.

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.

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

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

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

setVersion(Version) - Method in class org.apache.bookkeeper.client.LedgerMetadata

Updates the version of this metadata.

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

Set Zk Ledgers Root Path.

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.

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

Set zookeeper servers to connect

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

Set zookeeper servers to connect

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

Set zookeeper timeout

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

Set zookeeper timeout

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

Deprecated.

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

SHOULD_SHUTDOWN_SERVICE_TRACKER - Static variable in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

shutDownRegistry - Variable in class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

SingleFragmentCallback(AsyncCallback.VoidCallback, LedgerHandle, long, BookieSocketAddress, BookieSocketAddress) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator.SingleFragmentCallback

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

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

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

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

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

start(Configuration) - Method in class org.apache.bookkeeper.stats.CachingStatsProvider

start(Configuration) - Method in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

start(Configuration) - Method in class org.apache.bookkeeper.stats.NullStatsProvider

start(Configuration) - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider

start(Configuration) - Method in interface org.apache.bookkeeper.stats.StatsProvider

Intialize the stats provider by loading the given configuration conf.

start(Configuration) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsProvider

start(Configuration) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

start() - Method in class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

start(Configuration) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

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 - Class in org.apache.bookkeeper.stats

An umbrella class for loading stats provider.

Stats() - Constructor for class org.apache.bookkeeper.stats.Stats

STATS_EXPORT - Static variable in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

STATS_EXPORT - Static variable in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

STATS_HTTP_PORT - Static variable in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

STATS_HTTP_PORT - Static variable in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

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

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

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

StatsLogger - Interface in org.apache.bookkeeper.stats

A simple interface that exposes just 2 useful methods.

statsLoggers - Variable in class org.apache.bookkeeper.stats.CachingStatsProvider

StatsProvider - Interface in org.apache.bookkeeper.stats

Provider to provide stats logger for different scopes.

stop() - Method in class org.apache.bookkeeper.stats.CachingStatsProvider

stop() - Method in class org.apache.bookkeeper.stats.CodahaleMetricsProvider

stop() - Method in class org.apache.bookkeeper.stats.NullStatsProvider

stop() - Method in class org.apache.bookkeeper.stats.PrometheusMetricsProvider

stop() - Method in interface org.apache.bookkeeper.stats.StatsProvider

Close the stats provider.

stop() - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsProvider

stop() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichProvider

stop() - Method in class org.apache.bookkeeper.stats.twitter.science.HTTPStatsExporter

stop() - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

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

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

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

success - Variable in class org.apache.bookkeeper.stats.CodahaleOpStatsLogger

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

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

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

SynchCallbackUtils - Class in org.apache.bookkeeper.client

Utility for callbacks

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

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

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

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

SyncReadLastConfirmedCallback() - Constructor for class org.apache.bookkeeper.client.LedgerHandle.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 - Variable in class org.apache.bookkeeper.client.LedgerHandle

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

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

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

Operations timeouts.

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

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

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

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_KEYSTORE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

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

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

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

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

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

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

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

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

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

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

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

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

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

This function should go away soon (hopefully).

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

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

toOpStatsData() - Method in class org.apache.bookkeeper.stats.PrometheusOpStatsLogger

toOpStatsData() - Method in class org.apache.bookkeeper.stats.twitter.finagle.OpStatsLoggerImpl

We don't need to support percentiles as a part of this provider, since they're part of the Stats implementation library.

toOpStatsData() - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OpStatsLoggerImpl

toOpStatsData() - Method in class org.apache.bookkeeper.stats.twitter.science.OpStatsLoggerImpl

This function should go away soon (hopefully).

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

TopologyAwareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client

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

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

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

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

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

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

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

toString() - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

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

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

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

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, ReadLastConfirmedOp.LastConfirmedDataCallback, long) - Constructor for class org.apache.bookkeeper.client.TryReadLastConfirmedOp

TwitterStatsLoggerImpl - Class in org.apache.bookkeeper.stats.twitter.science

Implementation of twitter-stats logger.

TwitterStatsLoggerImpl(String) - Constructor for class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

TwitterStatsProvider - Class in org.apache.bookkeeper.stats.twitter.science

A stats provider implemented based on Twitter Stats library.

TwitterStatsProvider() - Constructor for class org.apache.bookkeeper.stats.twitter.science.TwitterStatsProvider

U

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

Operations failed due to unauthorized.

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

Replication failed due to unclosed fragments.

underlying - Variable in class org.apache.bookkeeper.stats.CachingStatsLogger

underlying - Variable in class org.apache.bookkeeper.stats.CachingStatsProvider

UnexpectedConditionException - Static variable in interface org.apache.bookkeeper.client.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

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

A placer holder (unused)

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

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CachingStatsLogger

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.CodahaleStatsLogger

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.NullStatsLogger

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.PrometheusStatsLogger

unregisterGauge(String, Gauge<T>) - Method in interface org.apache.bookkeeper.stats.StatsLogger

Unregister given gauge from name name.

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.finagle.FinagleStatsLoggerImpl

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.ostrich.OstrichStatsLoggerImpl

unregisterGauge(String, Gauge<T>) - Method in class org.apache.bookkeeper.stats.twitter.science.TwitterStatsLoggerImpl

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

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

update(ByteBuf) - Method in class org.apache.bookkeeper.client.CRC32DigestManager

update(byte[]) - Method in class org.apache.bookkeeper.client.DigestManager

update(ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

update(ByteBuf) - Method in class org.apache.bookkeeper.client.MacDigestManager

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

Update the bookie id present in the ledger metadata.

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

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

Send the bookie info details.

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

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

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

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

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

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

V

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

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.

verifyDigestAndReturnData(long, ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

Verify that the digest matches and returns the data in the entry.

verifyDigestAndReturnLac(ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

verifyDigestAndReturnLastConfirmed(ByteBuf) - Method in class org.apache.bookkeeper.client.DigestManager

version - Variable in class org.apache.bookkeeper.client.LedgerMetadata

VERSION_KEY - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

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

W

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

Wait for a result.

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

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

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

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

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

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

writeComplete(int, long, long, BookieSocketAddress, Object) - Method in class org.apache.bookkeeper.client.PendingAddOp

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

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

Write operations failed (bookie error)

writeLacComplete(int, long, BookieSocketAddress, Object) - Method in class org.apache.bookkeeper.client.PendingWriteLacOp

writeLedgerConfig(BookkeeperInternalCallbacks.GenericCallback<Void>) - Method in class org.apache.bookkeeper.client.LedgerHandle

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

Write operations failed due to bookies are readonly

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

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

writeSet - Variable in class org.apache.bookkeeper.client.PendingReadOp.LedgerEntryRequest

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

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

Z

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

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

Configure the bookkeeper client with a provided ZooKeeper client.

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

ZK_CONNECT_BACKOFF_SEC - Static variable in class org.apache.bookkeeper.client.BookieWatcher

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_START_MS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

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

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

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

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

ZooKeeper operations failed

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

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