Uses of Interface
org.infinispan.distribution.ch.ConsistentHash

Packages that use ConsistentHash

Package	Description
org.infinispan.configuration.cache	Cache configuration
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.distribution.ch	Consistent Hash interfaces
org.infinispan.distribution.ch.impl
org.infinispan.distribution.group.impl
org.infinispan.distribution.impl
org.infinispan.distribution.topologyaware
org.infinispan.distribution.util
org.infinispan.notifications.cachelistener	Cache-specific notifications and eventing.
org.infinispan.notifications.cachelistener.event	Cache-specific listener events
org.infinispan.notifications.cachelistener.event.impl
org.infinispan.partitionhandling.impl
org.infinispan.scattered.impl
org.infinispan.server.hotrod.logging
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.stream.impl
org.infinispan.topology

Uses of ConsistentHash in org.infinispan.configuration.cache

Methods in org.infinispan.configuration.cache that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	HashConfiguration.consistentHash()	Deprecated. Since 5.2, replaced by HashConfiguration.consistentHashFactory().

Methods in org.infinispan.configuration.cache with parameters of type ConsistentHash

Modifier and Type	Method	Description
HashConfigurationBuilder	HashConfigurationBuilder.consistentHash(ConsistentHash consistentHash)	Deprecated. Since 5.2, replaced by HashConfigurationBuilder.consistentHashFactory(ConsistentHashFactory).

Method parameters in org.infinispan.configuration.cache with type arguments of type ConsistentHash

Modifier and Type	Method	Description
HashConfigurationBuilder	HashConfigurationBuilder.consistentHashFactory(ConsistentHashFactory<? extends ConsistentHash> consistentHashFactory)	The consistent hash factory in use.

Uses of ConsistentHash in org.infinispan.distribution

Methods in org.infinispan.distribution that return ConsistentHash

Modifier and Type	Method	Description
default ConsistentHash	DistributionManager.getConsistentHash()	Deprecated. Since 9.0, please use DistributionManager.getWriteConsistentHash() instead.
ConsistentHash	DistributionManager.getReadConsistentHash()
ConsistentHash	DistributionManager.getWriteConsistentHash()

Uses of ConsistentHash in org.infinispan.distribution.ch

Classes in org.infinispan.distribution.ch with type parameters of type ConsistentHash

Modifier and Type	Interface	Description
interface	ConsistentHashFactory<CH extends ConsistentHash>	Factory for ConsistentHash instances.

Methods in org.infinispan.distribution.ch that return ConsistentHash

Modifier and Type	Method	Description
default ConsistentHash	ConsistentHash.remapAddresses(UnaryOperator<Address> remapper)	Returns a new ConsistentHash with the addresses remapped according to the provided UnaryOperator.

Uses of ConsistentHash in org.infinispan.distribution.ch.impl

Classes in org.infinispan.distribution.ch.impl with type parameters of type ConsistentHash

Modifier and Type	Class	Description
class	AbstractConsistentHashFactory<CH extends ConsistentHash>

Classes in org.infinispan.distribution.ch.impl that implement ConsistentHash

Modifier and Type	Class	Description
class	AbstractConsistentHash
class	DefaultConsistentHash	Default ConsistentHash implementation.
class	ReplicatedConsistentHash	Special implementation of ConsistentHash for replicated caches.
class	ScatteredConsistentHash	CH used by scattered caches.

Methods in org.infinispan.distribution.ch.impl that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	DefaultConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
ConsistentHash	ReplicatedConsistentHash.remapAddresses(UnaryOperator<Address> remapper)
ConsistentHash	ScatteredConsistentHash.remapAddresses(UnaryOperator<Address> remapper)

Constructors in org.infinispan.distribution.ch.impl with parameters of type ConsistentHash

Constructor	Description
OwnershipStatistics(ConsistentHash ch, List<Address> activeNodes)

Uses of ConsistentHash in org.infinispan.distribution.group.impl

Classes in org.infinispan.distribution.group.impl that implement ConsistentHash

Modifier and Type	Class	Description
class	PartitionerConsistentHash	ConsistentHash wrapper that uses a KeyPartitioner instead of a Hash.

Methods in org.infinispan.distribution.group.impl that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	PartitionerConsistentHash.remapAddresses(UnaryOperator<Address> remapper)

Constructors in org.infinispan.distribution.group.impl with parameters of type ConsistentHash

Constructor	Description
PartitionerConsistentHash(ConsistentHash ch, KeyPartitioner keyPartitioner)

Uses of ConsistentHash in org.infinispan.distribution.impl

Methods in org.infinispan.distribution.impl that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	DistributionManagerImpl.getReadConsistentHash()
ConsistentHash	DistributionManagerImpl.getWriteConsistentHash()

Uses of ConsistentHash in org.infinispan.distribution.topologyaware

Constructors in org.infinispan.distribution.topologyaware with parameters of type ConsistentHash

Constructor	Description
TopologyInfo(ConsistentHash ch)

Uses of ConsistentHash in org.infinispan.distribution.util

