Uses of Interface
org.apache.bookkeeper.client.DistributionSchedule.WriteSet

Packages that use DistributionSchedule.WriteSet

Package	Description
org.apache.bookkeeper.client	BookKeeper Client.

Uses of DistributionSchedule.WriteSet in org.apache.bookkeeper.client

Fields in org.apache.bookkeeper.client declared as DistributionSchedule.WriteSet

Modifier and Type	Field and Description
static DistributionSchedule.WriteSet	DistributionSchedule.NULL_WRITE_SET
(package private) DistributionSchedule.WriteSet	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.orderedEnsemble
(package private) DistributionSchedule.WriteSet	PendingReadOp.LedgerEntryRequest.writeSet
(package private) DistributionSchedule.WriteSet	ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.writeSet

Methods in org.apache.bookkeeper.client that return DistributionSchedule.WriteSet

Modifier and Type	Method and Description
DistributionSchedule.WriteSet	DistributionSchedule.WriteSet.copy() Make a deep copy of this write set.
DistributionSchedule.WriteSet	RoundRobinDistributionSchedule.getEnsembleSet(long entryId)
DistributionSchedule.WriteSet	DistributionSchedule.getEnsembleSet(long entryId) Return the set of bookies indices to send the messages to the whole ensemble.
DistributionSchedule.WriteSet	RoundRobinDistributionSchedule.getWriteSet(long entryId)
DistributionSchedule.WriteSet	DistributionSchedule.getWriteSet(long entryId) Return the set of bookie indices to send the message to.
(package private) DistributionSchedule.WriteSet	LedgerHandle.getWriteSetForReadOperation(long entryId) Return a DistributionSchedule.WriteSet suitable for reading a particular entry.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read last add confirmed sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
(package private) DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequenceWithRegion(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, DistributionSchedule.WriteSet writeSet, java.util.Map<java.lang.Integer,java.lang.String> writeSetWithRegion, BookiesHealthInfo bookiesHealthInfo, boolean regionAware, java.lang.String myRegion, int remoteNodeInReorderSequence) This function orders the read sequence with a given region.
(package private) static DistributionSchedule.WriteSet	RoundRobinDistributionSchedule.writeSetFromValues(java.lang.Integer... values)

Methods in org.apache.bookkeeper.client with parameters of type DistributionSchedule.WriteSet

Modifier and Type	Method and Description
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadLACSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read last add confirmed sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	RegionAwareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	TopologyAwareEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	ZoneawareEnsemblePlacementPolicyImpl.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	DefaultEnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet	EnsemblePlacementPolicy.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequence(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
(package private) DistributionSchedule.WriteSet	RackawareEnsemblePlacementPolicyImpl.reorderReadSequenceWithRegion(java.util.List<org.apache.bookkeeper.net.BookieId> ensemble, DistributionSchedule.WriteSet writeSet, java.util.Map<java.lang.Integer,java.lang.String> writeSetWithRegion, BookiesHealthInfo bookiesHealthInfo, boolean regionAware, java.lang.String myRegion, int remoteNodeInReorderSequence) This function orders the read sequence with a given region.
(package private) static void	TopologyAwareEnsemblePlacementPolicy.shuffleWithMask(DistributionSchedule.WriteSet writeSet, int mask, int bits) Shuffle all the entries of an array that matches a mask.
protected boolean	LedgerHandle.waitForWritable(DistributionSchedule.WriteSet writeSet, int allowedNonWritableCount, long durationMs)