Uses of Interface
org.apache.bookkeeper.client.DistributionSchedule.WriteSet
-
Packages that use DistributionSchedule.WriteSet Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.client BookKeeper Client. -
-
Uses of DistributionSchedule.WriteSet in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie that return DistributionSchedule.WriteSet Modifier and Type Method Description DistributionSchedule.WriteSet
LocalBookieEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
LocalBookieEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
Methods in org.apache.bookkeeper.bookie with parameters of type DistributionSchedule.WriteSet Modifier and Type Method Description DistributionSchedule.WriteSet
LocalBookieEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
LocalBookieEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
-
Uses of DistributionSchedule.WriteSet in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as DistributionSchedule.WriteSet Modifier and Type Field Description static DistributionSchedule.WriteSet
DistributionSchedule. NULL_WRITE_SET
(package private) DistributionSchedule.WriteSet
ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest. orderedEnsemble
(package private) DistributionSchedule.WriteSet
ReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest. writeSet
(package private) DistributionSchedule.WriteSet
ReadOpBase.LedgerEntryRequest. writeSet
Methods in org.apache.bookkeeper.client that return DistributionSchedule.WriteSet Modifier and Type Method Description DistributionSchedule.WriteSet
DistributionSchedule.WriteSet. copy()
Make a deep copy of this write set.DistributionSchedule.WriteSet
DistributionSchedule. getEnsembleSet(long entryId)
Return the set of bookies indices to send the messages to the whole ensemble.DistributionSchedule.WriteSet
RoundRobinDistributionSchedule. getEnsembleSet(long entryId)
DistributionSchedule.WriteSet
DistributionSchedule. getWriteSet(long entryId)
Return the set of bookie indices to send the message to.DistributionSchedule.WriteSet
RoundRobinDistributionSchedule. getWriteSet(long entryId)
(package private) DistributionSchedule.WriteSet
LedgerHandle. getWriteSetForReadOperation(long entryId)
Return aDistributionSchedule.WriteSet
suitable for reading a particular entry.DistributionSchedule.WriteSet
DefaultEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
EnsemblePlacementPolicy. reorderReadLACSequence(java.util.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(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RegionAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
TopologyAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
ZoneawareEnsemblePlacementPolicyImpl. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
DefaultEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
EnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
Reorder the read sequence of a given write quorum writeSet.DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RegionAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
TopologyAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
ZoneawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
(package private) DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicyImpl. reorderReadSequenceWithRegion(java.util.List<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 Description DistributionSchedule.WriteSet
DefaultEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
EnsemblePlacementPolicy. reorderReadLACSequence(java.util.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(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RegionAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
TopologyAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
ZoneawareEnsemblePlacementPolicyImpl. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
DefaultEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
EnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
Reorder the read sequence of a given write quorum writeSet.DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
RegionAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
TopologyAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
DistributionSchedule.WriteSet
ZoneawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)
(package private) DistributionSchedule.WriteSet
RackawareEnsemblePlacementPolicyImpl. reorderReadSequenceWithRegion(java.util.List<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)
-