protected static class RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble extends Object implements RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble
RoundRobinDistributionSchedule,
which ensures that a write quorum should be covered by at least two racks.| Modifier | Constructor and Description |
|---|---|
protected |
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble(int ensembleSize,
int writeQuorumSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
addBookie(RackawareEnsemblePlacementPolicy.BookieNode node)
Append the new bookie node to the ensemble.
|
boolean |
apply(RackawareEnsemblePlacementPolicy.BookieNode candidate,
RackawareEnsemblePlacementPolicy.Ensemble ensemble) |
ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> |
toList() |
String |
toString() |
protected RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble(int ensembleSize,
int writeQuorumSize)
public boolean apply(RackawareEnsemblePlacementPolicy.BookieNode candidate, RackawareEnsemblePlacementPolicy.Ensemble ensemble)
apply in interface RackawareEnsemblePlacementPolicy.Predicatepublic void addBookie(RackawareEnsemblePlacementPolicy.BookieNode node)
RackawareEnsemblePlacementPolicy.EnsembleaddBookie in interface RackawareEnsemblePlacementPolicy.Ensemblenode - new candidate bookie node.public ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> toList()
toList in interface RackawareEnsemblePlacementPolicy.EnsembleCopyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.