Uses of Class
org.apache.bookkeeper.net.BookieId

Packages that use BookieId

Package	Description
org.apache.bookkeeper.bookie	Provides a Bookie server that stores entries for clients.
org.apache.bookkeeper.bookie.datainteg	Package of the classes for defining bookie stats.
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.client.api	BookKeeper Client Public API.
org.apache.bookkeeper.discover	Classes related to service discovery.
org.apache.bookkeeper.meta	Classes for interacting with bookkeeper ledgers and ledger metadata.
org.apache.bookkeeper.net	Network-related classes.
org.apache.bookkeeper.proto	Classes related to the Bookkeeper protocol.
org.apache.bookkeeper.replication	Classes for replicating Bookkeeper data.
org.apache.bookkeeper.tools.cli.commands.cookie	Cookie related cli commands.
org.apache.bookkeeper.tools.cli.helpers	This classes provides some helper mixins for easily to add commands to bookie shell.

Uses of BookieId in org.apache.bookkeeper.bookie

Methods in org.apache.bookkeeper.bookie that return BookieId

Modifier and Type	Method	Description
static BookieId	BookieImpl.getBookieId(ServerConfiguration conf)

Methods in org.apache.bookkeeper.bookie that return types with arguments of type BookieId

Modifier and Type	Method	Description
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	LocalBookieEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
Set<BookieId>	LocalBookieEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	LocalBookieEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)

Methods in org.apache.bookkeeper.bookie with parameters of type BookieId

Modifier and Type	Method	Description
void	Cookie.deleteFromRegistrationManager(RegistrationManager rm, BookieId address, Version version)	Delete cookie from registration manager.
static Versioned<Cookie>	Cookie.readFromRegistrationManager(RegistrationManager rm, BookieId address)	Read cookie from registration manager for a given bookie address.
void	LocalBookieEnsemblePlacementPolicy.registerSlowBookie(BookieId bookieSocketAddress, long entryId)
EnsemblePlacementPolicy.PlacementResult<BookieId>	LocalBookieEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
void	BookieImpl.NopWriteCallback.writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)

Method parameters in org.apache.bookkeeper.bookie with type arguments of type BookieId

Modifier and Type	Method	Description
EnsemblePlacementPolicy.PlacementPolicyAdherence	LocalBookieEnsemblePlacementPolicy.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	LocalBookieEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
Set<BookieId>	LocalBookieEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
DistributionSchedule.WriteSet	LocalBookieEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	LocalBookieEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
EnsemblePlacementPolicy.PlacementResult<BookieId>	LocalBookieEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	LocalBookieEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
void	LocalBookieEnsemblePlacementPolicy.updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieToFreeSpaceMap)

Constructor parameters in org.apache.bookkeeper.bookie with type arguments of type BookieId

Modifier	Constructor	Description
	BookieStateManager(ServerConfiguration conf, StatsLogger statsLogger, RegistrationManager rm, List<File> statusDirs, Supplier<BookieId> bookieIdSupplier, Supplier<BookieServiceInfo> bookieServiceInfoProvider)

Uses of BookieId in org.apache.bookkeeper.bookie.datainteg

Methods in org.apache.bookkeeper.bookie.datainteg that return types with arguments of type BookieId

Modifier and Type	Method	Description
(package private) Set<BookieId>	EntryCopierImpl.SinBin.getErrorBookies()

Methods in org.apache.bookkeeper.bookie.datainteg with parameters of type BookieId

Modifier and Type	Method	Description
(package private) boolean	EntryCopierImpl.SinBin.addFailed(BookieId bookie)	Returns true if this is the first error for this bookie.
(package private) static boolean	DataIntegrityCheckImpl.ensemblesContainBookie(LedgerMetadata metadata, BookieId bookieId)
(package private) void	EntryCopierImpl.BatchImpl.notifyBookieError(BookieId bookie)
(package private) static com.google.common.collect.ImmutableSortedMap<Long,com.google.common.collect.ImmutableList<Integer>>	EntryCopierImpl.preferredBookieIndices(BookieId bookieId, LedgerMetadata metadata, Set<BookieId> errorBookies, long seed)	Generate a map of preferred bookie indices.

Method parameters in org.apache.bookkeeper.bookie.datainteg with type arguments of type BookieId

Modifier and Type	Method	Description
(package private) static com.google.common.collect.ImmutableSortedMap<Long,com.google.common.collect.ImmutableList<Integer>>	EntryCopierImpl.preferredBookieIndices(BookieId bookieId, LedgerMetadata metadata, Set<BookieId> errorBookies, long seed)	Generate a map of preferred bookie indices.

Constructors in org.apache.bookkeeper.bookie.datainteg with parameters of type BookieId

Modifier	Constructor	Description
(package private)	BatchImpl(BookieId bookieId, long ledgerId, LedgerMetadata metadata, EntryCopierImpl.SinBin sinBin)
	DataIntegrityCheckImpl(BookieId bookieId, LedgerManager ledgerManager, LedgerStorage ledgerStorage, EntryCopier entryCopier, BookKeeperAdmin admin, io.reactivex.rxjava3.core.Scheduler scheduler)
	EntryCopierImpl(BookieId bookieId, BookieClient bookieClient, LedgerStorage storage, com.google.common.base.Ticker ticker)

Uses of BookieId in org.apache.bookkeeper.client

Fields in org.apache.bookkeeper.client declared as BookieId

Modifier and Type	Field	Description
(package private) final BookieId	ReadOpBase.ReadContext.to

Fields in org.apache.bookkeeper.client with type parameters of type BookieId

