Package org.apache.bookkeeper.client

Class TopologyAwareEnsemblePlacementPolicy

java.lang.Object

org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy

All Implemented Interfaces:

EnsemblePlacementPolicy, ITopologyAwareEnsemblePlacementPolicy<BookieNode>

Direct Known Subclasses:

RackawareEnsemblePlacementPolicyImpl, ZoneawareEnsemblePlacementPolicyImpl

abstract class TopologyAwareEnsemblePlacementPolicy
extends Object
implements ITopologyAwareEnsemblePlacementPolicy<BookieNode>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TopologyAwareEnsemblePlacementPolicy.DefaultResolver
(package private) static class	TopologyAwareEnsemblePlacementPolicy.DNSResolverDecorator	Decorator for any existing dsn resolver.
protected static class	TopologyAwareEnsemblePlacementPolicy.EnsembleForReplacementWithNoConstraints
protected static class	TopologyAwareEnsemblePlacementPolicy.RRTopologyAwareCoverageEnsemble	A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.
protected static class	TopologyAwareEnsemblePlacementPolicy.TruePredicate

Nested classes/interfaces inherited from interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

EnsemblePlacementPolicy.PlacementPolicyAdherence, EnsemblePlacementPolicy.PlacementResult<T>

Nested classes/interfaces inherited from interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

ITopologyAwareEnsemblePlacementPolicy.Ensemble<T extends Node>, ITopologyAwareEnsemblePlacementPolicy.Predicate<T extends Node>

Field Summary

Fields

Modifier and Type	Field	Description
protected BookieAddressResolver	bookieAddressResolver
protected Map<BookieNode,WeightedRandomSelection.WeightedObject>	bookieInfoMap
protected OpStatsLogger	bookiesJoinedCounter
protected OpStatsLogger	bookiesLeftCounter
protected DNSToSwitchMapping	dnsResolver
protected final Map<BookieId,BookieNode>	historyBookies
(package private) boolean	isWeighted
protected final Map<BookieId,BookieNode>	knownBookies
(package private) static final org.slf4j.Logger	LOG
protected com.google.common.collect.ImmutableSet<BookieId>	readOnlyBookies
static final String	REPP_DNS_RESOLVER_CLASS
protected final ReentrantReadWriteLock	rwLock
protected NetworkTopology	topology
protected WeightedRandomSelection<BookieNode>	weightedSelection

Constructor Summary

Constructors

Constructor	Description
TopologyAwareEnsemblePlacementPolicy()

Method Summary

Modifier and Type	Method	Description
protected Set<Node>	convertBookiesToNodes(Collection<BookieId> bookies)
protected BookieNode	convertBookieToNode(BookieId addr)
protected BookieNode	createBookieNode(BookieId addr)
protected BookieNode	createDummyLocalBookieNode(String hostname)
static int	differBetweenBookies(List<BookieId> bookiesA, List<BookieId> bookiesB)
protected String	getDefaultRack()
(package private) static Set<String>	getNetworkLocations(Set<Node> bookieNodes)
void	handleBookiesThatJoined(Set<BookieId> joinedBookies)	Handle bookies that joined.
void	handleBookiesThatLeft(Set<BookieId> leftBookies)	Handle bookies that left.
void	onBookieRackChange(List<BookieId> bookieAddressList)	Handle rack change for the bookies.
Set<BookieId>	onClusterChanged(Set<BookieId> writableBookies, Set<BookieId> readOnlyBookies)	A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
DistributionSchedule.WriteSet	reorderReadLACSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)	Reorder the read last add confirmed sequence of a given write quorum writeSet.
DistributionSchedule.WriteSet	reorderReadSequence(List<BookieId> ensemble, BookiesHealthInfo bookiesHealthInfo, DistributionSchedule.WriteSet writeSet)	Reorder the read sequence of a given write quorum writeSet.
protected String	resolveNetworkLocation(BookieId addr)
(package private) static void	shuffleWithMask(DistributionSchedule.WriteSet writeSet, int mask, int bits)	Shuffle all the entries of an array that matches a mask.
void	updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)	Send the bookie info details.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

areAckedBookiesAdheringToPlacementPolicy, getStickyReadBookieIndex, initialize, isEnsembleAdheringToPlacementPolicy, newEnsemble, registerSlowBookie, replaceBookie, replaceToAdherePlacementPolicy, uninitalize

Methods inherited from interface org.apache.bookkeeper.client.ITopologyAwareEnsemblePlacementPolicy

newEnsemble, selectFromNetworkLocation, selectFromNetworkLocation, selectFromNetworkLocation

Field Details

LOG

static final org.slf4j.Logger LOG

REPP_DNS_RESOLVER_CLASS

public static final String REPP_DNS_RESOLVER_CLASS

See Also:

• Constant Field Values

knownBookies

protected final Map<BookieId,BookieNode> knownBookies

historyBookies

protected final Map<BookieId,BookieNode> historyBookies

rwLock

protected final ReentrantReadWriteLock rwLock

bookieInfoMap

protected Map<BookieNode,WeightedRandomSelection.WeightedObject> bookieInfoMap

readOnlyBookies

protected com.google.common.collect.ImmutableSet<BookieId> readOnlyBookies

isWeighted

boolean isWeighted

weightedSelection

protected WeightedRandomSelection<BookieNode> weightedSelection

