org.infinispan.distribution.ch.impl

Class TopologyAwareSyncConsistentHashFactory

java.lang.Object

org.infinispan.distribution.ch.impl.SyncConsistentHashFactory

org.infinispan.distribution.ch.impl.TopologyAwareSyncConsistentHashFactory

All Implemented Interfaces:

ConsistentHashFactory<DefaultConsistentHash>

public class TopologyAwareSyncConsistentHashFactory
extends SyncConsistentHashFactory

A ConsistentHashFactory implementation that guarantees caches with the same members have the same consistent hash and also tries to distribute segments based on the topology information in TransportConfiguration.

It has a drawback compared to DefaultConsistentHashFactory: it can potentially move a lot more segments during a rebalance than strictly necessary.

It is not recommended using the TopologyAwareSyncConsistentHashFactory with a very small number of segments. The distribution of segments to owners gets better with a higher number of segments, and is especially bad when numSegments < numNodes

Since:

5.2

Author:

Dan Berindei

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TopologyAwareSyncConsistentHashFactory.Builder
static class	TopologyAwareSyncConsistentHashFactory.Externalizer

Field Summary

Fields inherited from class org.infinispan.distribution.ch.impl.SyncConsistentHashFactory

OWNED_SEGMENTS_ALLOWED_VARIATION, PRIMARY_SEGMENTS_ALLOWED_VARIATION

Constructor Summary

Constructors

Constructor and Description
TopologyAwareSyncConsistentHashFactory()

Method Summary

Modifier and Type	Method and Description
protected TopologyAwareSyncConsistentHashFactory.Builder	createBuilder(int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)

Methods inherited from class org.infinispan.distribution.ch.impl.SyncConsistentHashFactory

create, equals, fromPersistentState, hashCode, rebalance, union, updateMembers

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 Detail

TopologyAwareSyncConsistentHashFactory

public TopologyAwareSyncConsistentHashFactory()

Method Detail

createBuilder

protected TopologyAwareSyncConsistentHashFactory.Builder createBuilder(int numOwners,
                                                                       int numSegments,
                                                                       List<Address> members,
                                                                       Map<Address,Float> capacityFactors)