org.infinispan.client.hotrod.impl.consistenthash

Class SegmentConsistentHash

java.lang.Object

org.infinispan.client.hotrod.impl.consistenthash.SegmentConsistentHash

All Implemented Interfaces:

ConsistentHash

public final class SegmentConsistentHash
extends Object
implements ConsistentHash

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
SegmentConsistentHash()

Method Summary

Modifier and Type	Method and Description
int	getNormalizedHash(Object object) Computes hash code of a given object, and then normalizes it to ensure a positive value is always returned.
int	getNumSegments()
Map<SocketAddress,Set<Integer>>	getPrimarySegmentsByServer()
int	getSegment(Object key)
SocketAddress[][]	getSegmentOwners()
Map<SocketAddress,Set<Integer>>	getSegmentsByServer()
SocketAddress	getServer(Object key)
void	init(Map<SocketAddress,Set<Integer>> servers2Hash, int numKeyOwners, int hashSpace)
void	init(SocketAddress[][] segmentOwners, int numSegments)

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentConsistentHash

public SegmentConsistentHash()

Method Detail

init

public void init(Map<SocketAddress,Set<Integer>> servers2Hash,
                 int numKeyOwners,
                 int hashSpace)

Specified by:

init in interface ConsistentHash

init

public void init(SocketAddress[][] segmentOwners,
                 int numSegments)

getServer

public SocketAddress getServer(Object key)

Specified by:

getServer in interface ConsistentHash

getSegment

public int getSegment(Object key)

getNormalizedHash

public int getNormalizedHash(Object object)

Description copied from interface: ConsistentHash

Computes hash code of a given object, and then normalizes it to ensure a positive value is always returned.

Specified by:

getNormalizedHash in interface ConsistentHash

Parameters:

object - to hash

Returns:

a non-null, non-negative normalized hash code for a given object

getSegmentsByServer

public Map<SocketAddress,Set<Integer>> getSegmentsByServer()

Specified by:

getSegmentsByServer in interface ConsistentHash

getPrimarySegmentsByServer

public Map<SocketAddress,Set<Integer>> getPrimarySegmentsByServer()

Specified by:

getPrimarySegmentsByServer in interface ConsistentHash

getNumSegments

public int getNumSegments()

getSegmentOwners

public SocketAddress[][] getSegmentOwners()