Class TopologyAwareSyncConsistentHashFactory

java.lang.Object

org.infinispan.distribution.ch.impl.SyncConsistentHashFactory

org.infinispan.distribution.ch.impl.TopologyAwareSyncConsistentHashFactory

All Implemented Interfaces:

ConsistentHashFactory<DefaultConsistentHash>

@ProtoTypeId(1234)
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	Description
protected static class	TopologyAwareSyncConsistentHashFactory.Builder

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TopologyAwareSyncConsistentHashFactory()

Method Summary

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

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

create, fromPersistentState, rebalance, union, updateMembers

Methods inherited from class java.lang.Object

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

Constructor Details

TopologyAwareSyncConsistentHashFactory

protected TopologyAwareSyncConsistentHashFactory()

Method Details

getInstance

@ProtoFactory
public static TopologyAwareSyncConsistentHashFactory getInstance()

createBuilder

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