Modifier and Type	Field	Description
(package private) Set<BookieId>	PendingAddOp.addEntrySuccessBookies
protected final ConcurrentMap<BookieId,ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation>	ZoneawareEnsemblePlacementPolicyImpl.address2NodePlacement
protected final ConcurrentMap<BookieId,String>	RegionAwareEnsemblePlacementPolicy.address2Region
(package private) final com.google.common.cache.LoadingCache<BookieId,Long>	LedgerHandle.bookieFailureHistory
(package private) final List<BookieId>	ForceLedgerOp.currentEnsemble
(package private) final List<BookieId>	PendingReadLacOp.currentEnsemble
(package private) final List<BookieId>	PendingWriteLacOp.currentEnsemble
(package private) final List<BookieId>	TryReadLastConfirmedOp.currentEnsemble
(package private) final Map<Integer,BookieId>	LedgerHandle.delayedWriteFailedBookies
(package private) static final List<BookieId>	TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints.EMPTY_LIST
(package private) static final Set<BookieId>	DefaultEnsemblePlacementPolicy.EMPTY_SET
(package private) List<BookieId>	PendingAddOp.ensemble
(package private) final List<BookieId>	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.ensemble
(package private) final List<BookieId>	ReadOpBase.LedgerEntryRequest.ensemble
protected final Set<BookieId>	ReadOpBase.heardFromHosts
protected final Map<BookieId,BookieNode>	TopologyAwareEnsemblePlacementPolicy.historyBookies
protected final Map<BookieId,BookieNode>	TopologyAwareEnsemblePlacementPolicy.knownBookies
(package private) final Map<BookieId,BookieId>	LedgerFragmentReplicator.SingleFragmentCallback.oldBookie2NewBookie
(package private) final Map<BookieId,BookieId>	LedgerFragmentReplicator.SingleFragmentCallback.oldBookie2NewBookie
(package private) final com.google.common.cache.Cache<BookieId,Boolean>	BookieWatcherImpl.quarantinedBookies
protected com.google.common.collect.ImmutableSet<BookieId>	TopologyAwareEnsemblePlacementPolicy.readOnlyBookies
protected final Set<BookieId>	ReadOpBase.sentToHosts
protected com.google.common.cache.Cache<BookieId,Long>	RackawareEnsemblePlacementPolicyImpl.slowBookies
protected com.google.common.cache.Cache<BookieId,Long>	ZoneawareEnsemblePlacementPolicyImpl.slowBookies

Methods in org.apache.bookkeeper.client that return BookieId

Modifier and Type	Method	Description
BookieId	LedgerFragment.getAddress(int bookieIndex)	Gets the failedBookie address.
BookieId	BookKeeperAdmin.getCurrentAuditor()
(package private) BookieId	BatchedReadOp.SequenceReadRequest.maybeSendSpeculativeRead(BitSet heardFrom)
(package private) BookieId	PendingReadOp.ParallelReadRequest.maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)
(package private) BookieId	PendingReadOp.SequenceReadRequest.maybeSendSpeculativeRead(BitSet heardFrom)	Send to next replica speculatively, if required and possible.
(package private) BookieId	ReadLastConfirmedAndEntryOp.ParallelReadRequest.maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)
(package private) abstract BookieId	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)	Send to next replica speculatively, if required and possible.
(package private) BookieId	ReadLastConfirmedAndEntryOp.SequenceReadRequest.maybeSendSpeculativeRead(BitSet heardFrom)	Send to next replica speculatively, if required and possible.
(package private) abstract BookieId	ReadOpBase.LedgerEntryRequest.maybeSendSpeculativeRead(BitSet heardFromHostsBitSet)	Send to next replica speculatively, if required and possible.
BookieId	BookieWatcher.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)	Choose a bookie to replace bookie bookieIdx in existingBookies.
BookieId	BookieWatcherImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)
(package private) BookieId	BatchedReadOp.SequenceReadRequest.sendNextRead()
(package private) BookieId	PendingReadOp.SequenceReadRequest.sendNextRead()
(package private) BookieId	ReadLastConfirmedAndEntryOp.SequenceReadRequest.sendNextRead()

Methods in org.apache.bookkeeper.client that return types with arguments of type BookieId

Modifier and Type	Method	Description
protected Set<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.addDefaultFaultDomainBookies(Set<BookieId> excludeBookies)
protected Set<BookieId>	RackawareEnsemblePlacementPolicyImpl.addDefaultRackBookiesIfMinNumRacksIsEnforced(Set<BookieId> excludeBookies)
Set<BookieId>	LedgerFragment.getAddresses()
Set<BookieId>	BookieWatcher.getAllBookies()
Set<BookieId>	BookieWatcherImpl.getAllBookies()
Collection<BookieId>	BookKeeperAdmin.getAllBookies()	Get a list of all bookies including the not available ones.
NavigableMap<Long,? extends List<BookieId>>	LedgerMetadataImpl.getAllEnsembles()
Collection<BookieId>	BookKeeperAdmin.getAvailableBookies()	Get a list of the available bookies.
(package private) Map<BookieId,BookieInfoReader.BookieInfo>	BookieInfoReader.getBookieInfo()
Map<BookieId,BookieInfoReader.BookieInfo>	BookKeeper.getBookieInfo()	Retrieves BookieInfo from all the bookies in the cluster.
Set<BookieId>	BookieWatcher.getBookies()
Set<BookieId>	BookieWatcherImpl.getBookies()
(package private) static Set<BookieId>	LedgerMetadataUtils.getBookiesInThisLedger(LedgerMetadata metadata)
(package private) List<BookieId>	LedgerHandle.getCurrentEnsemble()	Get the current ensemble from the ensemble list.
(package private) static List<BookieId>	LedgerMetadataUtils.getCurrentEnsemble(LedgerMetadata metadata)
(package private) List<BookieId>	ReadOnlyLedgerHandle.getCurrentEnsemble()
List<BookieId>	LedgerFragment.getEnsemble()	Gets the ensemble of fragment.
List<BookieId>	LedgerMetadataImpl.getEnsembleAt(long entryId)
Map<Integer,BookieId>	DistributionSchedule.AckSet.getFailedBookies()	Return the list of bookies that already failed.
(package private) static List<BookieId>	LedgerMetadataUtils.getLastEnsembleValue(LedgerMetadata metadata)
Set<BookieId>	BookieWatcher.getReadOnlyBookies()
Set<BookieId>	BookieWatcherImpl.getReadOnlyBookies()
Collection<BookieId>	BookKeeperAdmin.getReadOnlyBookies()	Get a list of readonly bookies synchronously.
List<BookieId>	BookieWatcher.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata)	Create an ensemble with given ensembleSize and writeQuorumSize.
List<BookieId>	BookieWatcherImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int quorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	EnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)	Choose numBookies bookies for ensemble.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate)	Create an ensemble with parent ensemble.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludedBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
protected EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsembleInternal(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
Set<BookieId>	DefaultEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	EnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)	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.
Set<BookieId>	RackawareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	TopologyAwareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	ZoneawareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	EnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)	Choose a new bookie to replace bookieToReplace.
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
(package private) static List<BookieId>	EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher, LedgerMetadata metadata, List<BookieId> oldEnsemble, Map<Integer,BookieId> failedBookies, String logContext)
Map<Integer,BookieId>	BookKeeperAdmin.replaceNotAdheringPlacementPolicyBookie(List<BookieId> ensembleBookiesList, int writeQuorumSize, int ackQuorumSize)
default EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	EnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)	Returns placement result.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
List<BookieId>	ITopologyAwareEnsemblePlacementPolicy.Ensemble.toList()
List<BookieId>	TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints.toList()
List<BookieId>	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.toList()

