| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Method and Description |
|---|---|
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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) |
static <T> EnsemblePlacementPolicy.PlacementResult<T> |
EnsemblePlacementPolicy.PlacementResult.of(T result,
EnsemblePlacementPolicy.PlacementPolicyAdherence policyAdherence) |
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> |
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) |
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> |
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> |
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> |
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> |
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) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.