Package org.apache.bookkeeper.client

Class DynamicWeightedRandomSelectionImpl<T>

java.lang.Object

org.apache.bookkeeper.client.DynamicWeightedRandomSelectionImpl<T>

All Implemented Interfaces:

WeightedRandomSelection<T>

class DynamicWeightedRandomSelectionImpl<T>
extends Object
implements WeightedRandomSelection<T>

DynamicWeightedRandomSelectionImpl class implements both getNextRandom overloaded methods. Where getNextRandom() method considers all bookies it knows of as candidates, but getNextRandom(Collection selectedNodes) method considers only 'selectedNodes' as candidates.

Nested Class Summary

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

WeightedRandomSelection.WeightedObject

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final org.slf4j.Logger	LOG
(package private) int	maxProbabilityMultiplier
(package private) Random	rand
(package private) final ReadWriteLock	rwLock
(package private) final Map<T,WeightedRandomSelection.WeightedObject>	weightMap

Constructor Summary

Constructors

Constructor	Description
DynamicWeightedRandomSelectionImpl()
DynamicWeightedRandomSelectionImpl(int maxMultiplier)

Method Summary

Modifier and Type	Method	Description
T	getNextRandom()
T	getNextRandom(Collection<T> selectedNodes)
void	setMaxProbabilityMultiplier(int max)
void	updateMap(Map<T,WeightedRandomSelection.WeightedObject> updatedMap)

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

maxProbabilityMultiplier

int maxProbabilityMultiplier

weightMap

final Map<T,WeightedRandomSelection.WeightedObject> weightMap

rwLock

final ReadWriteLock rwLock

rand

Random rand

Constructor Details

DynamicWeightedRandomSelectionImpl

DynamicWeightedRandomSelectionImpl()

DynamicWeightedRandomSelectionImpl

DynamicWeightedRandomSelectionImpl(int maxMultiplier)

Method Details

updateMap

public void updateMap(Map<T,WeightedRandomSelection.WeightedObject> updatedMap)

Specified by:

updateMap in interface WeightedRandomSelection<T>

getNextRandom

public T getNextRandom()

Specified by:

getNextRandom in interface WeightedRandomSelection<T>

getNextRandom

public T getNextRandom(Collection<T> selectedNodes)

Specified by:

getNextRandom in interface WeightedRandomSelection<T>

setMaxProbabilityMultiplier

public void setMaxProbabilityMultiplier(int max)

Specified by:

setMaxProbabilityMultiplier in interface WeightedRandomSelection<T>