org.apache.bookkeeper.client

Class BookKeeperAdmin

java.lang.Object

org.apache.bookkeeper.client.BookKeeperAdmin

All Implemented Interfaces:

java.lang.AutoCloseable

public class BookKeeperAdmin
extends java.lang.Object
implements java.lang.AutoCloseable

Admin client for BookKeeper clusters.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	BookKeeperAdmin.LedgerEntriesIterable
(package private) class	BookKeeperAdmin.LedgerEntriesIterator
static class	BookKeeperAdmin.ResultCallBack This is the class for getting the replication result.
(package private) static class	BookKeeperAdmin.SyncObject

Constructor Summary

Constructors

Constructor and Description
BookKeeperAdmin(BookKeeper bkc)
BookKeeperAdmin(BookKeeper bkc, org.apache.bookkeeper.stats.StatsLogger statsLogger) Constructor that takes in a BookKeeper instance .
BookKeeperAdmin(ClientConfiguration conf) Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(java.lang.String zkServers) Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.

Method Summary

Modifier and Type	Method and Description
static boolean	areEntriesOfLedgerStoredInTheBookie(long ledgerId, org.apache.bookkeeper.net.BookieId bookieAddress, org.apache.bookkeeper.meta.LedgerManager ledgerManager)
static boolean	areEntriesOfLedgerStoredInTheBookie(long ledgerId, org.apache.bookkeeper.net.BookieId bookieAddress, LedgerMetadata ledgerMetadata)
void	asyncGetLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.SortedMap<java.lang.Long,LedgerMetadata>> callback)
java.util.concurrent.CompletableFuture<org.apache.bookkeeper.util.AvailabilityOfEntriesOfLedger>	asyncGetListOfEntriesOfLedger(org.apache.bookkeeper.net.BookieId address, long ledgerId) Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.
void	asyncOpenLedger(long lId, AsyncCallback.OpenCallback cb, java.lang.Object ctx) Open a ledger as an administrator.
void	asyncOpenLedgerNoRecovery(long lId, AsyncCallback.OpenCallback cb, java.lang.Object ctx) Open a ledger as an administrator without recovering the ledger.
void	asyncRecoverBookieData(org.apache.bookkeeper.net.BookieId bookieSrc, AsyncCallback.RecoverCallback cb, java.lang.Object context) Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.
void	asyncRecoverBookieData(long lid, java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc, boolean dryrun, boolean skipOpenLedgers, AsyncCallback.RecoverCallback callback, java.lang.Object context) Recover a specific ledger.
void	asyncRecoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc, AsyncCallback.RecoverCallback cb, java.lang.Object context)
void	asyncRecoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc, boolean dryrun, boolean skipOpenLedgers, AsyncCallback.RecoverCallback cb, java.lang.Object context)
void	close() Gracefully release resources that this client uses.
void	decommissionBookie(org.apache.bookkeeper.net.BookieId bookieAddress) Triggers AuditTask by resetting lostBookieRecoveryDelay and then make sure the ledgers stored in the given decommissioning bookie are properly replicated and they are not underreplicated because of the given bookie.
static boolean	format(ServerConfiguration conf, boolean isInteractive, boolean force) Format the BookKeeper metadata in zookeeper.
(package private) static java.lang.String	formatEnsemble(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc, char marker)
java.util.Collection<org.apache.bookkeeper.net.BookieId>	getAllBookies() Get a list of all bookies including the not available ones.
java.util.Collection<org.apache.bookkeeper.net.BookieId>	getAvailableBookies() Get a list of the available bookies.
org.apache.bookkeeper.proto.BookieAddressResolver	getBookieAddressResolver()
org.apache.bookkeeper.discover.BookieServiceInfo	getBookieServiceInfo(java.lang.String bookiedId)
ClientConfiguration	getConf()
LedgerMetadata	getLedgerMetadata(LedgerHandle lh)
java.util.SortedMap<java.lang.Long,LedgerMetadata>	getLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies)
int	getLostBookieRecoveryDelay() Returns the current LostBookieRecoveryDelay value (in seconds) in Zookeeper.
java.util.Collection<org.apache.bookkeeper.net.BookieId>	getReadOnlyBookies() Get a list of readonly bookies synchronously.
static boolean	initBookie(ServerConfiguration conf) Initializes bookie, by making sure that the journalDir, ledgerDirs and indexDirs are empty and there is no registered Bookie with this BookieId.
static boolean	initNewCluster(ServerConfiguration conf) Intializes new cluster by creating required znodes for the cluster.
EnsemblePlacementPolicy.PlacementPolicyAdherence	isEnsembleAdheringToPlacementPolicy(java.util.List<org.apache.bookkeeper.net.BookieId> ensembleBookiesList, int writeQuorumSize, int ackQuorumSize) returns boolean value specifying if the ensemble of the segment is adhering to the ensemble placement policy for the given writeQuorumSize and ackQuorumSize.
java.lang.Iterable<java.lang.Long>	listLedgers() This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.
static boolean	nukeExistingCluster(ServerConfiguration conf, java.lang.String ledgersRootPath, java.lang.String instanceId, boolean force) Nukes existing cluster metadata.
LedgerHandle	openLedger(long lId) Open a ledger as an administrator.
LedgerHandle	openLedgerNoRecovery(long lId) Open a ledger as an administrator without recovering the ledger.
java.lang.Iterable<LedgerEntry>	readEntries(long ledgerId, long firstEntry, long lastEntry) Read entries from a ledger synchronously.
void	recoverBookieData(org.apache.bookkeeper.net.BookieId bookieSrc) Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
void	recoverBookieData(long lid, java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	recoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc)
void	recoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	replicateLedgerFragment(LedgerHandle lh, LedgerFragment ledgerFragment, java.util.function.BiConsumer<java.lang.Long,java.lang.Long> onReadEntryFailureCallback) Replicate the Ledger fragment to target Bookie passed.
void	setLostBookieRecoveryDelay(int lostBookieRecoveryDelay) Setter for LostBookieRecoveryDelay value (in seconds) in Zookeeper.
void	triggerAudit() Trigger AuditTask by resetting lostBookieRecoveryDelay to its current value.
void	watchReadOnlyBookiesChanged(org.apache.bookkeeper.discover.RegistrationClient.RegistrationListener listener) Notify when the available list of read only bookies changes.
void	watchWritableBookiesChanged(org.apache.bookkeeper.discover.RegistrationClient.RegistrationListener listener) Notify when the available list of bookies changes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BookKeeperAdmin

