| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| org.apache.bookkeeper.conf |
Configurations used by bookkeeper.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ITopologyAwareEnsemblePlacementPolicy<T extends org.apache.bookkeeper.net.Node>
Interface for topology aware ensemble placement policy.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultEnsemblePlacementPolicy
Default Ensemble Placement Policy, which picks bookies randomly.
|
class |
RackawareEnsemblePlacementPolicy
A placement policy implementation use rack information for placing ensembles.
|
class |
RackawareEnsemblePlacementPolicyImpl
Simple rackware ensemble placement policy.
|
class |
RegionAwareEnsemblePlacementPolicy
A placement policy use region information in the network topology for placing ensembles.
|
(package private) class |
TopologyAwareEnsemblePlacementPolicy |
class |
ZoneawareEnsemblePlacementPolicy
A placement policy implementation use zone information for placing ensembles.
|
class |
ZoneawareEnsemblePlacementPolicyImpl
Simple zoneaware ensemble placement policy.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) EnsemblePlacementPolicy |
BookKeeper.placementPolicy |
| Modifier and Type | Method and Description |
|---|---|
EnsemblePlacementPolicy |
ClientContext.getPlacementPolicy() |
(package private) EnsemblePlacementPolicy |
BookKeeper.getPlacementPolicy() |
EnsemblePlacementPolicy |
EnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer hashedWheelTimer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver)
Initialize the policy.
|
EnsemblePlacementPolicy |
DefaultEnsemblePlacementPolicy.initialize(ClientConfiguration conf,
java.util.Optional<org.apache.bookkeeper.net.DNSToSwitchMapping> optionalDnsResolver,
io.netty.util.HashedWheelTimer hashedWheelTimer,
FeatureProvider featureProvider,
org.apache.bookkeeper.stats.StatsLogger statsLogger,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver) |
EnsemblePlacementPolicy |
ZoneawareEnsemblePlacementPolicy.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) |
EnsemblePlacementPolicy |
ZoneawareEnsemblePlacementPolicyImpl.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) |
| Constructor and Description |
|---|
BookieWatcherImpl(ClientConfiguration conf,
EnsemblePlacementPolicy placementPolicy,
org.apache.bookkeeper.discover.RegistrationClient registrationClient,
org.apache.bookkeeper.proto.BookieAddressResolver bookieAddressResolver,
org.apache.bookkeeper.stats.StatsLogger statsLogger) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Class<? extends EnsemblePlacementPolicy> |
ClientConfiguration.getEnsemblePlacementPolicy()
Get Ensemble Placement Policy Class.
|
| Modifier and Type | Method and Description |
|---|---|
ClientConfiguration |
ClientConfiguration.setEnsemblePlacementPolicy(java.lang.Class<? extends EnsemblePlacementPolicy> policyClass)
Set Ensemble Placement Policy Class.
|
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.