| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RackawareEnsemblePlacementPolicy
A placement policy implementation use rack information for placing ensembles.
|
class |
RegionAwareEnsemblePlacementPolicy
A placement policy use region information in the network topology for placing ensembles.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) RackawareEnsemblePlacementPolicyImpl |
RackawareEnsemblePlacementPolicy.slave |
| Modifier and Type | Method and Description |
|---|---|
RackawareEnsemblePlacementPolicyImpl |
RackawareEnsemblePlacementPolicyImpl.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer timer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
protected RackawareEnsemblePlacementPolicyImpl |
RackawareEnsemblePlacementPolicyImpl.initialize(org.apache.bookkeeper.net.DNSToSwitchMapping dnsResolver,
io.netty.util.HashedWheelTimer timer,
boolean reorderReadsRandom,
int stabilizePeriodSeconds,
int reorderThresholdPendingRequests,
boolean isWeighted,
int maxWeightMultiple,
int minNumRacksPerWriteQuorum,
boolean enforceMinNumRacksPerWriteQuorum,
boolean ignoreLocalNodeInPlacementPolicy,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver)
Initialize the policy.
|
RackawareEnsemblePlacementPolicyImpl |
RackawareEnsemblePlacementPolicyImpl.withDefaultRack(java.lang.String rack) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.