Fields in org.infinispan.distribution.util declared as ConsistentHash

Modifier and Type	Field	Description
protected ConsistentHash	ReadOnlySegmentAwareCollection.ch
protected ConsistentHash	ReadOnlySegmentAwareIterator.ch
protected ConsistentHash	ReadOnlySegmentAwareMap.ch

Constructors in org.infinispan.distribution.util with parameters of type ConsistentHash

Constructor	Description
ReadOnlySegmentAwareCollection(Collection<E> set, ConsistentHash ch, org.infinispan.commons.util.IntSet allowedSegments)
ReadOnlySegmentAwareEntryCollection(Set<Map.Entry<K,V>> set, ConsistentHash ch, org.infinispan.commons.util.IntSet allowedSegments)
ReadOnlySegmentAwareEntryIterator(Iterator<Map.Entry<K,V>> iter, ConsistentHash ch, org.infinispan.commons.util.IntSet allowedSegments)
ReadOnlySegmentAwareIterator(Iterator<E> iter, ConsistentHash ch, org.infinispan.commons.util.IntSet allowedSegments)
ReadOnlySegmentAwareMap(Map<K,V> map, ConsistentHash ch, org.infinispan.commons.util.IntSet allowedSegments)

Uses of ConsistentHash in org.infinispan.notifications.cachelistener

Methods in org.infinispan.notifications.cachelistener with parameters of type ConsistentHash

Modifier and Type	Method	Description
void	CacheNotifier.notifyDataRehashed(ConsistentHash oldCH, ConsistentHash newCH, ConsistentHash unionCH, int newTopologyId, boolean pre)
void	CacheNotifierImpl.notifyDataRehashed(ConsistentHash oldCH, ConsistentHash newCH, ConsistentHash unionCH, int newTopologyId, boolean pre)

Uses of ConsistentHash in org.infinispan.notifications.cachelistener.event

Methods in org.infinispan.notifications.cachelistener.event that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	DataRehashedEvent.getConsistentHashAtEnd()
default ConsistentHash	TopologyChangedEvent.getConsistentHashAtEnd()	Deprecated. since 9.0 use TopologyChangedEvent.getReadConsistentHashAtEnd() or TopologyChangedEvent.getWriteConsistentHashAtEnd()
ConsistentHash	DataRehashedEvent.getConsistentHashAtStart()
default ConsistentHash	TopologyChangedEvent.getConsistentHashAtStart()	Deprecated. since 9.0 use TopologyChangedEvent.getReadConsistentHashAtStart() or TopologyChangedEvent.getWriteConsistentHashAtStart()
ConsistentHash	TopologyChangedEvent.getReadConsistentHashAtEnd()
ConsistentHash	TopologyChangedEvent.getReadConsistentHashAtStart()
ConsistentHash	DataRehashedEvent.getUnionConsistentHash()	Deprecated. Since 9.0
ConsistentHash	TopologyChangedEvent.getWriteConsistentHashAtEnd()
ConsistentHash	TopologyChangedEvent.getWriteConsistentHashAtStart()

Uses of ConsistentHash in org.infinispan.notifications.cachelistener.event.impl

Methods in org.infinispan.notifications.cachelistener.event.impl that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	EventImpl.getConsistentHashAtEnd()
ConsistentHash	EventImpl.getConsistentHashAtStart()
ConsistentHash	EventImpl.getReadConsistentHashAtEnd()
ConsistentHash	EventImpl.getReadConsistentHashAtStart()
ConsistentHash	EventImpl.getUnionConsistentHash()
ConsistentHash	EventImpl.getWriteConsistentHashAtEnd()
ConsistentHash	EventImpl.getWriteConsistentHashAtStart()

Methods in org.infinispan.notifications.cachelistener.event.impl with parameters of type ConsistentHash

Modifier and Type	Method	Description
void	EventImpl.setReadConsistentHashAtEnd(ConsistentHash readConsistentHashAtEnd)
void	EventImpl.setReadConsistentHashAtStart(ConsistentHash readConsistentHashAtStart)
void	EventImpl.setUnionConsistentHash(ConsistentHash unionConsistentHash)
void	EventImpl.setWriteConsistentHashAtEnd(ConsistentHash writeConsistentHashAtEnd)
void	EventImpl.setWriteConsistentHashAtStart(ConsistentHash writeConsistentHashAtStart)

Uses of ConsistentHash in org.infinispan.partitionhandling.impl

Methods in org.infinispan.partitionhandling.impl that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
static ConsistentHash	AvailabilityStrategy.ownersConsistentHash(CacheTopology topology, ConsistentHashFactory chFactory)	Compute the read consistent hash for a topology with a null union consistent hash.

Methods in org.infinispan.partitionhandling.impl with parameters of type ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)

Method parameters in org.infinispan.partitionhandling.impl with type arguments of type ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	AvailabilityStrategyContext.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)

Uses of ConsistentHash in org.infinispan.scattered.impl

Methods in org.infinispan.scattered.impl with parameters of type ConsistentHash

