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

Packages that use ITopologyAwareEnsemblePlacementPolicy.Ensemble

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

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

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

Modifier and Type	Class and Description
protected static class	TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
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.

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

Modifier and Type	Field and Description
(package private) ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode>	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.parentEnsemble

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

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

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

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