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.Predicate
public void addBookie(RackawareEnsemblePlacementPolicy.BookieNode node)
RackawareEnsemblePlacementPolicy.Ensemble
addBookie
in interface RackawareEnsemblePlacementPolicy.Ensemble
node
- new candidate bookie node.public ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> toList()
toList
in interface RackawareEnsemblePlacementPolicy.Ensemble
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.