Package org.infinispan.distribution.ch.impl

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 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, float[] capacityFactors)
protected	AbstractConsistentHash(int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
protected	AbstractConsistentHash(ScopedPersistentState state)

Method Summary

Modifier and Type	Method	Description
protected void	checkSameHashAndSegments(AbstractConsistentHash dch2)
Map<Address,Float>	getCapacityFactors()	The capacity factor of each member.
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 float[]	parseCapacityFactors(ScopedPersistentState state)
protected static Hash	parseHashFunction(ScopedPersistentState state)
protected static List<Address>	parseMembers(ScopedPersistentState state)
protected static int	parseNumSegments(ScopedPersistentState state)
protected Map<Address,Float>	remapCapacityFactors(UnaryOperator<Address> remapper, boolean allowMissing)
protected List<Address>	remapMembers(UnaryOperator<Address> remapper, boolean allowMissing)
void	toScopedState(ScopedPersistentState state)	Writes this ConsistentHash to the specified scoped state.
protected Map<Address,Float>	unionCapacityFactors(AbstractConsistentHash ch2)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.distribution.ch.ConsistentHash

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

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 float[] capacityFactors

Constructor Details

AbstractConsistentHash

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

AbstractConsistentHash

protected AbstractConsistentHash(int numSegments,
 List<Address> members,
 float[] capacityFactors)

AbstractConsistentHash

protected AbstractConsistentHash(ScopedPersistentState state)

Method Details

parseNumSegments

protected static int parseNumSegments(ScopedPersistentState state)

parseMembers

protected static List<Address> parseMembers(ScopedPersistentState state)

parseHashFunction

protected static Hash parseHashFunction(ScopedPersistentState state)

parseCapacityFactors

protected static float[] parseCapacityFactors(ScopedPersistentState state)

toScopedState

public void toScopedState(ScopedPersistentState state)

Description copied from interface: ConsistentHash

Writes this ConsistentHash to the specified scoped state. Before invoking this method, the ConsistentHash addresses will have to be replaced with their corresponding PersistentUUIDs

Specified by:

toScopedState in interface ConsistentHash

Parameters:

state - the state to which this ConsistentHash will be written

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:

set 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

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)

remapCapacityFactors

protected Map<Address,Float> remapCapacityFactors(UnaryOperator<Address> remapper,
 boolean allowMissing)

remapMembers

protected List<Address> remapMembers(UnaryOperator<Address> remapper,
 boolean allowMissing)