topology

protected NetworkTopology topology

dnsResolver

protected DNSToSwitchMapping dnsResolver

bookieAddressResolver

protected BookieAddressResolver bookieAddressResolver

bookiesJoinedCounter

@StatsDoc(name="BOOKIES_JOINED",
          help="The distribution of number of bookies joined the cluster on each network topology change")
protected OpStatsLogger bookiesJoinedCounter

bookiesLeftCounter

@StatsDoc(name="BOOKIES_LEFT",
          help="The distribution of number of bookies left the cluster on each network topology change")
protected OpStatsLogger bookiesLeftCounter

Constructor Details

TopologyAwareEnsemblePlacementPolicy

TopologyAwareEnsemblePlacementPolicy()

Method Details

getNetworkLocations

static Set<String> getNetworkLocations(Set<Node> bookieNodes)

shuffleWithMask

static void shuffleWithMask(DistributionSchedule.WriteSet writeSet,
 int mask,
 int bits)

Shuffle all the entries of an array that matches a mask. It assumes all entries with the same mask are contiguous in the array.

reorderReadSequence

public DistributionSchedule.WriteSet reorderReadSequence(List<BookieId> ensemble,
 BookiesHealthInfo bookiesHealthInfo,
 DistributionSchedule.WriteSet writeSet)

Description copied from interface: EnsemblePlacementPolicy

Reorder the read sequence of a given write quorum writeSet.

Specified by:

reorderReadSequence in interface EnsemblePlacementPolicy

Parameters:

ensemble - Ensemble to read entries.

bookiesHealthInfo - Health info for bookies

writeSet - Write quorum to read entries. This will be modified, rather than allocating a new WriteSet.

Returns:

The read sequence. This will be the same object as the passed in writeSet.

reorderReadLACSequence

public DistributionSchedule.WriteSet reorderReadLACSequence(List<BookieId> ensemble,
 BookiesHealthInfo bookiesHealthInfo,
 DistributionSchedule.WriteSet writeSet)

Description copied from interface: EnsemblePlacementPolicy

Reorder the read last add confirmed sequence of a given write quorum writeSet.

Specified by:

reorderReadLACSequence in interface EnsemblePlacementPolicy

Parameters:

ensemble - Ensemble to read entries.

bookiesHealthInfo - Health info for bookies

writeSet - Write quorum to read entries. This will be modified, rather than allocating a new WriteSet.

Returns:

The read sequence. This will be the same object as the passed in writeSet.

onClusterChanged

public Set<BookieId> onClusterChanged(Set<BookieId> writableBookies,
 Set<BookieId> readOnlyBookies)

Description copied from interface: EnsemblePlacementPolicy

A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.

The implementation should take actions when the cluster view is changed. So subsequent EnsemblePlacementPolicy.newEnsemble(int, int, int, Map, Set) and EnsemblePlacementPolicy.replaceBookie(int, int, int, java.util.Map, java.util.List, BookieId, java.util.Set) can choose proper bookies.

Specified by:

onClusterChanged in interface EnsemblePlacementPolicy

Parameters:

writableBookies - All the bookies in the cluster available for write/read.

readOnlyBookies - All the bookies in the cluster available for readonly.

Returns:

the dead bookies during this cluster change.

handleBookiesThatLeft

public void handleBookiesThatLeft(Set<BookieId> leftBookies)

Description copied from interface: ITopologyAwareEnsemblePlacementPolicy

Handle bookies that left.

Specified by:

handleBookiesThatLeft in interface ITopologyAwareEnsemblePlacementPolicy<BookieNode>

Parameters:

leftBookies - bookies that left

handleBookiesThatJoined

public void handleBookiesThatJoined(Set<BookieId> joinedBookies)

Description copied from interface: ITopologyAwareEnsemblePlacementPolicy

Handle bookies that joined.

Specified by:

handleBookiesThatJoined in interface ITopologyAwareEnsemblePlacementPolicy<BookieNode>

Parameters:

joinedBookies - bookies that joined.

onBookieRackChange

public void onBookieRackChange(List<BookieId> bookieAddressList)

Description copied from interface: ITopologyAwareEnsemblePlacementPolicy

Handle rack change for the bookies.

Specified by:

onBookieRackChange in interface ITopologyAwareEnsemblePlacementPolicy<BookieNode>

differBetweenBookies

public static int differBetweenBookies(List<BookieId> bookiesA,
 List<BookieId> bookiesB)

updateBookieInfo

public void updateBookieInfo(Map<BookieId,BookieInfoReader.BookieInfo> bookieInfoMap)

Description copied from interface: EnsemblePlacementPolicy

Send the bookie info details.

Specified by:

updateBookieInfo in interface EnsemblePlacementPolicy

Parameters:

bookieInfoMap - A map that has the bookie to BookieInfo

createBookieNode

protected BookieNode createBookieNode(BookieId addr)

createDummyLocalBookieNode

protected BookieNode createDummyLocalBookieNode(String hostname)

resolveNetworkLocation

protected String resolveNetworkLocation(BookieId addr)

getDefaultRack

protected String getDefaultRack()

convertBookiesToNodes

protected Set<Node> convertBookiesToNodes(Collection<BookieId> bookies)

convertBookieToNode

protected BookieNode convertBookieToNode(BookieId addr)