public BookKeeperAdmin(java.lang.String zkServers)
                throws java.io.IOException,
                       java.lang.InterruptedException,
                       BKException

Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster. We need this before we can do any type of admin operations on the BookKeeper cluster.

Parameters:

zkServers - Comma separated list of hostname:port pairs for the ZooKeeper servers cluster.

Throws:

java.io.IOException - throws this exception if there is an error instantiating the ZooKeeper client.

java.lang.InterruptedException - Throws this exception if there is an error instantiating the BookKeeper client.

BKException - Throws this exception if there is an error instantiating the BookKeeper client.

BookKeeperAdmin

public BookKeeperAdmin(ClientConfiguration conf)
                throws java.io.IOException,
                       java.lang.InterruptedException,
                       BKException

Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster. We need this before we can do any type of admin operations on the BookKeeper cluster.

Parameters:

conf - Client Configuration Object

Throws:

java.io.IOException - throws this exception if there is an error instantiating the ZooKeeper client.

java.lang.InterruptedException - Throws this exception if there is an error instantiating the BookKeeper client.

BKException - Throws this exception if there is an error instantiating the BookKeeper client.

BookKeeperAdmin

public BookKeeperAdmin(BookKeeper bkc,
                       org.apache.bookkeeper.stats.StatsLogger statsLogger)

Constructor that takes in a BookKeeper instance . This will be useful, when user already has bk instance ready.

Parameters:

bkc - - bookkeeper instance

statsLogger - - stats logger

BookKeeperAdmin

public BookKeeperAdmin(BookKeeper bkc)

Method Detail

getConf

public ClientConfiguration getConf()

close

public void close()
           throws java.lang.InterruptedException,
                  BKException