Methods in org.apache.bookkeeper.client with parameters of type BookieId

Modifier and Type	Method	Description
static boolean	BookKeeperAdmin.areEntriesOfLedgerStoredInTheBookie(long ledgerId, BookieId bookieAddress, LedgerMetadata ledgerMetadata)
static boolean	BookKeeperAdmin.areEntriesOfLedgerStoredInTheBookie(long ledgerId, BookieId bookieAddress, LedgerManager ledgerManager)
CompletableFuture<AvailabilityOfEntriesOfLedger>	BookKeeperAdmin.asyncGetListOfEntriesOfLedger(BookieId address, long ledgerId)	Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.
void	BookKeeperAdmin.asyncRecoverBookieData(BookieId bookieSrc, AsyncCallback.RecoverCallback cb, Object context)	Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.
(package private) boolean	BatchedReadOp.BatchedLedgerEntryRequest.complete(int bookieIndex, BookieId host, ByteBufList bufList)
(package private) boolean	BatchedReadOp.SequenceReadRequest.complete(int bookieIndex, BookieId host, ByteBufList bufList)
(package private) boolean	PendingReadOp.SequenceReadRequest.complete(int bookieIndex, BookieId host, io.netty.buffer.ByteBuf buffer)
(package private) boolean	PendingReadOp.SingleLedgerEntryRequest.complete(int bookieIndex, BookieId host, io.netty.buffer.ByteBuf buffer)	Complete the read request from host.
(package private) boolean	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.complete(int bookieIndex, BookieId host, io.netty.buffer.ByteBuf buffer, long entryId)	Complete the read request from host.
(package private) boolean	ReadLastConfirmedAndEntryOp.SequenceReadRequest.complete(int bookieIndex, BookieId host, io.netty.buffer.ByteBuf buffer, long entryId)
protected BookieNode	TopologyAwareEnsemblePlacementPolicy.convertBookieToNode(BookieId addr)
protected BookieNode	TopologyAwareEnsemblePlacementPolicy.createBookieNode(BookieId addr)
void	BookKeeperAdmin.decommissionBookie(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.
boolean	DistributionSchedule.AckSet.failBookieAndCheck(int bookieIndexHeardFrom, BookieId address)	Received failure response from a bookie and check if ack quorum will be broken.
void	ForceLedgerOp.forceLedgerComplete(int rc, long ledgerId, BookieId addr, Object ctx)
long	BookiesHealthInfo.getBookieFailureHistory(BookieId bookieSocketAddress)	Return the failure history for a bookie.
long	BookiesHealthInfo.getBookiePendingRequests(BookieId bookieSocketAddress)	Returns pending requests to a bookie.
BookieServiceInfo	BookKeeperAdmin.getBookieServiceInfo(BookieId bookiedId)
(package private) Optional<Long>	BookieInfoReader.getFreeDiskSpace(BookieId bookie)	Method to allow tests to block until bookie info is available.
protected String	RegionAwareEnsemblePlacementPolicy.getRegion(BookieId addr)
protected ZoneawareEnsemblePlacementPolicyImpl.ZoneAwareNodeLocation	ZoneawareEnsemblePlacementPolicyImpl.getZoneAwareNodeLocation(BookieId addr)
boolean	BookieWatcher.isBookieUnavailable(BookieId id)	Determine if a bookie should be considered unavailable.
boolean	BookieWatcherImpl.isBookieUnavailable(BookieId id)	Determine if a bookie should be considered unavailable.
(package private) void	BatchedReadOp.SequenceReadRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)
(package private) void	PendingReadOp.ParallelReadRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)
(package private) void	PendingReadOp.SequenceReadRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)
(package private) void	ReadLastConfirmedAndEntryOp.ParallelReadRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)
(package private) void	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) void	ReadLastConfirmedAndEntryOp.SequenceReadRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)
(package private) void	ReadOpBase.LedgerEntryRequest.logErrorAndReattemptRead(int bookieIndex, BookieId host, String errMsg, int rc)	Log error errMsg and reattempt read from host.
(package private) void	LedgerHandle.notifyWriteFailed(int index, BookieId addr)
protected String	RegionAwareEnsemblePlacementPolicy.parseBookieRegion(BookieId addr)
void	BookieWatcher.quarantineBookie(BookieId bookie)	Quarantine bookie so it will not be preferred to be chosen for new ensembles.
void	BookieWatcherImpl.quarantineBookie(BookieId bookie)	Quarantine bookie so it will not be preferred to be chosen for new ensembles.
void	BookKeeperAdmin.recoverBookieData(BookieId bookieSrc)	Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
(package private) void	LedgerHandle.registerOperationFailureOnBookie(BookieId bookie, long entryId)
void	DefaultEnsemblePlacementPolicy.registerSlowBookie(BookieId bookieSocketAddress, long entryId)
void	EnsemblePlacementPolicy.registerSlowBookie(BookieId bookieSocketAddress, long entryId)	Register a bookie as slow so that it is tried after available and read-only bookies.
void	RackawareEnsemblePlacementPolicyImpl.registerSlowBookie(BookieId bookieSocketAddress, long entryId)
void	ZoneawareEnsemblePlacementPolicyImpl.registerSlowBookie(BookieId bookieSocketAddress, long entryId)
EnsemblePlacementPolicy.PlacementResult<BookieId>	DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	EnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)	Choose a new bookie to replace bookieToReplace.
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
BookieSocketAddress	BookieAddressResolverDisabled.resolve(BookieId bookieId)
BookieSocketAddress	DefaultBookieAddressResolver.resolve(BookieId bookieId)
protected String	TopologyAwareEnsemblePlacementPolicy.resolveNetworkLocation(BookieId addr)
(package private) void	BatchedReadOp.sendReadTo(int bookieIndex, BookieId to, BatchedReadOp.BatchedLedgerEntryRequest entry)
(package private) void	PendingReadOp.sendReadTo(int bookieIndex, BookieId to, PendingReadOp.SingleLedgerEntryRequest entry)
(package private) void	ReadLastConfirmedAndEntryOp.sendReadTo(int bookieIndex, BookieId to, ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest entry)
void	UpdateLedgerOp.updateBookieIdInLedgers(BookieId oldBookieId, BookieId newBookieId, int rate, int maxOutstandingReads, int limit, BookieShell.UpdateLedgerNotifier progressable)	Update the bookie id present in the ledger metadata.
void	PendingAddOp.writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)
void	PendingWriteLacOp.writeLacComplete(int rc, long ledgerId, BookieId addr, Object ctx)

