Uses of Interface
org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy.Predicate

Packages that use ITopologyAwareEnsemblePlacementPolicy.Predicate

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

Uses of ITopologyAwareEnsemblePlacementPolicy.Predicate in org.apache.bookkeeper.client

Classes in org.apache.bookkeeper.client that implement ITopologyAwareEnsemblePlacementPolicy.Predicate

Modifier and Type	Class	Description
protected static class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble	A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.
protected static class	TopologyAwareEnsemblePlacementPolicy.TruePredicate

Fields in org.apache.bookkeeper.client declared as ITopologyAwareEnsemblePlacementPolicy.Predicate

Modifier and Type	Field	Description
(package private) ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode>	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.parentPredicate

Methods in org.apache.bookkeeper.client with parameters of type ITopologyAwareEnsemblePlacementPolicy.Predicate

Modifier and Type	Method	Description
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>>	ITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, java.util.Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate)	Create an ensemble with parent ensemble.
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>>	RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, java.util.Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, java.util.Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>>	ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, java.util.Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
protected EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>>	RackawareEnsemblePlacementPolicyImpl.newEnsembleInternal(int ensembleSize, int writeQuorumSize, int ackQuorumSize, java.util.Set<BookieId> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate)
protected BookieNode	RegionAwareEnsemblePlacementPolicy.replaceFromRack(BookieNode bookieNodeToReplace, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean enforceDurability)
T	ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)	Select a node from networkLoc rack excluding excludeBookies.
T	ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<T> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> ensemble, boolean fallbackToRandom)	Select a node from a given network location.
T	ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks, java.util.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.
BookieNode	RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)	It randomly selects a BookieNode that is not on the excludeRacks set, excluding the nodes in excludeBookies set.
BookieNode	ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
BookieNode	ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble, boolean fallbackToRandom)
protected java.util.List<BookieNode>	RackawareEnsemblePlacementPolicyImpl.selectRandom(int numBookies, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)	Choose a random node from whole cluster.
protected BookieNode	RackawareEnsemblePlacementPolicyImpl.selectRandomFromRack(java.lang.String netPath, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)	Choose random node under a given network path.
protected java.util.List<BookieNode>	RegionAwareEnsemblePlacementPolicy.selectRandomFromRegions(java.util.Set<java.lang.String> availableRegions, int numBookies, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)
protected java.util.List<BookieNode>	RackawareEnsemblePlacementPolicyImpl.selectRandomInternal(java.util.List<BookieNode> bookiesToSelectFrom, int numBookies, java.util.Set<Node> excludeBookies, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble)

Constructors in org.apache.bookkeeper.client with parameters of type ITopologyAwareEnsemblePlacementPolicy.Predicate

Constructor	Description
RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, int minNumRacksPerWriteQuorum)
RRTopologyAwareCoverageEnsemble(int ensembleSize, int writeQuorumSize, int ackQuorumSize, int distanceFromLeaves, ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> parentEnsemble, ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> parentPredicate, java.util.Set<java.lang.String> racksOrRegions, int minRacksOrRegionsForDurability, int minNumRacksPerWriteQuorum)