Uses of Class
org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl
-
Packages that use RackawareEnsemblePlacementPolicyImpl Package Description org.apache.bookkeeper.client BookKeeper Client. -
-
Uses of RackawareEnsemblePlacementPolicyImpl in org.apache.bookkeeper.client
Subclasses of RackawareEnsemblePlacementPolicyImpl in org.apache.bookkeeper.client Modifier and Type Class 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.Fields in org.apache.bookkeeper.client declared as RackawareEnsemblePlacementPolicyImpl Modifier and Type Field Description (package private) RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicy. slave
Methods in org.apache.bookkeeper.client that return RackawareEnsemblePlacementPolicyImpl Modifier and Type Method Description RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(ClientConfiguration conf, java.util.Optional<DNSToSwitchMapping> optionalDnsResolver, io.netty.util.HashedWheelTimer timer, FeatureProvider featureProvider, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, boolean useHostnameResolveLocalNodePlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.protected RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. initialize(DNSToSwitchMapping dnsResolver, io.netty.util.HashedWheelTimer timer, boolean reorderReadsRandom, int stabilizePeriodSeconds, int reorderThresholdPendingRequests, boolean isWeighted, int maxWeightMultiple, int minNumRacksPerWriteQuorum, boolean enforceMinNumRacksPerWriteQuorum, boolean ignoreLocalNodeInPlacementPolicy, StatsLogger statsLogger, BookieAddressResolver bookieAddressResolver)
Initialize the policy.RackawareEnsemblePlacementPolicyImpl
RackawareEnsemblePlacementPolicyImpl. withDefaultRack(java.lang.String rack)
-