Package | Description |
---|---|
org.apache.bookkeeper.client |
Modifier and Type | Class and Description |
---|---|
protected static class |
RackawareEnsemblePlacementPolicy.EnsembleForReplacement |
protected static class |
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
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. |
Modifier and Type | Method and Description |
---|---|
boolean |
RackawareEnsemblePlacementPolicy.Predicate.apply(RackawareEnsemblePlacementPolicy.BookieNode candidate,
RackawareEnsemblePlacementPolicy.Ensemble chosenBookies) |
boolean |
RackawareEnsemblePlacementPolicy.TruePredicate.apply(RackawareEnsemblePlacementPolicy.BookieNode candidate,
RackawareEnsemblePlacementPolicy.Ensemble chosenNodes) |
boolean |
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble.apply(RackawareEnsemblePlacementPolicy.BookieNode candidate,
RackawareEnsemblePlacementPolicy.Ensemble ensemble) |
protected RackawareEnsemblePlacementPolicy.BookieNode |
RackawareEnsemblePlacementPolicy.selectFromRack(String networkLoc,
Set<org.apache.bookkeeper.net.Node> excludeBookies,
RackawareEnsemblePlacementPolicy.Predicate predicate,
RackawareEnsemblePlacementPolicy.Ensemble ensemble) |
protected List<RackawareEnsemblePlacementPolicy.BookieNode> |
RackawareEnsemblePlacementPolicy.selectRandom(int numBookies,
Set<org.apache.bookkeeper.net.Node> excludeBookies,
RackawareEnsemblePlacementPolicy.Ensemble ensemble)
Choose a random node from whole cluster.
|
protected RackawareEnsemblePlacementPolicy.BookieNode |
RackawareEnsemblePlacementPolicy.selectRandomFromRack(String netPath,
Set<org.apache.bookkeeper.net.Node> excludeBookies,
RackawareEnsemblePlacementPolicy.Predicate predicate,
RackawareEnsemblePlacementPolicy.Ensemble ensemble)
Choose random node under a given network path.
|
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.