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