Uses of Interface
org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Predicate
Packages that use ITopologyAwareEnsemblePlacementPolicy.Predicate
-
Uses of ITopologyAwareEnsemblePlacementPolicy.Predicate in org.apache.bookkeeper.client
Classes in org.apache.bookkeeper.client that implement ITopologyAwareEnsemblePlacementPolicy.PredicateModifier and TypeClassDescriptionprotected static classA predicate checking the rack coverage for write quorum inRoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.protected static classFields in org.apache.bookkeeper.client declared as ITopologyAwareEnsemblePlacementPolicy.PredicateModifier and TypeFieldDescription(package private) final ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.parentPredicateMethods in org.apache.bookkeeper.client with parameters of type ITopologyAwareEnsemblePlacementPolicy.PredicateModifier and TypeMethodDescriptionITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate) Create an ensemble with parent ensemble.RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate) RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate) 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) protected BookieNodeRegionAwareEnsemblePlacementPolicy.replaceFromRack(BookieNode bookieNodeToReplace, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean enforceDurability) ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(String networkLoc, Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) Select a node from networkLoc rack excluding excludeBookies.ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(String networkLoc, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> ensemble, boolean fallbackToRandom) Select a node from a given network location.ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) Select a node from cluster excluding excludeBookies and bookie nodes of excludeRacks.RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(String networkLoc, Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(String networkLoc, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(String networkLoc, Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(String networkLoc, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) It randomly selects aBookieNodethat is not on the excludeRacks set, excluding the nodes in excludeBookies set.ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(String networkLoc, Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(String networkLoc, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(Set<String> excludeRacks, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom) protected List<BookieNode>RackawareEnsemblePlacementPolicyImpl.selectRandom(int numBookies, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble) Choose a random node from whole cluster.protected BookieNodeRackawareEnsemblePlacementPolicyImpl.selectRandomFromRack(String netPath, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble) Choose random node under a given network path.protected List<BookieNode>RegionAwareEnsemblePlacementPolicy.selectRandomFromRegions(Set<String> availableRegions, int numBookies, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble) protected List<BookieNode>RackawareEnsemblePlacementPolicyImpl.selectRandomInternal(List<BookieNode> bookiesToSelectFrom, int numBookies, Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble) Constructors in org.apache.bookkeeper.client with parameters of type ITopologyAwareEnsemblePlacementPolicy.PredicateModifierConstructorDescriptionprotectedRRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, int minNumRacksPerWriteQuorum) protectedRRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, Set<String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)