public class SyncConsistentHashFactory extends Object implements ConsistentHashFactory<DefaultConsistentHash>
ConsistentHashFactory
implementation that guarantees caches with the same members
have the same consistent hash.
It has a drawback compared to DefaultConsistentHashFactory
, though: it can potentially
move a lot more segments during a rebalance than strictly necessary.Modifier and Type | Class and Description |
---|---|
protected static class |
SyncConsistentHashFactory.Builder |
static class |
SyncConsistentHashFactory.Externalizer |
Constructor and Description |
---|
SyncConsistentHashFactory() |
Modifier and Type | Method and Description |
---|---|
DefaultConsistentHash |
create(Hash hashFunction,
int numOwners,
int numSegments,
List<Address> members,
Map<Address,Float> capacityFactors)
Create a new consistent hash instance.
|
protected int |
normalizedHash(Hash hashFunction,
int hashcode) |
protected void |
populateOwnersFewSegments(SyncConsistentHashFactory.Builder builder,
SortedMap<Integer,Address> primarySegments) |
protected void |
populateOwnersManySegments(SyncConsistentHashFactory.Builder builder,
SortedMap<Integer,Address> primarySegments) |
DefaultConsistentHash |
rebalance(DefaultConsistentHash baseCH)
Create a new consistent hash instance, based on an existing instance, but "balanced" according to
the implementation's rules.
|
DefaultConsistentHash |
union(DefaultConsistentHash ch1,
DefaultConsistentHash ch2)
Creates a union of two compatible ConsistentHashes (use the same hashing function and have the same configuration
parameters).
|
DefaultConsistentHash |
updateMembers(DefaultConsistentHash baseCH,
List<Address> newMembers,
Map<Address,Float> actualCapacityFactors)
Create a new consistent hash instance, based on an existing instance, but with a new list of members.
|
public DefaultConsistentHash create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)
ConsistentHashFactory
create
in interface ConsistentHashFactory<DefaultConsistentHash>
hashFunction
- The hash function to use on top of the keys' own hashCode()
implementation.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.
If null
, all the members are assumed to have a capacity factor of 1.protected void populateOwnersFewSegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
protected int normalizedHash(Hash hashFunction, int hashcode)
protected void populateOwnersManySegments(SyncConsistentHashFactory.Builder builder, SortedMap<Integer,Address> primarySegments)
public DefaultConsistentHash updateMembers(DefaultConsistentHash baseCH, List<Address> newMembers, Map<Address,Float> actualCapacityFactors)
ConsistentHashFactory
updateMembers
in interface ConsistentHashFactory<DefaultConsistentHash>
baseCH
- An existing consistent hash instance, should not be null
newMembers
- 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.
If null
, all the members are assumed to have a capacity factor of 1.ConsistentHash
instance, or baseCH
if the existing instance
does not need any changes.public DefaultConsistentHash rebalance(DefaultConsistentHash baseCH)
ConsistentHashFactory
rebalance(rebalance(ch))
must be equivalent to rebalance(ch)
.rebalance
in interface ConsistentHashFactory<DefaultConsistentHash>
baseCH
- An existing consistent hash instance, should not be null
ConsistentHash
instance, or baseCH
if the existing instance
does not need any changes.public DefaultConsistentHash union(DefaultConsistentHash ch1, DefaultConsistentHash ch2)
ConsistentHashFactory
union
in interface ConsistentHashFactory<DefaultConsistentHash>
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.