Class DefaultConsistentHashFactory
java.lang.Object
org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory<DefaultConsistentHash>
org.infinispan.distribution.ch.impl.DefaultConsistentHashFactory
- All Implemented Interfaces:
ConsistentHashFactory<DefaultConsistentHash>
- Direct Known Subclasses:
TopologyAwareConsistentHashFactory
public class DefaultConsistentHashFactory
extends AbstractConsistentHashFactory<DefaultConsistentHash>
Default implementation of
ConsistentHashFactory
.
All methods except union(DefaultConsistentHash, DefaultConsistentHash)
return a consistent hash
with floor(numOwners*numSegments/numNodes) invalid input: '<'= segments per owner invalid input: '<'= ceil(numOwners*numSegments/numNodes).- Since:
- 5.2
- Author:
- Dan Berindei, anistor@redhat.com
-
Nested Class Summary
Modifier and TypeClassDescriptionprotected static class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected void
Create a new consistent hash instance.protected void
boolean
protected Address
findNewBackupOwner
(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner) Recreates a ConsistentHash from a previously stored persistent state.int
hashCode()
rebalance
(DefaultConsistentHash baseCH) Create a new consistent hash instance, based on an existing instance, but balanced according to the implementation's rules.protected void
protected void
protected void
protected void
replacePrimaryOwners
(DefaultConsistentHashFactory.Builder builder, int maxOwners) protected void
union
(DefaultConsistentHash dch1, DefaultConsistentHash dch2) Merges two consistent hash objects that have the same number of segments, numOwners and hash function.updateMembers
(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address, Float> actualCapacityFactors) Leavers are removed and segments without owners are assigned new owners.Methods inherited from class org.infinispan.distribution.ch.impl.AbstractConsistentHashFactory
checkCapacityFactors, findNewPrimaryOwner, findWorstPrimaryOwner
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.infinispan.distribution.ch.ConsistentHashFactory
create
-
Constructor Details
-
DefaultConsistentHashFactory
public DefaultConsistentHashFactory()
-
-
Method Details
-
create
public DefaultConsistentHash create(int numOwners, int numSegments, List<Address> members, Map<Address, Float> capacityFactors) Description copied from interface:ConsistentHashFactory
Create a new consistent hash instance. The consistent hash will be balanced.- Parameters:
numOwners
- The ideal number of owners for each key. The created consistent hash can have more or less owners, but each key will have at least one owner.numSegments
- Number of hash-space segments. The implementation may round up the number of segments for performance, or may ignore the parameter altogether.members
- A list of addresses representing the new cache members.capacityFactors
- The capacity factor of each member. Determines the relative capacity of each node compared to the others. The implementation may ignore this parameter. Ifnull
, all the members are assumed to have a capacity factor of 1.
-
fromPersistentState
Description copied from interface:ConsistentHashFactory
Recreates a ConsistentHash from a previously stored persistent state. The returned ConsistentHash will not have proper addresses, butPersistentUUID
s instead so they will need to be replaced- Parameters:
state
- the state to restore
-
updateMembers
public DefaultConsistentHash updateMembers(DefaultConsistentHash baseCH, List<Address> actualMembers, Map<Address, Float> actualCapacityFactors) Leavers are removed and segments without owners are assigned new owners. Joiners might get some of the un-owned segments but otherwise they are not taken into account (that should happen during a rebalance).- Parameters:
baseCH
- An existing consistent hash instance, should not benull
actualMembers
- A list of addresses representing the new cache members.actualCapacityFactors
- The capacity factor of each member. Determines the relative capacity of each node compared to the others. The implementation may ignore this parameter. Ifnull
, all the members are assumed to have a capacity factor of 1.- Returns:
-
rebalance
Description copied from interface:ConsistentHashFactory
Create a new consistent hash instance, based on an existing instance, but balanced according to the implementation's rules.- Parameters:
baseCH
- An existing consistent hash instance, should not benull
- Returns:
- A new
ConsistentHash
instance, orbaseCH
if the existing instance does not need any changes.
-
union
Merges two consistent hash objects that have the same number of segments, numOwners and hash function. For each segment, the primary owner of the first CH has priority, the other primary owners become backups. -
rebalanceBuilder
-
addPrimaryOwners
-
replacePrimaryOwners
-
swapPrimaryOwnersWithBackups
-
addBackupOwners
-
removeExtraBackupOwners
-
doAddBackupOwners
-
replaceBackupOwners
-
findNewBackupOwner
protected Address findNewBackupOwner(DefaultConsistentHashFactory.Builder builder, Collection<Address> excludes, Address owner) - Returns:
- The member with the worst owned segments/capacity ratio that is also not in the excludes list.
-
equals
-
hashCode
public int hashCode()
-