Gracefully release resources that this client uses.

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.InterruptedException - if there is an error shutting down the clients that this class uses.

BKException

getAvailableBookies

public java.util.Collection<org.apache.bookkeeper.net.BookieId> getAvailableBookies()
                                                                             throws BKException

Get a list of the available bookies.

Returns:

a collection of bookie addresses

Throws:

BKException

getAllBookies

public java.util.Collection<org.apache.bookkeeper.net.BookieId> getAllBookies()
                                                                       throws BKException

Get a list of all bookies including the not available ones.

Returns:

a collection of bookie addresses

Throws:

BKException

getBookieAddressResolver

public org.apache.bookkeeper.proto.BookieAddressResolver getBookieAddressResolver()

getBookieServiceInfo

public org.apache.bookkeeper.discover.BookieServiceInfo getBookieServiceInfo(java.lang.String bookiedId)
                                                                      throws BKException

Throws:

BKException

getReadOnlyBookies

public java.util.Collection<org.apache.bookkeeper.net.BookieId> getReadOnlyBookies()
                                                                            throws BKException

Get a list of readonly bookies synchronously.

Returns:

a collection of bookie addresses

Throws:

BKException - if there are issues trying to read the list.

watchWritableBookiesChanged

public void watchWritableBookiesChanged(org.apache.bookkeeper.discover.RegistrationClient.RegistrationListener listener)
                                 throws BKException

Notify when the available list of bookies changes. This is a one-shot notification. To receive subsequent notifications the listener must be registered again.

Parameters:

listener - the listener to notify

Throws:

BKException

watchReadOnlyBookiesChanged

public void watchReadOnlyBookiesChanged(org.apache.bookkeeper.discover.RegistrationClient.RegistrationListener listener)
                                 throws BKException

Notify when the available list of read only bookies changes. This is a one-shot notification. To receive subsequent notifications the listener must be registered again.

Parameters:

listener - the listener to notify

Throws:

BKException

asyncOpenLedger

public void asyncOpenLedger(long lId,
                            AsyncCallback.OpenCallback cb,
                            java.lang.Object ctx)

Open a ledger as an administrator. This means that no digest password checks are done. Otherwise, the call is identical to BookKeeper#asyncOpenLedger

Parameters:

lId - ledger identifier

cb - Callback which will receive a LedgerHandle object

ctx - optional context object, to be passwd to the callback (can be null)

See Also:

BookKeeper.asyncOpenLedger(long, org.apache.bookkeeper.client.BookKeeper.DigestType, byte[], org.apache.bookkeeper.client.AsyncCallback.OpenCallback, java.lang.Object)

openLedger

public LedgerHandle openLedger(long lId)
                        throws java.lang.InterruptedException,
                               BKException

Open a ledger as an administrator. This means that no digest password checks are done. Otherwise, the call is identical to BookKeeper#openLedger

Parameters:

lId - - ledger identifier

Throws:

java.lang.InterruptedException

BKException

See Also:

BookKeeper.openLedger(long, org.apache.bookkeeper.client.BookKeeper.DigestType, byte[])

asyncOpenLedgerNoRecovery

public void asyncOpenLedgerNoRecovery(long lId,
                                      AsyncCallback.OpenCallback cb,
                                      java.lang.Object ctx)

Open a ledger as an administrator without recovering the ledger. This means that no digest password checks are done. Otherwise, the call is identical to BookKeeper#asyncOpenLedgerNoRecovery

Parameters:

lId - ledger identifier

cb - Callback which will receive a LedgerHandle object

ctx - optional context object, to be passwd to the callback (can be null)

See Also:

BookKeeper.asyncOpenLedgerNoRecovery(long, org.apache.bookkeeper.client.BookKeeper.DigestType, byte[], org.apache.bookkeeper.client.AsyncCallback.OpenCallback, java.lang.Object)

openLedgerNoRecovery

public LedgerHandle openLedgerNoRecovery(long lId)
                                  throws java.lang.InterruptedException,
                                         BKException

Open a ledger as an administrator without recovering the ledger. This means that no digest password checks are done. Otherwise, the call is identical to BookKeeper#openLedgerNoRecovery

Parameters:

lId - ledger identifier

Throws:

java.lang.InterruptedException

BKException

See Also:

BookKeeper.openLedgerNoRecovery(long, org.apache.bookkeeper.client.BookKeeper.DigestType, byte[])

readEntries

public java.lang.Iterable<LedgerEntry> readEntries(long ledgerId,
                                                   long firstEntry,
                                                   long lastEntry)
                                            throws java.lang.InterruptedException,
                                                   BKException

Read entries from a ledger synchronously. If the lastEntry is -1, it will read all the entries in the ledger from the firstEntry.

Parameters:

ledgerId -

firstEntry -

lastEntry -

Returns:

Throws:

java.lang.InterruptedException

BKException

getLedgersContainBookies

public java.util.SortedMap<java.lang.Long,LedgerMetadata> getLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies)
                                                                            throws java.lang.InterruptedException,
                                                                                   BKException

Throws:

java.lang.InterruptedException

BKException

asyncGetLedgersContainBookies

public void asyncGetLedgersContainBookies(java.util.Set<org.apache.bookkeeper.net.BookieId> bookies,
                                          org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.GenericCallback<java.util.SortedMap<java.lang.Long,LedgerMetadata>> callback)

recoverBookieData

public void recoverBookieData(org.apache.bookkeeper.net.BookieId bookieSrc)
                       throws java.lang.InterruptedException,
                              BKException

Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie. That bookie could have failed completely and now the ledger data that was stored on it is under replicated. An optional destination bookie server could be given if we want to copy all of the ledger fragments data on the failed source bookie to it. Otherwise, we will just randomly distribute the ledger fragments to the active set of bookies, perhaps based on load. All ZooKeeper ledger metadata will be updated to point to the new bookie(s) that contain the replicated ledger fragments.

Parameters:

bookieSrc - Source bookie that had a failure. We want to replicate the ledger fragments that were stored there.

Throws:

java.lang.InterruptedException

BKException

recoverBookieData

public void recoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc)
                       throws java.lang.InterruptedException,
                              BKException

Throws:

java.lang.InterruptedException

BKException

recoverBookieData

public void recoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc,
                              boolean dryrun,
                              boolean skipOpenLedgers)
                       throws java.lang.InterruptedException,
                              BKException

Throws:

java.lang.InterruptedException

BKException

recoverBookieData

public void recoverBookieData(long lid,
                              java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc,
                              boolean dryrun,
                              boolean skipOpenLedgers)
                       throws java.lang.InterruptedException,
                              BKException

Throws:

java.lang.InterruptedException

BKException

asyncRecoverBookieData

public void asyncRecoverBookieData(org.apache.bookkeeper.net.BookieId bookieSrc,
                                   AsyncCallback.RecoverCallback cb,
                                   java.lang.Object context)

Async method to rebuild and recover the ledger fragments data that was stored on the source bookie. That bookie could have failed completely and now the ledger data that was stored on it is under replicated. An optional destination bookie server could be given if we want to copy all of the ledger fragments data on the failed source bookie to it. Otherwise, we will just randomly distribute the ledger fragments to the active set of bookies, perhaps based on load. All ZooKeeper ledger metadata will be updated to point to the new bookie(s) that contain the replicated ledger fragments.

Parameters:

bookieSrc - Source bookie that had a failure. We want to replicate the ledger fragments that were stored there.

cb - RecoverCallback to invoke once all of the data on the dead bookie has been recovered and replicated.

context - Context for the RecoverCallback to call.

asyncRecoverBookieData

public void asyncRecoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc,
                                   AsyncCallback.RecoverCallback cb,
                                   java.lang.Object context)

asyncRecoverBookieData

public void asyncRecoverBookieData(java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc,
                                   boolean dryrun,
                                   boolean skipOpenLedgers,
                                   AsyncCallback.RecoverCallback cb,
                                   java.lang.Object context)

asyncRecoverBookieData

public void asyncRecoverBookieData(long lid,
                                   java.util.Set<org.apache.bookkeeper.net.BookieId> bookieSrc,
                                   boolean dryrun,
                                   boolean skipOpenLedgers,
                                   AsyncCallback.RecoverCallback callback,
                                   java.lang.Object context)

