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.WriteSetLocalBookieEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetLocalBookieEnsemblePlacementPolicy. 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.WriteSetLocalBookieEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetLocalBookieEnsemblePlacementPolicy. 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.WriteSetDistributionSchedule. NULL_WRITE_SET(package private) DistributionSchedule.WriteSetReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest. orderedEnsemble(package private) DistributionSchedule.WriteSetReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest. writeSet(package private) DistributionSchedule.WriteSetReadOpBase.LedgerEntryRequest. writeSetMethods in org.apache.bookkeeper.client that return DistributionSchedule.WriteSet Modifier and Type Method Description DistributionSchedule.WriteSetDistributionSchedule.WriteSet. copy()Make a deep copy of this write set.DistributionSchedule.WriteSetDistributionSchedule. getEnsembleSet(long entryId)Return the set of bookies indices to send the messages to the whole ensemble.DistributionSchedule.WriteSetRoundRobinDistributionSchedule. getEnsembleSet(long entryId)DistributionSchedule.WriteSetDistributionSchedule. getWriteSet(long entryId)Return the set of bookie indices to send the message to.DistributionSchedule.WriteSetRoundRobinDistributionSchedule. getWriteSet(long entryId)(package private) DistributionSchedule.WriteSetLedgerHandle. getWriteSetForReadOperation(long entryId)Return aDistributionSchedule.WriteSetsuitable for reading a particular entry.DistributionSchedule.WriteSetDefaultEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetEnsemblePlacementPolicy. 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.WriteSetRackawareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRegionAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetTopologyAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetZoneawareEnsemblePlacementPolicyImpl. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetDefaultEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)Reorder the read sequence of a given write quorum writeSet.DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRegionAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetTopologyAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetZoneawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)(package private) DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl. 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.WriteSetRoundRobinDistributionSchedule. writeSetFromValues(java.lang.Integer... values)Methods in org.apache.bookkeeper.client with parameters of type DistributionSchedule.WriteSet Modifier and Type Method Description DistributionSchedule.WriteSetDefaultEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetEnsemblePlacementPolicy. 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.WriteSetRackawareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRegionAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetTopologyAwareEnsemblePlacementPolicy. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetZoneawareEnsemblePlacementPolicyImpl. reorderReadLACSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetDefaultEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)Reorder the read sequence of a given write quorum writeSet.DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetRegionAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetTopologyAwareEnsemblePlacementPolicy. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)DistributionSchedule.WriteSetZoneawareEnsemblePlacementPolicyImpl. reorderReadSequence(java.util.List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)(package private) DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl. 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 voidTopologyAwareEnsemblePlacementPolicy. shuffleWithMask(DistributionSchedule.WriteSet writeSet, int mask, int bits)Shuffle all the entries of an array that matches a mask.protected booleanLedgerHandle. waitForWritable(DistributionSchedule.WriteSet writeSet, int allowedNonWritableCount, long durationMs)
-