Method parameters in org.apache.bookkeeper.client with type arguments of type BookieId

Modifier and Type	Method	Description
protected Set<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.addDefaultFaultDomainBookies(Set<BookieId> excludeBookies)
protected Set<BookieId>	RackawareEnsemblePlacementPolicyImpl.addDefaultRackBookiesIfMinNumRacksIsEnforced(Set<BookieId> excludeBookies)
default boolean	EnsemblePlacementPolicy.areAckedBookiesAdheringToPlacementPolicy(Set<BookieId> ackedBookies, int writeQuorumSize, int ackQuorumSize)	Returns true if the bookies that have acknowledged a write adhere to the minimum fault domains as defined in the placement policy in use.
boolean	RackawareEnsemblePlacementPolicyImpl.areAckedBookiesAdheringToPlacementPolicy(Set<BookieId> ackedBookies, int writeQuorumSize, int ackQuorumSize)
boolean	ZoneawareEnsemblePlacementPolicyImpl.areAckedBookiesAdheringToPlacementPolicy(Set<BookieId> ackedBookies, int writeQuorumSize, int ackQuorumSize)
void	BookKeeperAdmin.asyncGetLedgersContainBookies(Set<BookieId> bookies, BookkeeperInternalCallbacks.GenericCallback<SortedMap<Long,LedgerMetadata>> callback)
void	BookKeeperAdmin.asyncRecoverBookieData(long lid, Set<BookieId> bookieSrc, boolean dryrun, boolean skipOpenLedgers, AsyncCallback.RecoverCallback callback, Object context)	Recover a specific ledger.
void	BookKeeperAdmin.asyncRecoverBookieData(Set<BookieId> bookieSrc, boolean dryrun, boolean skipOpenLedgers, boolean skipUnrecoverableLedgers, AsyncCallback.RecoverCallback cb, Object context)
void	BookKeeperAdmin.asyncRecoverBookieData(Set<BookieId> bookieSrc, AsyncCallback.RecoverCallback cb, Object context)
(package private) void	BookieInfoReader.availableBookiesChanged(Set<BookieId> updatedBookiesList)
(package private) void	LedgerFragmentReplicator.batchRecoverLedgerFragmentEntry(long startEntryId, long endEntryId, LedgerHandle lh, org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentMcb, Set<BookieId> newBookies, BiConsumer<Long,Long> onReadEntryFailureCallback)
protected Set<Node>	TopologyAwareEnsemblePlacementPolicy.convertBookiesToNodes(Collection<BookieId> bookies)
(package private) static PendingAddOp	PendingAddOp.create(LedgerHandle lh, ClientContext clientCtx, List<BookieId> ensemble, io.netty.buffer.ByteBuf payload, EnumSet<WriteFlag> writeFlags, AsyncCallback.AddCallbackWithLatency cb, Object ctx)
(package private) static Set<Integer>	EnsembleUtils.diffEnsemble(List<BookieId> e1, List<BookieId> e2)
static int	TopologyAwareEnsemblePlacementPolicy.differBetweenBookies(List<BookieId> bookiesA, List<BookieId> bookiesB)
(package private) void	LedgerHandle.ensembleChangeLoop(List<BookieId> origEnsemble, Map<Integer,BookieId> failedBookies)
(package private) void	LedgerHandle.ensembleChangeLoop(List<BookieId> origEnsemble, Map<Integer,BookieId> failedBookies)
(package private) static String	BookKeeperAdmin.formatEnsemble(List<BookieId> ensemble, Set<BookieId> bookiesSrc, char marker)
(package private) static String	BookKeeperAdmin.formatEnsemble(List<BookieId> ensemble, Set<BookieId> bookiesSrc, char marker)
SortedMap<Long,LedgerMetadata>	BookKeeperAdmin.getLedgersContainBookies(Set<BookieId> bookies)
(package private) void	LedgerHandle.handleBookieFailure(Map<Integer,BookieId> failedBookies)
(package private) void	ReadOnlyLedgerHandle.handleBookieFailure(Map<Integer,BookieId> failedBookies)	For a read only ledger handle, this method will only ever be called during recovery, when we are reading forward from LAC and writing back those entries.
void	ITopologyAwareEnsemblePlacementPolicy.handleBookiesThatJoined(Set<BookieId> joinedBookies)	Handle bookies that joined.
void	RackawareEnsemblePlacementPolicy.handleBookiesThatJoined(Set<BookieId> joinedBookies)
void	RegionAwareEnsemblePlacementPolicy.handleBookiesThatJoined(Set<BookieId> joinedBookies)
void	TopologyAwareEnsemblePlacementPolicy.handleBookiesThatJoined(Set<BookieId> joinedBookies)
void	ZoneawareEnsemblePlacementPolicy.handleBookiesThatJoined(Set<BookieId> joinedBookies)
void	ITopologyAwareEnsemblePlacementPolicy.handleBookiesThatLeft(Set<BookieId> leftBookies)	Handle bookies that left.
void	RackawareEnsemblePlacementPolicy.handleBookiesThatLeft(Set<BookieId> leftBookies)
void	RegionAwareEnsemblePlacementPolicy.handleBookiesThatLeft(Set<BookieId> leftBookies)
void	TopologyAwareEnsemblePlacementPolicy.handleBookiesThatLeft(Set<BookieId> leftBookies)
void	ZoneawareEnsemblePlacementPolicy.handleBookiesThatLeft(Set<BookieId> leftBookies)
EnsemblePlacementPolicy.PlacementPolicyAdherence	BookKeeperAdmin.isEnsembleAdheringToPlacementPolicy(List<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.
EnsemblePlacementPolicy.PlacementPolicyAdherence	DefaultEnsemblePlacementPolicy.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)
default EnsemblePlacementPolicy.PlacementPolicyAdherence	EnsemblePlacementPolicy.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)	returns AdherenceLevel if the Ensemble is strictly/softly/fails adhering to placement policy, like in the case of RackawareEnsemblePlacementPolicy, bookies in the writeset are from 'minNumRacksPerWriteQuorum' number of racks.
EnsemblePlacementPolicy.PlacementPolicyAdherence	RackawareEnsemblePlacementPolicyImpl.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)
EnsemblePlacementPolicy.PlacementPolicyAdherence	RegionAwareEnsemblePlacementPolicy.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)
EnsemblePlacementPolicy.PlacementPolicyAdherence	ZoneawareEnsemblePlacementPolicyImpl.isEnsembleAdheringToPlacementPolicy(List<BookieId> ensembleList, int writeQuorumSize, int ackQuorumSize)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int quorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	EnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)	Choose numBookies bookies for ensemble.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate)	Create an ensemble with parent ensemble.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludedBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
LedgerMetadataBuilder	LedgerMetadataBuilder.newEnsembleEntry(long firstEntry, List<BookieId> ensemble)
protected EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsembleInternal(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
void	ITopologyAwareEnsemblePlacementPolicy.onBookieRackChange(List<BookieId> bookieAddressList)	Handle rack change for the bookies.
void	RegionAwareEnsemblePlacementPolicy.onBookieRackChange(List<BookieId> bookieAddressList)
void	TopologyAwareEnsemblePlacementPolicy.onBookieRackChange(List<BookieId> bookieAddressList)
Set<BookieId>	DefaultEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	EnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)	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.
Set<BookieId>	RackawareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	TopologyAwareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
Set<BookieId>	ZoneawareEnsemblePlacementPolicy.onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)
void	BookKeeperAdmin.recoverBookieData(long lid, Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers)
void	BookKeeperAdmin.recoverBookieData(Set<BookieId> bookiesSrc, boolean dryrun, boolean skipOpenLedgers, boolean skipUnrecoverableLedgers)
(package private) void	LedgerFragmentReplicator.recoverLedgerFragmentEntry(Long entryId, LedgerHandle lh, org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentEntryMcb, Set<BookieId> newBookies, BiConsumer<Long,Long> onReadEntryFailureCallback)	This method asynchronously recovers a specific ledger entry by reading the values via the BookKeeper Client (which would read it from the other replicas) and then writing it to the chosen new bookie.
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)	Reorder the read last add confirmed sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
final DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)	Reorder the read sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
final DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
(package private) DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequenceWithRegion(List<BookieId> ensemble, DistributionSchedule.WriteSet writeSet, Map<Integer,String> writeSetWithRegion, BookiesHealthInfo bookiesHealthInfo, boolean regionAware, String myRegion, int remoteNodeInReorderSequence)	This function orders the read sequence with a given region.
BookieId	BookieWatcher.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)	Choose a bookie to replace bookie bookieIdx in existingBookies.
BookieId	BookieWatcher.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)	Choose a bookie to replace bookie bookieIdx in existingBookies.
BookieId	BookieWatcherImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)
BookieId	BookieWatcherImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> existingBookies, int bookieIdx, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	EnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)	Choose a new bookie to replace bookieToReplace.
EnsemblePlacementPolicy.PlacementResult<BookieId>	EnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)	Choose a new bookie to replace bookieToReplace.
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
EnsemblePlacementPolicy.PlacementResult<BookieId>	ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Map<String,byte[]> customMetadata, List<BookieId> currentEnsemble, BookieId bookieToReplace, Set<BookieId> excludeBookies)
(package private) static List<BookieId>	EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher, LedgerMetadata metadata, List<BookieId> oldEnsemble, Map<Integer,BookieId> failedBookies, String logContext)
(package private) static List<BookieId>	EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher, LedgerMetadata metadata, List<BookieId> oldEnsemble, Map<Integer,BookieId> failedBookies, String logContext)
LedgerMetadataBuilder	LedgerMetadataBuilder.replaceEnsembleEntry(long firstEntry, List<BookieId> ensemble)
Map<Integer,BookieId>	BookKeeperAdmin.replaceNotAdheringPlacementPolicyBookie(List<BookieId> ensembleBookiesList, int writeQuorumSize, int ackQuorumSize)
default EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	EnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)	Returns placement result.
default EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	EnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)	Returns placement result.
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicy.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
EnsemblePlacementPolicy.PlacementResult<List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.replaceToAdherePlacementPolicy(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, List<BookieId> currentEnsemble)
(package private) void	LedgerFragmentReplicator.replicate(LedgerHandle lh, LedgerFragment lf, org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentMcb, Set<BookieId> targetBookieAddresses, BiConsumer<Long,Long> onReadEntryFailureCallback)	This method replicate a ledger fragment which is a contiguous portion of a ledger that was stored in an ensemble that included the failed bookie.
(package private) void	LedgerHandle.unsetSuccessAndSendWriteRequest(List<BookieId> ensemble, Set<Integer> bookies)
(package private) void	PendingAddOp.unsetSuccessAndSendWriteRequest(List<BookieId> ensemble, int bookieIndex)
void	DefaultEnsemblePlacementPolicy.updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)
default void	EnsemblePlacementPolicy.updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)	Send the bookie info details.
void	RegionAwareEnsemblePlacementPolicy.updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)
void	TopologyAwareEnsemblePlacementPolicy.updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)