Recover a specific ledger.

Parameters:

lid - ledger to recover

bookieSrc - Source bookies that had a failure. We want to replicate the ledger fragments that were stored there.

dryrun - dryrun the recover procedure.

skipOpenLedgers - Skip recovering open ledgers.

callback - RecoverCallback to invoke once all of the data on the dead bookie has been recovered and replicated.

context - Context for the RecoverCallback to call.

formatEnsemble

static java.lang.String formatEnsemble(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
                                       java.util.Set<org.apache.bookkeeper.net.BookieId> bookiesSrc,
                                       char marker)

replicateLedgerFragment

public void replicateLedgerFragment(LedgerHandle lh,
                                    LedgerFragment ledgerFragment,
                                    java.util.function.BiConsumer<java.lang.Long,java.lang.Long> onReadEntryFailureCallback)
                             throws java.lang.InterruptedException,
                                    BKException

Replicate the Ledger fragment to target Bookie passed.

Parameters:

lh - - ledgerHandle

ledgerFragment - - LedgerFragment to replicate

Throws:

java.lang.InterruptedException

BKException

format

public static boolean format(ServerConfiguration conf,
                             boolean isInteractive,
                             boolean force)
                      throws java.lang.Exception

Format the BookKeeper metadata in zookeeper.

Parameters:

isInteractive - Whether format should ask prompt for confirmation if old data exists or not.

force - If non interactive and force is true, then old data will be removed without prompt.

Returns:

Returns true if format succeeds else false.

Throws:

java.lang.Exception

initNewCluster

public static boolean initNewCluster(ServerConfiguration conf)
                              throws java.lang.Exception

Intializes new cluster by creating required znodes for the cluster. If ledgersrootpath is already existing then it will error out.

Parameters:

conf -

Returns:

Throws:

java.lang.Exception

nukeExistingCluster

public static boolean nukeExistingCluster(ServerConfiguration conf,
                                          java.lang.String ledgersRootPath,
                                          java.lang.String instanceId,
                                          boolean force)
                                   throws java.lang.Exception

Nukes existing cluster metadata. But it does only if the provided ledgersRootPath matches with configuration's zkLedgersRootPath and provided instanceid matches with the cluster metadata. If force is mentioned then instanceid will not be validated.

Parameters:

conf -

ledgersRootPath -

instanceId -

force -

Returns:

Throws:

java.lang.Exception

initBookie

public static boolean initBookie(ServerConfiguration conf)
                          throws java.lang.Exception

Initializes bookie, by making sure that the journalDir, ledgerDirs and indexDirs are empty and there is no registered Bookie with this BookieId.

Parameters:

conf -

Returns:

Throws:

java.lang.Exception

listLedgers

public java.lang.Iterable<java.lang.Long> listLedgers()
                                               throws java.io.IOException

This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.

Returns:

an iterable object for the list of ledger identifiers

Throws:

java.io.IOException - if the list of ledger identifiers cannot be read from the metadata store

getLedgerMetadata

public LedgerMetadata getLedgerMetadata(LedgerHandle lh)

Returns:

the metadata for the passed ledger handle

setLostBookieRecoveryDelay

public void setLostBookieRecoveryDelay(int lostBookieRecoveryDelay)
                                throws org.apache.bookkeeper.replication.ReplicationException.CompatibilityException,
                                       org.apache.zookeeper.KeeperException,
                                       java.lang.InterruptedException,
                                       org.apache.bookkeeper.replication.ReplicationException.UnavailableException

Setter for LostBookieRecoveryDelay value (in seconds) in Zookeeper.

Parameters:

lostBookieRecoveryDelay - lostBookieRecoveryDelay value (in seconds) to set

Throws:

org.apache.bookkeeper.replication.ReplicationException.CompatibilityException

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

org.apache.bookkeeper.replication.ReplicationException.UnavailableException

getLostBookieRecoveryDelay

public int getLostBookieRecoveryDelay()
                               throws org.apache.bookkeeper.replication.ReplicationException.CompatibilityException,
                                      org.apache.zookeeper.KeeperException,
                                      java.lang.InterruptedException,
                                      org.apache.bookkeeper.replication.ReplicationException.UnavailableException

