Package | Description |
---|---|
org.apache.bookkeeper.client |
Modifier and Type | Method and Description |
---|---|
protected RackawareEnsemblePlacementPolicy.BookieNode |
RackawareEnsemblePlacementPolicy.selectFromRack(String networkLoc,
Set<org.apache.bookkeeper.net.Node> excludeBookies,
RackawareEnsemblePlacementPolicy.Predicate predicate,
RackawareEnsemblePlacementPolicy.Ensemble ensemble) |
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.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
RackawareEnsemblePlacementPolicy.Ensemble.addBookie(RackawareEnsemblePlacementPolicy.BookieNode node)
Append the new bookie node to the ensemble.
|
void |
RackawareEnsemblePlacementPolicy.EnsembleForReplacement.addBookie(RackawareEnsemblePlacementPolicy.BookieNode node) |
void |
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble.addBookie(RackawareEnsemblePlacementPolicy.BookieNode node) |
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 String |
RackawareEnsemblePlacementPolicy.getRemoteRack(RackawareEnsemblePlacementPolicy.BookieNode node) |
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.