Constructors in org.apache.bookkeeper.client with parameters of type BookieId

Modifier	Constructor	Description
(package private)	ReadContext(int bookieIndex, BookieId to, ReadOpBase.LedgerEntryRequest entry)

Constructor parameters in org.apache.bookkeeper.client with type arguments of type BookieId

Modifier	Constructor	Description
(package private)	BatchedLedgerEntryRequest(List<BookieId> ensemble, long lId, long eId, int maxCount, long maxSize)
(package private)	ForceLedgerOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, CompletableFuture<Void> cb)
(package private)	LedgerEntryRequest(List<BookieId> ensemble, long eId)
(package private)	LedgerMetadataImpl(long ledgerId, int metadataFormatVersion, int ensembleSize, int writeQuorumSize, int ackQuorumSize, LedgerMetadata.State state, Optional<Long> lastEntryId, Optional<Long> length, Map<Long,List<BookieId>> ensembles, Optional<DigestType> digestType, Optional<byte[]> password, long ctime, boolean storeCtime, long cToken, Map<String,byte[]> customMetadata)
(package private)	ParallelReadRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	ParallelReadRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	PendingReadLacOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, PendingReadLacOp.LacCallback cb)
(package private)	PendingWriteLacOp(LedgerHandle lh, ClientContext clientCtx, List<BookieId> ensemble, AsyncCallback.AddLacCallback cb, Object ctx)
(package private)	ReadLACAndEntryRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	ReadLastConfirmedAndEntryOp(LedgerHandle lh, ClientContext clientCtx, List<BookieId> ensemble, ReadLastConfirmedAndEntryOp.LastConfirmedAndEntryCallback cb, long prevEntryId, long timeOutInMillis)
	ReadLastConfirmedOp(BookieClient bookieClient, DistributionSchedule schedule, DigestManager digestManager, long ledgerId, List<BookieId> ensemble, byte[] ledgerKey, ReadLastConfirmedOp.LastConfirmedDataCallback cb)
