Uses of Interface
org.apache.bookkeeper.client.DistributionSchedule.WriteSet
Packages that use DistributionSchedule.WriteSet
Package
Description
Provides a Bookie server that stores entries for clients.
BookKeeper Client.
-
Uses of DistributionSchedule.WriteSet in org.apache.bookkeeper.bookie
Methods in org.apache.bookkeeper.bookie that return DistributionSchedule.WriteSetModifier and TypeMethodDescriptionLocalBookieEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) LocalBookieEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Methods in org.apache.bookkeeper.bookie with parameters of type DistributionSchedule.WriteSetModifier and TypeMethodDescriptionLocalBookieEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) LocalBookieEnsemblePlacementPolicy.reorderReadSequence(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.WriteSetModifier and TypeFieldDescriptionstatic final DistributionSchedule.WriteSetDistributionSchedule.NULL_WRITE_SET(package private) final DistributionSchedule.WriteSetReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.orderedEnsemble(package private) final DistributionSchedule.WriteSetReadLastConfirmedAndEntryOp.ReadLACAndEntryRequest.writeSet(package private) final DistributionSchedule.WriteSetReadOpBase.LedgerEntryRequest.writeSetMethods in org.apache.bookkeeper.client that return DistributionSchedule.WriteSetModifier and TypeMethodDescriptionDistributionSchedule.WriteSet.copy()Make a deep copy of this write set.DistributionSchedule.getEnsembleSet(long entryId) Return the set of bookies indices to send the messages to the whole ensemble.RoundRobinDistributionSchedule.getEnsembleSet(long entryId) DistributionSchedule.getWriteSet(long entryId) Return the set of bookie indices to send the message to.RoundRobinDistributionSchedule.getWriteSet(long entryId) (package private) DistributionSchedule.WriteSetLedgerHandle.getWriteSetForReadOperation(long entryId) Return aDistributionSchedule.WriteSetsuitable for reading a particular entry.DefaultEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) EnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read last add confirmed sequence of a given write quorum writeSet.RackawareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RegionAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) TopologyAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) ZoneawareEnsemblePlacementPolicyImpl.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) DefaultEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) EnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read sequence of a given write quorum writeSet.RackawareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RackawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RegionAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) TopologyAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) ZoneawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) (package private) DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl.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.(package private) static DistributionSchedule.WriteSetRoundRobinDistributionSchedule.writeSetFromValues(Integer... values) Methods in org.apache.bookkeeper.client with parameters of type DistributionSchedule.WriteSetModifier and TypeMethodDescriptionDefaultEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) EnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read last add confirmed sequence of a given write quorum writeSet.RackawareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RegionAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) TopologyAwareEnsemblePlacementPolicy.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) ZoneawareEnsemblePlacementPolicyImpl.reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) DefaultEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) EnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) Reorder the read sequence of a given write quorum writeSet.RackawareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RackawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) RegionAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) TopologyAwareEnsemblePlacementPolicy.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) ZoneawareEnsemblePlacementPolicyImpl.reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet) (package private) DistributionSchedule.WriteSetRackawareEnsemblePlacementPolicyImpl.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.(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)