boolean |
TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble.apply(BookieNode candidate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> 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>> |
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>> |
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) |
|
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 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) |
|
void |
RackChangeNotifier.registerRackChangeListener(ITopologyAwareEnsemblePlacementPolicy<BookieNode> rackawarePolicy) |
Register a listener for the rack-aware placement policy.
|
protected BookieNode |
RegionAwareEnsemblePlacementPolicy.replaceFromRack(BookieNode bookieNodeToReplace,
java.util.Set<Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble,
boolean enforceDurability) |
|
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<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.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.
|
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<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.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 |
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<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.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 |
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<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.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) |
|
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 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 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> |
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) |
|
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) |
|
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) |
|