(package private)	SequenceReadRequest(List<BookieId> ensemble, long lId, long eId, int maxCount, long maxSize)
(package private)	SequenceReadRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	SequenceReadRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb, LedgerHandle lh, LedgerManager ledgerManager, long fragmentStartId, Map<BookieId,BookieId> oldBookie2NewBookie)
(package private)	SingleFragmentCallback(org.apache.zookeeper.AsyncCallback.VoidCallback ledgerFragmentsMcb, LedgerHandle lh, LedgerManager ledgerManager, long fragmentStartId, Map<BookieId,BookieId> oldBookie2NewBookie)
(package private)	SingleLedgerEntryRequest(List<BookieId> ensemble, long lId, long eId)
(package private)	TryReadLastConfirmedOp(LedgerHandle lh, BookieClient bookieClient, List<BookieId> ensemble, ReadLastConfirmedOp.LastConfirmedDataCallback cb, long lac)

Uses of BookieId in org.apache.bookkeeper.client.api

Methods in org.apache.bookkeeper.client.api that return types with arguments of type BookieId

Modifier and Type	Method	Description
NavigableMap<Long,? extends List<BookieId>>	LedgerMetadata.getAllEnsembles()	Returns all the ensembles of this ledger.
List<BookieId>	LedgerMetadata.getEnsembleAt(long entryId)	Returns the ensemble at the given entryId.

Uses of BookieId in org.apache.bookkeeper.discover

Methods in org.apache.bookkeeper.discover that return types with arguments of type BookieId

Modifier and Type	Method	Description
CompletableFuture<Versioned<Set<BookieId>>>	RegistrationClient.getAllBookies()	Get the list of all bookies identifiers.
CompletableFuture<Versioned<Set<BookieId>>>	ZKRegistrationClient.getAllBookies()
CompletableFuture<Versioned<Set<BookieId>>>	RegistrationClient.getReadOnlyBookies()	Get the list of readonly bookie identifiers.
CompletableFuture<Versioned<Set<BookieId>>>	ZKRegistrationClient.getReadOnlyBookies()
CompletableFuture<Versioned<Set<BookieId>>>	RegistrationClient.getWritableBookies()	Get the list of writable bookie identifiers.
CompletableFuture<Versioned<Set<BookieId>>>	ZKRegistrationClient.getWritableBookies()

Methods in org.apache.bookkeeper.discover with parameters of type BookieId

Modifier and Type	Method	Description
(package private) static BookieServiceInfo	ZKRegistrationClient.deserializeBookieServiceInfo(BookieId bookieId, byte[] bookieServiceInfo)
default CompletableFuture<Versioned<BookieServiceInfo>>	RegistrationClient.getBookieServiceInfo(BookieId bookieId)	Get detailed information about the services exposed by a Bookie.
CompletableFuture<Versioned<BookieServiceInfo>>	ZKRegistrationClient.getBookieServiceInfo(BookieId bookieId)
String	ZKRegistrationManager.getCookiePath(BookieId bookieId)	Returns the CookiePath of the bookie in the ZooKeeper.
boolean	RegistrationManager.isBookieRegistered(BookieId bookieId)	Checks if Bookie with the given BookieId is registered as readwrite or readonly bookie.
boolean	ZKRegistrationManager.isBookieRegistered(BookieId bookieId)
Versioned<byte[]>	RegistrationManager.readCookie(BookieId bookieId)	Read the cookie data, which will be used for verifying the integrity of the bookie environment.
Versioned<byte[]>	ZKRegistrationManager.readCookie(BookieId bookieId)
void	RegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo serviceInfo)	Registering the bookie server as bookieId.
void	ZKRegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo bookieServiceInfo)
void	RegistrationManager.removeCookie(BookieId bookieId, Version version)	Remove the cookie data.
void	ZKRegistrationManager.removeCookie(BookieId bookieId, Version version)
void	RegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly)	Unregistering the bookie server as bookieId.
void	ZKRegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly)
void	RegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)	Write the cookie data, which will be used for verifying the integrity of the bookie environment.
void	ZKRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)

Method parameters in org.apache.bookkeeper.discover with type arguments of type BookieId

Modifier and Type	Method	Description
void	ZKRegistrationClient.WatchTask.accept(Versioned<Set<BookieId>> bookieSet, Throwable throwable)
void	RegistrationClient.RegistrationListener.onBookiesChanged(Versioned<Set<BookieId>> bookies)

Uses of BookieId in org.apache.bookkeeper.meta

Methods in org.apache.bookkeeper.meta that return BookieId

Modifier and Type	Method	Description
BookieId	LedgerAuditorManager.getCurrentAuditor()	Return the information regarding the current auditor.
BookieId	NullMetadataBookieDriver.NullLedgerAuditorManager.getCurrentAuditor()
BookieId	ZkLedgerAuditorManager.getCurrentAuditor()

