Class AbstractConsistentHash

java.lang.Object

org.infinispan.distribution.ch.impl.AbstractConsistentHash

All Implemented Interfaces:

ConsistentHash

Direct Known Subclasses:

DefaultConsistentHash

public abstract class AbstractConsistentHash
extends Object
implements ConsistentHash

Author:

Radim Vansa <rvansa@redhat.com>

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<Float>	capacityFactors
protected final List<Address>	members	The membership of the cache topology that uses this CH.
protected static final String	STATE_CAPACITY_FACTOR
protected static final String	STATE_CAPACITY_FACTORS
protected static final String	STATE_NUM_SEGMENTS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractConsistentHash(int numSegments, List<Address> members, List<Float> capacityFactors)
protected	AbstractConsistentHash(int numSegments, List<Address> members, Map<Address,Float> capacityFactors)

Method Summary

Modifier and Type	Method	Description
protected void	checkSameHashAndSegments(AbstractConsistentHash dch2)
Map<Address,Float>	getCapacityFactors()	The capacity factor of each member.
static HashMap<Address,Integer>	getMemberIndexMap(List<Address> members)
List<Address>	getMembers()	Should return the addresses of the nodes used to create this consistent hash.
protected static void	mergeLists(List<Address> dest, List<Address> src)	Adds all elements from src list that do not already exist in dest list to the latter.
protected static org.infinispan.distribution.ch.impl.PersistedMembers	parseMembers(ScopedPersistentState state, Function<UUID,Address> addressMapper)
protected static int	parseNumSegments(ScopedPersistentState state)
void	toScopedState(ScopedPersistentState state, Function<Address,UUID> addressMapper)	Writes this ConsistentHash to the specified scoped persistent state.
protected Map<Address,Float>	unionCapacityFactors(AbstractConsistentHash ch2)
protected static void	writeAddressToState(ScopedPersistentState state, List<Address> members, String sizeKey, String memberKeyFormat, Function<Address,UUID> addressMapper)

Methods inherited from class Object

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

Methods inherited from interface ConsistentHash

getNumSegments, getPrimarySegmentsForOwner, getRoutingTableAsString, getSegmentsForOwner, isReplicated, isSegmentLocalToNode, locateOwnersForSegment, locatePrimaryOwnerForSegment

Field Details

STATE_CAPACITY_FACTOR

protected static final String STATE_CAPACITY_FACTOR

See Also:

• Constant Field Values

STATE_CAPACITY_FACTORS

protected static final String STATE_CAPACITY_FACTORS

See Also:

• Constant Field Values

STATE_NUM_SEGMENTS

protected static final String STATE_NUM_SEGMENTS

See Also:

• Constant Field Values

members

protected final List<Address> members

The membership of the cache topology that uses this CH.

capacityFactors

protected final List<Float> capacityFactors

Constructor Details

AbstractConsistentHash

protected AbstractConsistentHash(int numSegments,
 List<Address> members,
 Map<Address,Float> capacityFactors)

AbstractConsistentHash

protected AbstractConsistentHash(int numSegments,
 List<Address> members,
 List<Float> capacityFactors)

Method Details

parseNumSegments

protected static int parseNumSegments(ScopedPersistentState state)

parseMembers

protected static org.infinispan.distribution.ch.impl.PersistedMembers parseMembers(ScopedPersistentState state,
 Function<UUID,Address> addressMapper)

toScopedState

public void toScopedState(ScopedPersistentState state,
 Function<Address,UUID> addressMapper)

Description copied from interface: ConsistentHash

Writes this ConsistentHash to the specified scoped persistent state.

Specified by:

toScopedState in interface ConsistentHash

Parameters:

state - The state to which this ConsistentHash will be written.

addressMapper - The mapper Function to convert the Address to the UUID used to persist the address within the state.

getMembers

public List<Address> getMembers()

Description copied from interface: ConsistentHash

Should return the addresses of the nodes used to create this consistent hash.

Specified by:

getMembers in interface ConsistentHash

Returns:

list of node addresses.

mergeLists

protected static void mergeLists(List<Address> dest,
 List<Address> src)

Adds all elements from src list that do not already exist in dest list to the latter.

Parameters:

dest - List where elements are added

src - List of elements to add - this is never modified

getMemberIndexMap

public static HashMap<Address,Integer> getMemberIndexMap(List<Address> members)

getCapacityFactors

public Map<Address,Float> getCapacityFactors()

Description copied from interface: ConsistentHash

The capacity factor of each member. Determines the relative capacity of each node compared to the others. If null, all the members are assumed to have a capacity factor of 1.

Specified by:

getCapacityFactors in interface ConsistentHash

unionCapacityFactors

protected Map<Address,Float> unionCapacityFactors(AbstractConsistentHash ch2)

checkSameHashAndSegments

protected void checkSameHashAndSegments(AbstractConsistentHash dch2)

writeAddressToState

protected static void writeAddressToState(ScopedPersistentState state,
 List<Address> members,
 String sizeKey,
 String memberKeyFormat,
 Function<Address,UUID> addressMapper)