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

A

AbstractConfiguration - Class in org.apache.bookkeeper.conf
Abstract configuration
AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration
 
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
 

B

BKException - Exception in org.apache.bookkeeper.client
Class the enumerates all the possible error conditions
BKException.BKAddEntryQuorumTimeoutException - Exception in org.apache.bookkeeper.client
 
BKException.BKAddEntryQuorumTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKAddEntryQuorumTimeoutException
 
BKException.BKBookieException - Exception in org.apache.bookkeeper.client
 
BKException.BKBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieException
 
BKException.BKBookieHandleNotAvailableException - Exception in org.apache.bookkeeper.client
 
BKException.BKBookieHandleNotAvailableException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieHandleNotAvailableException
 
BKException.BKClientClosedException - Exception in org.apache.bookkeeper.client
 
BKException.BKClientClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKClientClosedException
 
BKException.BKDigestMatchException - Exception in org.apache.bookkeeper.client
 
BKException.BKDigestMatchException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestMatchException
 
BKException.BKDigestNotInitializedException - Exception in org.apache.bookkeeper.client
 
BKException.BKDigestNotInitializedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestNotInitializedException
 
BKException.BKDuplicateEntryIdException - Exception in org.apache.bookkeeper.client
 
BKException.BKDuplicateEntryIdException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDuplicateEntryIdException
 
BKException.BKIllegalOpException - Exception in org.apache.bookkeeper.client
 
BKException.BKIllegalOpException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIllegalOpException
 
BKException.BKIncorrectParameterException - Exception in org.apache.bookkeeper.client
 
BKException.BKIncorrectParameterException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIncorrectParameterException
 
BKException.BKInterruptedException - Exception in org.apache.bookkeeper.client
 
BKException.BKInterruptedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKInterruptedException
 
BKException.BKLedgerClosedException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerClosedException
 
BKException.BKLedgerExistException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerExistException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerExistException
 
BKException.BKLedgerFencedException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerFencedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerFencedException
 
BKException.BKLedgerRecoveryException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerRecoveryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerRecoveryException
 
BKException.BKMetadataVersionException - Exception in org.apache.bookkeeper.client
 
BKException.BKMetadataVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataVersionException
 
BKException.BKNoSuchEntryException - Exception in org.apache.bookkeeper.client
 
BKException.BKNoSuchEntryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchEntryException
 
BKException.BKNoSuchLedgerExistsException - Exception in org.apache.bookkeeper.client
 
BKException.BKNoSuchLedgerExistsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsException
 
BKException.BKNotEnoughBookiesException - Exception in org.apache.bookkeeper.client
 
BKException.BKNotEnoughBookiesException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException
 
BKException.BKProtocolVersionException - Exception in org.apache.bookkeeper.client
 
BKException.BKProtocolVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKProtocolVersionException
 
BKException.BKQuorumException - Exception in org.apache.bookkeeper.client
 
BKException.BKQuorumException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKQuorumException
 
BKException.BKReadException - Exception in org.apache.bookkeeper.client
 
BKException.BKReadException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReadException
 
BKException.BKReplicationException - Exception in org.apache.bookkeeper.client
 
BKException.BKReplicationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReplicationException
 
BKException.BKTimeoutException - Exception in org.apache.bookkeeper.client
 
BKException.BKTimeoutException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKTimeoutException
 
BKException.BKUnauthorizedAccessException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnauthorizedAccessException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnauthorizedAccessException
 
BKException.BKUnclosedFragmentException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnclosedFragmentException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnclosedFragmentException
 
BKException.BKUnexpectedConditionException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnexpectedConditionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnexpectedConditionException
 
BKException.BKWriteException - Exception in org.apache.bookkeeper.client
 
BKException.BKWriteException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteException
 
BKException.BKWriteOnReadOnlyBookieException - Exception in org.apache.bookkeeper.client
 
BKException.BKWriteOnReadOnlyBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteOnReadOnlyBookieException
 