Methods in org.apache.bookkeeper.meta with parameters of type BookieId

Modifier and Type	Method	Description
boolean	NullMetadataBookieDriver.NullRegistrationManager.isBookieRegistered(BookieId bookieId)
Versioned<byte[]>	NullMetadataBookieDriver.NullRegistrationManager.readCookie(BookieId bookieId)
void	NullMetadataBookieDriver.NullRegistrationManager.registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo bookieService)
void	NullMetadataBookieDriver.NullRegistrationManager.removeCookie(BookieId bookieId, Version version)
void	NullMetadataBookieDriver.NullRegistrationManager.unregisterBookie(BookieId bookieId, boolean readOnly)
void	NullMetadataBookieDriver.NullRegistrationManager.writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)

Uses of BookieId in org.apache.bookkeeper.net

Methods in org.apache.bookkeeper.net that return BookieId

Modifier and Type	Method	Description
static BookieId	BookieSocketAddress.createDummyBookieIdForHostname(String hostname)	Utility for Placement Policies that need to create a dummy BookieId that represents a given host.
BookieId	BookieNode.getAddr()
static BookieId	BookieId.parse(String serialized)	Parses the given serialized representation of a BookieId.
BookieId	BookieSocketAddress.toBookieId()	Create a BookieID in legacy format hostname:port.

Methods in org.apache.bookkeeper.net with parameters of type BookieId

Modifier and Type	Method	Description
static boolean	BookieSocketAddress.isDummyBookieIdForHostname(BookieId bookieId)	Tells whether a BookieId may be a dummy id.
static BookieSocketAddress	BookieSocketAddress.resolveLegacyBookieId(BookieId bookieId)	Use legacy resolver to resolve a bookieId.

Constructors in org.apache.bookkeeper.net with parameters of type BookieId

Modifier	Constructor	Description
	BookieNode(BookieId addr, String networkLoc)

Uses of BookieId in org.apache.bookkeeper.proto

Fields in org.apache.bookkeeper.proto declared as BookieId

Modifier and Type	Field	Description
(package private) final BookieId	DefaultPerChannelBookieClientPool.address
(package private) final BookieId	ReadLastConfirmedAndEntryContext.bookie
(package private) final BookieId	BookieNettyServer.bookieId
(package private) final BookieId	PerChannelBookieClient.bookieId

Fields in org.apache.bookkeeper.proto with type parameters of type BookieId

Modifier and Type	Field	Description
(package private) final ConcurrentHashMap<BookieId,PerChannelBookieClientPool>	BookieClientImpl.channels

Methods in org.apache.bookkeeper.proto that return BookieId

Modifier and Type	Method	Description
BookieId	ReadLastConfirmedAndEntryContext.getBookieAddress()
BookieId	BookieAddressResolver.BookieIdNotResolvedException.getBookieId()
BookieId	BookieServer.getBookieId()

Methods in org.apache.bookkeeper.proto that return types with arguments of type BookieId

Modifier and Type	Method	Description
List<BookieId>	BookieClient.getFaultyBookies()	Get the list of bookies which have exhibited more error responses than a configured threshold.
List<BookieId>	BookieClientImpl.getFaultyBookies()

Methods in org.apache.bookkeeper.proto with parameters of type BookieId

