| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<org.apache.bookkeeper.net.BookieId> |
BookieWatcherImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata) |
java.util.List<org.apache.bookkeeper.net.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.
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RegionAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludedBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
ZoneawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
DefaultEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int quorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
EnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies)
Choose numBookies bookies for ensemble.
|
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RackawareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
ZoneawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RackawareEnsemblePlacementPolicyImpl.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate) |
EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
ITopologyAwareEnsemblePlacementPolicy.newEnsemble(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<T> parentPredicate)
Create an ensemble with parent ensemble.
|
protected EnsemblePlacementPolicy.PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieId>> |
RackawareEnsemblePlacementPolicyImpl.newEnsembleInternal(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> parentEnsemble,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> parentPredicate) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
RackawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
RegionAwareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
ZoneawareEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
ZoneawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
DefaultEnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
EnsemblePlacementPolicy.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies)
Choose a new bookie to replace bookieToReplace.
|
EnsemblePlacementPolicy.PlacementResult<org.apache.bookkeeper.net.BookieId> |
RackawareEnsemblePlacementPolicyImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> currentEnsemble,
org.apache.bookkeeper.net.BookieId bookieToReplace,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
org.apache.bookkeeper.net.BookieId |
BookieWatcherImpl.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> existingBookies,
int bookieIdx,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies) |
org.apache.bookkeeper.net.BookieId |
BookieWatcher.replaceBookie(int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.List<org.apache.bookkeeper.net.BookieId> existingBookies,
int bookieIdx,
java.util.Set<org.apache.bookkeeper.net.BookieId> excludeBookies)
Choose a bookie to replace bookie bookieIdx in existingBookies.
|
(package private) static java.util.List<org.apache.bookkeeper.net.BookieId> |
EnsembleUtils.replaceBookiesInEnsemble(BookieWatcher bookieWatcher,
LedgerMetadata metadata,
java.util.List<org.apache.bookkeeper.net.BookieId> oldEnsemble,
java.util.Map<java.lang.Integer,org.apache.bookkeeper.net.BookieId> failedBookies,
java.lang.String logContext) |
protected org.apache.bookkeeper.net.BookieNode |
RegionAwareEnsemblePlacementPolicy.replaceFromRack(org.apache.bookkeeper.net.BookieNode bookieNodeToReplace,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean enforceDurability) |
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
T |
ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom)
Select a node from cluster excluding excludeBookies and bookie nodes of
excludeRacks.
|
org.apache.bookkeeper.net.BookieNode |
ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom)
It randomly selects a
BookieNode that is not on the excludeRacks set, excluding the nodes in
excludeBookies set. |
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
org.apache.bookkeeper.net.BookieNode |
ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
T |
ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<T> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<T> ensemble,
boolean fallbackToRandom)
Select a node from a given network location.
|
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
T |
ITopologyAwareEnsemblePlacementPolicy.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom)
Select a node from networkLoc rack excluding excludeBookies.
|
org.apache.bookkeeper.net.BookieNode |
ZoneawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicyImpl.selectFromNetworkLocation(java.lang.String networkLoc,
java.util.Set<java.lang.String> excludeRacks,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble,
boolean fallbackToRandom) |
protected java.util.List<org.apache.bookkeeper.net.BookieNode> |
RackawareEnsemblePlacementPolicyImpl.selectRandom(int numBookies,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble)
Choose a random node from whole cluster.
|
protected org.apache.bookkeeper.net.BookieNode |
RackawareEnsemblePlacementPolicyImpl.selectRandomFromRack(java.lang.String netPath,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble)
Choose random node under a given network path.
|
protected java.util.List<org.apache.bookkeeper.net.BookieNode> |
RegionAwareEnsemblePlacementPolicy.selectRandomFromRegions(java.util.Set<java.lang.String> availableRegions,
int numBookies,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble) |
protected java.util.List<org.apache.bookkeeper.net.BookieNode> |
RackawareEnsemblePlacementPolicyImpl.selectRandomInternal(java.util.List<org.apache.bookkeeper.net.BookieNode> bookiesToSelectFrom,
int numBookies,
java.util.Set<org.apache.bookkeeper.net.Node> excludeBookies,
ITopologyAwareEnsemblePlacementPolicy.Predicate<org.apache.bookkeeper.net.BookieNode> predicate,
ITopologyAwareEnsemblePlacementPolicy.Ensemble<org.apache.bookkeeper.net.BookieNode> ensemble) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.