BKException.Code - Interface in org.apache.bookkeeper.client
List of return codes
BKException.MetaStoreException - Exception in org.apache.bookkeeper.client
 
BKException.MetaStoreException() - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException
 
BKException.ZKException - Exception in org.apache.bookkeeper.client
 
BKException.ZKException() - Constructor for exception org.apache.bookkeeper.client.BKException.ZKException
 
BOOKIE_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BOOKIE_ERROR_THRESHOLD_PER_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_HEALTH_CHECK_ENABLED - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_HEALTH_CHECK_INTERVAL_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
BOOKIE_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
BOOKIE_QUARANTINE_TIME_SECONDS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
bookieClient - Variable in class org.apache.bookkeeper.client.LedgerChecker
 
BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
BookiesListener - Interface in org.apache.bookkeeper.client
Listener for the the available bookies changes.
BookKeeper - Class in org.apache.bookkeeper.client
BookKeeper client.
BookKeeper(String) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client.
BookKeeper(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client using a configuration object.
BookKeeper(ClientConfiguration, ZooKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.
BookKeeper(ClientConfiguration, ZooKeeper, ClientSocketChannelFactory) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client and client socket channel factory instead of instantiating those.
BookKeeper.Builder - Class in org.apache.bookkeeper.client
 
BookKeeper.DigestType - Enum in org.apache.bookkeeper.client
There are 2 digest types that can be used for verification.
BookKeeperAdmin - Class in org.apache.bookkeeper.client
Admin client for BookKeeper clusters
BookKeeperAdmin(String) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(BookKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a BookKeeper instance .
BookKeeperClientStats - Interface in org.apache.bookkeeper.client
 
build() - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 

C

CHANNEL_ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_ADD - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_READ - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>) - Method in class org.apache.bookkeeper.client.LedgerChecker
Check that all the fragments in the passed in ledger, and report those which are missing.
CLIENT_AUTH_PROVIDER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_CONNECT_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_RECEIVEBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CLIENT_SENDBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ClientClosedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
ClientConfiguration - Class in org.apache.bookkeeper.conf
Configuration settings for client side
ClientConfiguration() - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a default client-side configuration
ClientConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a client-side configuration using a base configuration
close() - Method in class org.apache.bookkeeper.client.BookKeeper
Shuts down client.
close() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Gracefully release resources that this client uses.
close() - Method in class org.apache.bookkeeper.client.LedgerHandle
Close this ledger synchronously.
closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback
Callback definition
COMPACTION_MAX_OUTSTANDING_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE_BY_BYTES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE_BY_ENTRIES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
Configurable - Interface in org.apache.bookkeeper.conf
Class that may be configured with a Configuration.
create(int) - Static method in exception org.apache.bookkeeper.client.BKException
Create an exception from an error code
CREATE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
createComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CreateCallback
Declaration of callback method
createLedger(BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger.
createLedger(int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedger(int, int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedgerAdv(int, int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
CURRENT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata
 

D

DEATH_WATCH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DefaultEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
Default Ensemble Placement Policy, which picks bookies randomly
DefaultEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
defaultLoader - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DELETE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
deleteComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.DeleteCallback
Callback definition for delete operations
deleteLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to delete a ledger.
DIGEST_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
DigestMatchException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
DigestNotInitializedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
DISK_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_WARN_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DuplicateEntryIdException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 

E

ENABLE_LOCAL_TRANSPORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENABLE_STATISTICS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENABLE_TASK_EXECUTION_STATS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
enableBookieHealthCheck() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Enables the bookie health check.
ENSEMBLE_CHANGES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ENSEMBLE_PLACEMENT_POLICY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
EnsemblePlacementPolicy - Interface in org.apache.bookkeeper.client
Encapsulation of the algorithm that selects a number of bookies from the cluster as an ensemble for storing data, based on the data input as well as the node properties.
ENTRY_LOG_FILE_PREALLOCATION_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
equals(Object) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 

F

FLUSH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FORCE_READ_ONLY_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
forConfig(ClientConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeper
 
format(ClientConfiguration, boolean, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Format the BookKeeper metadata in zookeeper

G

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

H

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

I

IllegalOpException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
IncorrectParameterException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
INDEX_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
initialize(Configuration) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
initialize(Configuration) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Initialize the policy.
initialize(Configuration) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
instance - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
instance - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
 
InterruptedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
INVALID_ENTRY_ID - Static variable in class org.apache.bookkeeper.client.LedgerHandle
Invalid entry id.
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
 
isAutoRecoveryDaemonEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the Bookie itself can start auto-recovery service also or not
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
isEnableLocalTransport() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get hwhether to use 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
 
isReadOnlyModeEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether read-only mode is enabled.
isStatisticsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is statistics enabled

J

JOURNAL_ADAPTIVE_GROUP_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_ALIGNMENT_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_ENTRIES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_WRITES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_DIR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FLUSH_WHEN_QUEUE_EMPTY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FORMAT_VERSION_TO_WRITE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_MAX_GROUP_WAIT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_PRE_ALLOC_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_REMOVE_FROM_PAGE_CACHE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

L

LAC_UPDATE_HITS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LAC_UPDATE_MISSES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LEDGER_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_MANAGER_TYPE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_STORAGE_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LedgerChecker - Class in org.apache.bookkeeper.client
Checks the complete ledger and finds the UnderReplicated fragments if any
LedgerChecker(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LedgerEntry - Class in org.apache.bookkeeper.client
Ledger entry.
LedgerExistException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LedgerFragment - Class in org.apache.bookkeeper.client
Represents the entries of a segment of a ledger which are stored on a single bookie in the segments bookie ensemble.
LedgerFragmentReplicator - Class in org.apache.bookkeeper.client
This is the helper class for replicating the fragments from one bookie to another
LedgerFragmentReplicator(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator
 
LedgerHandle - Class in org.apache.bookkeeper.client
Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.
LedgerHandleAdv - Class in org.apache.bookkeeper.client
Ledger Advanced handle extends LedgerHandle to provide API to add entries with user supplied entryIds.
LedgerMetadata - Class in org.apache.bookkeeper.client
This class encapsulates all the ledger metadata that is persistently stored in zookeeper.
LedgerMetadata(int, int, int, BookKeeper.DigestType, byte[]) - Constructor for class org.apache.bookkeeper.client.LedgerMetadata
 
LedgerRecoveryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LISTENING_INTERFACE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
listLedgers() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.
loadConf(URL) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configurations in precedence order.
loadConf(AbstractConfiguration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configuration from other configuration
loadConf(Configuration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Load configuration from other configuration object
LOWEST_COMPAT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata
 

M

MAJOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAJOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_BACKUP_JOURNALS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_JOURNAL_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MetadataVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
METASTORE_IMPL_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
METASTORE_MAX_ENTRIES_PER_SCAN - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
MetaStoreException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
MINOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MINOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

N

newEnsemble(int, int, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
newEnsemble(int, int, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose numBookies bookies for ensemble.
newEnsemble(int, int, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
NoBookieAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
NoSuchEntryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
NoSuchLedgerExistsException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
NotEnoughBookiesException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
notifyBookiesChanged(BookiesListener) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Notify when the available list of bookies changes.
notifyReadOnlyBookiesChanged(BookiesListener) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Notify when the available list of read only bookies changes.
NUM_ADD_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_CHANNELS_PER_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUM_JOURNAL_CALLBACK_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_READ_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 

O

OK - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
OPEN_FILE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_LEDGER_REREPLICATION_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
openComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback
Callback for asynchronous call to open ledger
openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous open ledger call
openLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator.
openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous, unsafe open ledger call
openLedgerNoRecovery(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator without recovering the ledger.
org.apache.bookkeeper.client - package org.apache.bookkeeper.client
 
org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf
 

P

PAGE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
PAGE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
parseConfig(byte[], Version, Optional<Long>) - Static method in class org.apache.bookkeeper.client.LedgerMetadata
Parses a given byte array and transforms into a LedgerConfig object
PASSWD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PCBC_TIMEOUT_TIMER_NUM_TICKS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PCBC_TIMEOUT_TIMER_TICK_DURATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PENDING_ADDS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 

Q

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

R

RackawareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
Simple rackware ensemble placement policy.
RackawareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
RackawareEnsemblePlacementPolicy.BookieNode - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.Ensemble - Interface in org.apache.bookkeeper.client
Ensemble used to hold the result of an ensemble selected for placement.
RackawareEnsemblePlacementPolicy.EnsembleForReplacement - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.EnsembleForReplacement() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
RackawareEnsemblePlacementPolicy.Predicate - Interface in org.apache.bookkeeper.client
Predicate used when choosing an ensemble.
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble - Class in org.apache.bookkeeper.client
A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble(int, int) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
RackawareEnsemblePlacementPolicy.TruePredicate - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.TruePredicate() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
 
READ_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
READ_ONLY_MODE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadCallback
Callback declaration
readEntries(long, long, long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Read entries from a ledger synchronously.
readEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries synchronously.
ReadException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
readLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains synchronously the last confirmed write from a quorum of bookies.
readLastConfirmedComplete(int, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedCallback
Callback definition for bookie recover operations
recoverBookieData(BookieSocketAddress, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback
Callback definition for bookie recover operations
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose a new bookie to replace bookieToReplace.
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
replicateLedgerFragment(LedgerHandle, LedgerFragment, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Replicate the Ledger fragment to target Bookie passed.
ReplicationException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
REPP_DNS_RESOLVER_CLASS - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
REREPLICATION_ENTRY_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 

S

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
Set the error threshold per interval (ClientConfiguration.getBookieHealthCheckIntervalSeconds()) for a bookie before it is quarantined.
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
Deprecated.
Use ServerConfiguration.setLedgerStorageClass(String) to configure the implementation class
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
 

T

TASK_EXECUTION_WARN_TIME_MICROS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
THROTTLE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
TIMEOUT_TASK_INTERVAL_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
TimeoutException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
toList() - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Ensemble
 
toList() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
toList() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
toString() - Method in class org.apache.bookkeeper.client.LedgerFragment
 
toString() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
toString() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
toString() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
tryReadLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains synchronously the last confirmed write from a quorum of bookies.

U

UnauthorizedAccessException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
UnclosedFragmentException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
UnexpectedConditionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
uninitalize() - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
uninitalize() - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Uninitialize the policy
uninitalize() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
updateBookieIdInLedgers(BookieSocketAddress, BookieSocketAddress, int, int, BookieShell.UpdateLedgerNotifier) - Method in class org.apache.bookkeeper.client.UpdateLedgerOp
Update the bookie id present in the ledger metadata.
UpdateLedgerOp - Class in org.apache.bookkeeper.client
Encapsulates updating the ledger metadata operation
UpdateLedgerOp(BookKeeper, BookKeeperAdmin) - Constructor for class org.apache.bookkeeper.client.UpdateLedgerOp
 
USE_HOST_NAME_AS_BOOKIE_ID - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

V

validate() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Validate the configuration.
valueOf(String) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType
Returns an array containing the constants of this enum type, in the order they are declared.
VERSION_KEY - Static variable in class org.apache.bookkeeper.client.LedgerMetadata
 

W

WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
WriteException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
WriteOnReadOnlyBookieException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 

Z

ZK_LEDGERS_ROOT_PATH - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
ZK_RETRY_BACKOFF_MAX_MS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ZK_RETRY_BACKOFF_START_MS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ZKException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
A B C D E F G H I J L M N O P Q R S T U V W Z 

Copyright © 2011-2016 The Apache Software Foundation. All Rights Reserved.