Modifier and Type	Method	Description
protected void	ScatteredStateConsumerImpl.beforeTopologyInstalled(int topologyId, boolean startRebalance, ConsistentHash previousWriteCh, ConsistentHash newWriteCh)

Uses of ConsistentHash in org.infinispan.server.hotrod.logging

Methods in org.infinispan.server.hotrod.logging with parameters of type ConsistentHash

Modifier and Type	Method	Description
void	Log_$logger.noMembersInHashTopology(ConsistentHash ch, String topologyMap)
void	Log.noMembersInHashTopology(ConsistentHash ch, String topologyMap)

Uses of ConsistentHash in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer with parameters of type ConsistentHash

Modifier and Type	Method	Description
protected void	StateConsumerImpl.beforeTopologyInstalled(int topologyId, boolean startRebalance, ConsistentHash previousWriteCh, ConsistentHash newWriteCh)
protected org.infinispan.commons.util.IntSet	StateConsumerImpl.getOwnedSegments(ConsistentHash consistentHash)

Uses of ConsistentHash in org.infinispan.stream.impl

Methods in org.infinispan.stream.impl with parameters of type ConsistentHash

Modifier and Type	Method	Description
org.reactivestreams.Publisher<S>	CompletionRehashPublisherDecorator.decorateLocal(ConsistentHash beginningCh, boolean onlyLocal, org.infinispan.commons.util.IntSet segmentsToFilter, org.reactivestreams.Publisher<S> localPublisher)
protected boolean	AbstractCacheStream.isPrimaryOwner(ConsistentHash ch, Object key)
<R> Object	ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)	Key tracking remote operation that doesn't have rehash enabled.
<R> Object	ClusterStreamManager.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)	Performs the remote stream operation without rehash awareness.
<R> Object	ClusterStreamManagerImpl.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
<R> Object	ClusterStreamManagerImpl.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
<R> Object	PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,R> operation, ClusterStreamManager.ResultsCallback<Collection<R>> callback)
<R> Object	PartitionAwareClusterStreamManager.remoteStreamOperation(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
Object	ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)	Key tracking remote operation that has rehash enabled
<R> Object	ClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)	Performs the remote stream operation with rehash awareness.
Object	ClusterStreamManagerImpl.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
<R> Object	ClusterStreamManagerImpl.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
Object	PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, KeyTrackingTerminalOperation<Original,K,?> operation, ClusterStreamManager.ResultsCallback<Collection<K>> callback)
<R> Object	PartitionAwareClusterStreamManager.remoteStreamOperationRehashAware(boolean parallelDistribution, boolean parallelStream, ConsistentHash ch, org.infinispan.commons.util.IntSet segments, Set<K> keysToInclude, Map<Integer,Set<K>> keysToExclude, boolean includeLoader, boolean entryStream, TerminalOperation<Original,R> operation, ClusterStreamManager.ResultsCallback<R> callback, Predicate<? super R> earlyTerminatePredicate)
protected Supplier<Stream<Original>>	AbstractCacheStream.supplierForSegments(ConsistentHash ch, org.infinispan.commons.util.IntSet targetSegments, Set<Object> excludedKeys)
protected Supplier<Stream<Original>>	AbstractCacheStream.supplierForSegments(ConsistentHash ch, org.infinispan.commons.util.IntSet targetSegments, Set<Object> excludedKeys, boolean usePrimary)	If usePrimary is true the segments are the primary segments but only those that exist in targetSegments.

Uses of ConsistentHash in org.infinispan.topology

Methods in org.infinispan.topology that return ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
ConsistentHash	CacheTopology.getCurrentCH()	The current consistent hash.
ConsistentHash	CacheTopologyControlCommand.getCurrentCH()
ConsistentHash	CacheTopology.getPendingCH()	The future consistent hash.
ConsistentHash	CacheTopologyControlCommand.getPendingCH()
ConsistentHash	CacheTopology.getReadConsistentHash()	Read operations should always go to the "current" owners.
ConsistentHash	CacheTopology.getUnionCH()	The union of the current and future consistent hashes.
ConsistentHash	CacheTopology.getWriteConsistentHash()	When there is a rebalance in progress, write operations should go to the union of the "current" and "future" owners.

Methods in org.infinispan.topology with parameters of type ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)
static boolean	ClusterTopologyManagerImpl.distLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)
static boolean	ClusterTopologyManagerImpl.scatteredLostDataCheck(ConsistentHash stableCH, List<Address> newMembers)

Method parameters in org.infinispan.topology with type arguments of type ConsistentHash

Modifier and Type	Method	Description
ConsistentHash	ClusterCacheStatus.calculateConflictHash(ConsistentHash preferredHash, Set<ConsistentHash> distinctHashes, List<Address> actualMembers)

Constructors in org.infinispan.topology with parameters of type ConsistentHash

Constructor	Description
CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, ConsistentHash unionCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)
CacheTopology(int topologyId, int rebalanceId, ConsistentHash currentCH, ConsistentHash pendingCH, CacheTopology.Phase phase, List<Address> actualMembers, List<PersistentUUID> persistentUUIDs)