org.infinispan.distribution.ch.impl

Class SyncReplicatedConsistentHashFactory

java.lang.Object

org.infinispan.distribution.ch.impl.SyncReplicatedConsistentHashFactory

All Implemented Interfaces:

ConsistentHashFactory<ReplicatedConsistentHash>

public class SyncReplicatedConsistentHashFactory
extends Object
implements ConsistentHashFactory<ReplicatedConsistentHash>

SyncConsistentHashFactory adapted for replicated caches, so that the primary owner of a key is the same in replicated and distributed caches.

Since:

8.2

Author:

Dan Berindei

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SyncReplicatedConsistentHashFactory.Externalizer

Field Summary

Fields

Modifier and Type	Field and Description
static float	OWNED_SEGMENTS_ALLOWED_VARIATION
static float	PRIMARY_SEGMENTS_ALLOWED_VARIATION

Constructor Summary

Constructors

Constructor and Description
SyncReplicatedConsistentHashFactory()

Method Summary

Modifier and Type	Method and Description
ReplicatedConsistentHash	create(Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors) Create a new consistent hash instance.
ReplicatedConsistentHash	rebalance(ReplicatedConsistentHash baseCH) Create a new consistent hash instance, based on an existing instance, but "balanced" according to the implementation's rules.
ReplicatedConsistentHash	union(ReplicatedConsistentHash ch1, ReplicatedConsistentHash ch2) Creates a union of two compatible ConsistentHashes (use the same hashing function and have the same configuration parameters).
ReplicatedConsistentHash	updateMembers(ReplicatedConsistentHash 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.

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.ConsistentHashFactory

fromPersistentState

Field Detail

OWNED_SEGMENTS_ALLOWED_VARIATION

public static final float OWNED_SEGMENTS_ALLOWED_VARIATION

See Also:

Constant Field Values

PRIMARY_SEGMENTS_ALLOWED_VARIATION

public static final float PRIMARY_SEGMENTS_ALLOWED_VARIATION

See Also:

Constant Field Values

Constructor Detail

SyncReplicatedConsistentHashFactory

public SyncReplicatedConsistentHashFactory()

Method Detail

create

public ReplicatedConsistentHash create(Hash hashFunction,
                                       int numOwners,
                                       int numSegments,
                                       List<Address> members,
                                       Map<Address,Float> capacityFactors)

Description copied from interface: ConsistentHashFactory

Create a new consistent hash instance.

Specified by:

create in interface ConsistentHashFactory<ReplicatedConsistentHash>

Parameters:

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.

updateMembers

public ReplicatedConsistentHash updateMembers(ReplicatedConsistentHash baseCH,
                                              List<Address> newMembers,
                                              Map<Address,Float> actualCapacityFactors)

Description copied from interface: ConsistentHashFactory

Create a new consistent hash instance, based on an existing instance, but with a new list of members.

This method will not assign any new owners, so it will not require a state transfer. The only exception is if a segment doesn't have any owners in the new members list - but there isn't anyone to transfer that segment from, so that won't require a state transfer either.

Specified by:

updateMembers in interface ConsistentHashFactory<ReplicatedConsistentHash>

Parameters:

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.

Returns:

A new ConsistentHash instance, or baseCH if the existing instance does not need any changes.

rebalance

public ReplicatedConsistentHash rebalance(ReplicatedConsistentHash baseCH)

Description copied from interface: ConsistentHashFactory

Create a new consistent hash instance, based on an existing instance, but "balanced" according to the implementation's rules.

It must be possible to switch from the "intermediary" consistent hash that includes the old owners to the new consistent hash without any state transfer.

rebalance(rebalance(ch)) must be equivalent to rebalance(ch).

Specified by:

rebalance in interface ConsistentHashFactory<ReplicatedConsistentHash>

Parameters:

baseCH - An existing consistent hash instance, should not be null

Returns:

A new ConsistentHash instance, or baseCH if the existing instance does not need any changes.

union

public ReplicatedConsistentHash union(ReplicatedConsistentHash ch1,
                                      ReplicatedConsistentHash ch2)

Description copied from interface: ConsistentHashFactory

Creates a union of two compatible ConsistentHashes (use the same hashing function and have the same configuration parameters).

Specified by:

union in interface ConsistentHashFactory<ReplicatedConsistentHash>