Returns the current LostBookieRecoveryDelay value (in seconds) in Zookeeper.

Returns:

current lostBookieRecoveryDelay value (in seconds)

Throws:

org.apache.bookkeeper.replication.ReplicationException.CompatibilityException

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

org.apache.bookkeeper.replication.ReplicationException.UnavailableException

triggerAudit

public void triggerAudit()
                  throws org.apache.bookkeeper.replication.ReplicationException.CompatibilityException,
                         org.apache.zookeeper.KeeperException,
                         java.lang.InterruptedException,
                         org.apache.bookkeeper.replication.ReplicationException.UnavailableException,
                         java.io.IOException

Trigger AuditTask by resetting lostBookieRecoveryDelay to its current value. If Autorecovery is not enabled or if there is no Auditor then this method will throw UnavailableException.

Throws:

org.apache.bookkeeper.replication.ReplicationException.CompatibilityException

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

org.apache.bookkeeper.replication.ReplicationException.UnavailableException

java.io.IOException

decommissionBookie

public void decommissionBookie(org.apache.bookkeeper.net.BookieId bookieAddress)
                        throws org.apache.bookkeeper.replication.ReplicationException.CompatibilityException,
                               org.apache.bookkeeper.replication.ReplicationException.UnavailableException,
                               org.apache.zookeeper.KeeperException,
                               java.lang.InterruptedException,
                               java.io.IOException,
                               org.apache.bookkeeper.replication.ReplicationException.BKAuditException,
                               java.util.concurrent.TimeoutException,
                               BKException

Triggers AuditTask by resetting lostBookieRecoveryDelay and then make sure the ledgers stored in the given decommissioning bookie are properly replicated and they are not underreplicated because of the given bookie. This method waits untill there are no underreplicatedledgers because of this bookie. If the given Bookie is not shutdown yet, then it will throw BKIllegalOpException.

Parameters:

bookieAddress - address of the decommissioning bookie

Throws:

org.apache.bookkeeper.replication.ReplicationException.CompatibilityException

org.apache.bookkeeper.replication.ReplicationException.UnavailableException

org.apache.zookeeper.KeeperException

java.lang.InterruptedException

java.io.IOException

org.apache.bookkeeper.replication.ReplicationException.BKAuditException

java.util.concurrent.TimeoutException

BKException

areEntriesOfLedgerStoredInTheBookie

public static boolean areEntriesOfLedgerStoredInTheBookie(long ledgerId,
                                                          org.apache.bookkeeper.net.BookieId bookieAddress,
                                                          org.apache.bookkeeper.meta.LedgerManager ledgerManager)

areEntriesOfLedgerStoredInTheBookie

public static boolean areEntriesOfLedgerStoredInTheBookie(long ledgerId,
                                                          org.apache.bookkeeper.net.BookieId bookieAddress,
                                                          LedgerMetadata ledgerMetadata)

isEnsembleAdheringToPlacementPolicy

public EnsemblePlacementPolicy.PlacementPolicyAdherence isEnsembleAdheringToPlacementPolicy(java.util.List<org.apache.bookkeeper.net.BookieId> ensembleBookiesList,
                                                                                            int writeQuorumSize,
                                                                                            int ackQuorumSize)

returns boolean value specifying if the ensemble of the segment is adhering to the ensemble placement policy for the given writeQuorumSize and ackQuorumSize.

Parameters:

ensembleBookiesList - ensemble of the segment

writeQuorumSize - writeQuorumSize of the ledger

ackQuorumSize - ackQuorumSize of the ledger

Returns:

true if the ledger is adhering to EnsemblePlacementPolicy

asyncGetListOfEntriesOfLedger

public java.util.concurrent.CompletableFuture<org.apache.bookkeeper.util.AvailabilityOfEntriesOfLedger> asyncGetListOfEntriesOfLedger(org.apache.bookkeeper.net.BookieId address,
                                                                                                                                      long ledgerId)

Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.

Parameters:

address - BookieId of the bookie

ledgerId - ledgerId

Returns:

returns Future