java.util.List<BookieId> |
BookieWatcher.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata) |
Create an ensemble with given ensembleSize and writeQuorumSize.
|
java.util.List<BookieId> |
BookieWatcherImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata) |
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int quorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
EnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
Choose numBookies bookies for ensemble.
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
ITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate) |
Create an ensemble with parent ensemble.
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
|
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.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
|
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>> |
RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludedBookies) |
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
ZoneawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<BookieId>> |
ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<BookieId> excludeBookies) |
|
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) |
|
BookieId |
BookieWatcher.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> existingBookies,
int bookieIdx,
java.util.Set<BookieId> excludeBookies) |
Choose a bookie to replace bookie bookieIdx in existingBookies.
|
BookieId |
BookieWatcherImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> existingBookies,
int bookieIdx,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
EnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
Choose a new bookie to replace bookieToReplace.
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
EnsemblePlacementPolicy.PlacementResult<BookieId> |
ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<BookieId> currentEnsemble,
BookieId bookieToReplace,
java.util.Set<BookieId> excludeBookies) |
|
(package private) static java.util.List<BookieId> |
EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher,
LedgerMetadata metadata,
java.util.List<BookieId> oldEnsemble,
java.util.Map<java.lang.Integer,BookieId> failedBookies,
java.lang.String logContext) |
|
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<Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<T> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> ensemble,
boolean fallbackToRandom) |
Select a node from a given network location.
|
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<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<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 |
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.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 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> |
RackawareEnsemblePlacementPolicyImpl.selectRandomInternal(java.util.List<BookieNode> bookiesToSelectFrom,
int numBookies,
java.util.Set<Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<BookieNode> ensemble) |
|