Modifier and Type	Method	Description
void	BookieClient.addEntry(BookieId address, long ledgerId, byte[] masterKey, long entryId, io.netty.util.ReferenceCounted toSend, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, int options, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)	Add an entry for ledger ledgerId on the bookie at address address.
void	BookieClientImpl.addEntry(BookieId addr, long ledgerId, byte[] masterKey, long entryId, io.netty.util.ReferenceCounted toSend, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, int options, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)
default void	BookieClient.batchReadEntries(BookieId address, long ledgerId, long startEntryId, int maxCount, long maxSize, BookkeeperInternalCallbacks.BatchedReadEntryCallback cb, Object ctx, int flags)	Batch read entries with a null masterkey, disallowing failfast.
default void	BookieClient.batchReadEntries(BookieId address, long ledgerId, long startEntryId, int maxCount, long maxSize, BookkeeperInternalCallbacks.BatchedReadEntryCallback cb, Object ctx, int flags, byte[] masterKey)	Batch read entries, disallowing failfast.
void	BookieClient.batchReadEntries(BookieId address, long ledgerId, long startEntryId, int maxCount, long maxSize, BookkeeperInternalCallbacks.BatchedReadEntryCallback cb, Object ctx, int flags, byte[] masterKey, boolean allowFastFail)	Batch read entries from bookie at address address.
void	BookieClientImpl.batchReadEntries(BookieId address, long ledgerId, long startEntryId, int maxCount, long maxSize, BookkeeperInternalCallbacks.BatchedReadEntryCallback cb, Object ctx, int flags, byte[] masterKey, boolean allowFastFail)
(package private) static BookieClientImpl.ChannelReadyForAddEntryCallback	BookieClientImpl.ChannelReadyForAddEntryCallback.create(BookieClientImpl bookieClient, io.netty.util.ReferenceCounted toSend, long ledgerId, long entryId, BookieId addr, Object ctx, BookkeeperInternalCallbacks.WriteCallback cb, int options, byte[] masterKey, boolean allowFastFail, EnumSet<WriteFlag> writeFlags)
PerChannelBookieClient	BookieClientImpl.create(BookieId address, PerChannelBookieClientPool pcbcPool, SecurityHandlerFactory shFactory, boolean forceUseV3)
PerChannelBookieClient	PerChannelBookieClientFactory.create(BookieId address, PerChannelBookieClientPool pcbcPool, SecurityHandlerFactory shFactory, boolean forceUseV3)	Create a PerChannelBookieClient to address.
void	BookieClient.forceLedger(BookieId address, long ledgerId, BookkeeperInternalCallbacks.ForceLedgerCallback cb, Object ctx)	Send a force request to the server.
void	BookieClientImpl.forceLedger(BookieId addr, long ledgerId, BookkeeperInternalCallbacks.ForceLedgerCallback cb, Object ctx)
void	BookkeeperInternalCallbacks.ForceLedgerCallback.forceLedgerComplete(int rc, long ledgerId, BookieId addr, Object ctx)
void	BookieClient.getBookieInfo(BookieId address, long requested, BookkeeperInternalCallbacks.GetBookieInfoCallback cb, Object ctx)	Read information about the bookie, from the bookie.
void	BookieClientImpl.getBookieInfo(BookieId addr, long requested, BookkeeperInternalCallbacks.GetBookieInfoCallback cb, Object ctx)
CompletableFuture<AvailabilityOfEntriesOfLedger>	BookieClient.getListOfEntriesOfLedger(BookieId address, long ledgerId)	Makes async request for getting list of entries of ledger from a bookie and returns Future for the result.
CompletableFuture<AvailabilityOfEntriesOfLedger>	BookieClientImpl.getListOfEntriesOfLedger(BookieId address, long ledgerId)
long	BookieClient.getNumPendingRequests(BookieId address, long ledgerId)	Get the number of outstanding requests on the channel used to connect to a bookie at address for a ledger with ledgerId.
long	BookieClientImpl.getNumPendingRequests(BookieId address, long ledgerId)
static boolean	LocalBookiesRegistry.isLocalBookie(BookieId address)
boolean	BookieClient.isWritable(BookieId address, long ledgerId)	Check whether the channel used to write to a bookie channel is writable.
boolean	BookieClientImpl.isWritable(BookieId address, long key)
PerChannelBookieClientPool	BookieClientImpl.lookupClient(BookieId addr)
default void	BookieClient.readEntry(BookieId address, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags)	Read entry with a null masterkey, disallowing failfast.
default void	BookieClient.readEntry(BookieId address, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags, byte[] masterKey)	Read entry, disallowing failfast.
void	BookieClient.readEntry(BookieId address, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags, byte[] masterKey, boolean allowFastFail)	Read an entry from bookie at address address.
void	BookieClientImpl.readEntry(BookieId addr, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags)
void	BookieClientImpl.readEntry(BookieId addr, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags, byte[] masterKey)
void	BookieClientImpl.readEntry(BookieId addr, long ledgerId, long entryId, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx, int flags, byte[] masterKey, boolean allowFastFail)
void	BookieClient.readEntryWaitForLACUpdate(BookieId address, long ledgerId, long entryId, long previousLAC, long timeOutInMillis, boolean piggyBackEntry, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx)	Send a long poll request to bookie, waiting for the last add confirmed to be updated.
void	BookieClientImpl.readEntryWaitForLACUpdate(BookieId addr, long ledgerId, long entryId, long previousLAC, long timeOutInMillis, boolean piggyBackEntry, BookkeeperInternalCallbacks.ReadEntryCallback cb, Object ctx)
void	BookieClient.readLac(BookieId address, long ledgerId, BookkeeperInternalCallbacks.ReadLacCallback cb, Object ctx)	Read the last add confirmed for ledger ledgerId from the bookie at address.
void	BookieClientImpl.readLac(BookieId addr, long ledgerId, BookkeeperInternalCallbacks.ReadLacCallback cb, Object ctx)
(package private) static void	LocalBookiesRegistry.registerLocalBookieAddress(BookieId address)
BookieSocketAddress	BookieAddressResolver.resolve(BookieId bookieId)	Maps a logical address to a network address.
(package private) static void	LocalBookiesRegistry.unregisterLocalBookieAddress(BookieId address)
void	AddCompletion.writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)
void	BookkeeperInternalCallbacks.WriteCallback.writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)
void	WriteEntryProcessor.writeComplete(int rc, long ledgerId, long entryId, BookieId addr, Object ctx)
void	BookieClient.writeLac(BookieId address, long ledgerId, byte[] masterKey, long lac, ByteBufList toSend, BookkeeperInternalCallbacks.WriteLacCallback cb, Object ctx)	Explicitly write the last add confirmed for ledger ledgerId to the bookie at address.
void	BookieClientImpl.writeLac(BookieId addr, long ledgerId, byte[] masterKey, long lac, ByteBufList toSend, BookkeeperInternalCallbacks.WriteLacCallback cb, Object ctx)
void	BookkeeperInternalCallbacks.WriteLacCallback.writeLacComplete(int rc, long ledgerId, BookieId addr, Object ctx)

Constructors in org.apache.bookkeeper.proto with parameters of type BookieId

Modifier	Constructor	Description
	BookieIdNotResolvedException(BookieId bookieId, Throwable cause)
(package private)	DefaultPerChannelBookieClientPool(ClientConfiguration conf, PerChannelBookieClientFactory factory, BookieId address, int coreSize)
	PerChannelBookieClient(OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId bookieId, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, BookieAddressResolver bookieAddressResolver)
	PerChannelBookieClient(OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId addr, BookieAddressResolver bookieAddressResolver)
	PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.buffer.ByteBufAllocator allocator, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, SecurityHandlerFactory shFactory, BookieAddressResolver bookieAddressResolver)
	PerChannelBookieClient(ClientConfiguration conf, OrderedExecutor executor, io.netty.channel.EventLoopGroup eventLoopGroup, BookieId bookieId, StatsLogger parentStatsLogger, ClientAuthProvider.Factory authProviderFactory, com.google.protobuf.ExtensionRegistry extRegistry, PerChannelBookieClientPool pcbcPool, BookieAddressResolver bookieAddressResolver)
	ReadLastConfirmedAndEntryContext(int bookieIndex, BookieId bookie)

Uses of BookieId in org.apache.bookkeeper.replication

Methods in org.apache.bookkeeper.replication that return BookieId

Modifier and Type	Method	Description
BookieId	AuditorElector.getCurrentAuditor()

Uses of BookieId in org.apache.bookkeeper.tools.cli.commands.cookie

Methods in org.apache.bookkeeper.tools.cli.commands.cookie that return BookieId

Modifier and Type	Method	Description
protected BookieId	CookieCommand.getBookieId(CookieFlagsT cmdFlags)

Uses of BookieId in org.apache.bookkeeper.tools.cli.helpers

Methods in org.apache.bookkeeper.tools.cli.helpers with parameters of type BookieId

Modifier and Type	Method	Description
static String	CommandHelpers.getBookieSocketAddrStringRepresentation(BookieId bookieId, BookieAddressResolver bookieAddressResolver)