- AbstractConfiguration - Class in org.apache.bookkeeper.conf
-
Abstract configuration
- AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration
-
- 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(RackawareEnsemblePlacementPolicy.BookieNode) - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Ensemble
-
Append the new bookie node to the ensemble.
- addBookie(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
-
- addBookie(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
-
- addComplete(int, LedgerHandle, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback
-
Callback declaration
- 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.
- AddEntryQuorumTimeoutException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
-
- ALLOW_LOOPBACK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Predicate
-
- apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
-
- apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
-
- 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(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.
- AsyncCallback - Interface in org.apache.bookkeeper.client
-
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
- AsyncCallback.AddCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.CloseCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.CreateCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.DeleteCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.IsClosedCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.OpenCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.ReadCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.ReadLastConfirmedCallback - Interface in org.apache.bookkeeper.client
-
- AsyncCallback.RecoverCallback - Interface in org.apache.bookkeeper.client
-
- asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
-
Asynchronous close, any adds in flight will return errors.
- 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) - Method in class org.apache.bookkeeper.client.BookKeeper
-
Creates a new ledger asynchronously.
- asyncCreateLedgerAdv(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
-
Creates a new ledger asynchronously and returns
LedgerHandleAdv
which can accept entryId.
- asyncDeleteLedger(long, AsyncCallback.DeleteCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
-
Deletes a ledger asynchronously.
- 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.
- asyncReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
-
Obtains asynchronously the last confirmed write from a quorum of bookies.
- 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.
- 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
-
- AVAILABLE_NODE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
-
- availableBookiesChanged() - Method in interface org.apache.bookkeeper.client.BookiesListener
-
- 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
-
- getAckQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- 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.
- getAddr() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getAddress() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the failedBookie address
- getAllowLoopback() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Is the bookie allowed to use a loopback interface as its primary
interface(i.e.
- 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.
- getBookieAuthProviderFactoryClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the bookie authentication provider factory class name.
- getBookieErrorThresholdPerInterval() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the error threshold for a bookie to be quarantined.
- getBookieHealthCheckIntervalSeconds() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the bookie health check interval in seconds.
- 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
- getBookiesIndex() - Method in class org.apache.bookkeeper.client.LedgerFragment
-
Gets the failedBookie index
- getClientAuthProviderFactoryClass() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
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.
- getClientSendBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get client netty channel send buffer size.
- 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.
- getCtime() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
Get the creation timestamp of the ledger
- getDeathWatchInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get bookie death watch interval
- getDiskCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the disk checker interval
- 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.
- 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
- 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
-
- getEntryId() - Method in class org.apache.bookkeeper.client.LedgerEntry
-
- getEntryInputStream() - Method in class org.apache.bookkeeper.client.LedgerEntry
-
- getEntryLogSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get entry logger size limitation
- 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.
- 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.
- 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
- getJournalDir() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get dir to store journal files
- getJournalDirName() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get dir name 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
- 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)
- getLastEntryId() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- 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
- getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerEntry
-
- getLedgerKey() - Method in class org.apache.bookkeeper.client.LedgerHandle
-
Get the Ledger's key/password.
- 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
-
- 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
-
- getLevel() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getListeningInterface() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the network interface that the bookie should
listen for connections on.
- 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
- 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.
- 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.
- getName() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getNetworkLocation() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getNumAddWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle write requests.
- getNumChannelsPerBookie() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get num channels per bookie.
- getNumJournalCallbackThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle journal callbacks.
- getNumReadWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of threads that should handle read requests.
- 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.
- 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
- getParent() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- getPCBCTimeoutTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get number of ticks that used for
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
HashedWheelTimer
that used by PCBC to timeout
requests.
- 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.
- getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
-
Get a list of readonly bookies
- getReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
- getRemoteRack(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
- getRereplicationEntryBatchSize() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get the re-replication entry batch size
- 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)
- getSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Get the period of time after which a speculative entry read should be triggered.
- 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.
- getUseHostNameAsBookieID() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get whether bookie is using hostname for registration and in ledger
metadata.
- getVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
Returns the last version.
- getWriteBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Get the number of bytes used as capacity for the write buffer.
- getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
- getZkAvailableBookiesPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get the node under which available bookies are stored
- getZkLedgersRootPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Get Zk Ledgers Root Path.
- 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.
- selectFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
- selectRandom(int, Set<Node>, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
Choose a random node from whole cluster.
- selectRandomFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
-
Choose random node under a given network path.
- serialize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
-
Generates a byte array of this object
- 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
- 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.
- 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.
- 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
-
- setBookieHealthCheckInterval(int, TimeUnit) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the bookie health check interval.
- 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.
- setChannelFactory(ClientSocketChannelFactory) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
-
- setClientAuthProviderFactoryClass(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
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.
- setClientSendBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set client netty channel send buffer size.
- 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.
- setDiskCheckInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the disk checker interval to monitor ledger disk space
- 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.
- setEnableLocalTransport(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Configure the bookie to listen for BookKeeper clients executed on the local JVM
- 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.
- 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
- setFlushInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set flush interval
- 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
- 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
- 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.
- setJournalRemovePagesFromCache(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Sets that whether should we remove pages from page cache after force write.
- 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
- setLevel(int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- setListeningInterface(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
-
Set the network interface that the bookie should listen on.
- 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
- 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
- setNetworkLocation(String) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- 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.
- 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
- setParent(Node) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
-
- setPCBCTimeoutTimerNumTicks(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set number of ticks that used for
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
HashedWheelTimer
that used by PCBC to timeout
requests.
- 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
-
- setRereplicationEntryBatchSize(long) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set the max entries to keep in fragment for re-replication.
- 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 w 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
-
- setSpeculativeReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
-
Set the speculative read timeout.
- 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.
- 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.
- 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
- 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.
- setZkLedgersRootPath(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
-
Set Zk Ledgers Root Path.
- 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
-
- 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
-
- SORTED_LEDGER_STORAGE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-
- SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
-
- STATS_PROVIDER_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
-