edu.umass.cs.reconfiguration.reconfigurationutils

Class ConsistentHashing<NodeIDType>

java.lang.Object

edu.umass.cs.reconfiguration.reconfigurationutils.ConsistentHashing<NodeIDType>

Type Parameters:

NodeIDType - A utility class with mostly static methods to help with consistent hashing related functions. It is okay to suppress warnings about unchecked types of serversArray objects as they have to be of type NodeIDType.

public class ConsistentHashing<NodeIDType>
extends java.lang.Object

Author:

V. Arun

Constructor Summary

Constructors

Constructor and Description
ConsistentHashing(NodeIDType[] servers)
ConsistentHashing(NodeIDType[] servers, int numReplicas)
ConsistentHashing(java.util.Set<NodeIDType> servers)
ConsistentHashing(java.util.Set<NodeIDType> servers, boolean replicateAll)

Method Summary

Modifier and Type	Method and Description
protected NodeIDType	getNode(java.lang.String name)
java.util.Set<NodeIDType>	getReplicatedServers(java.lang.String name)
java.util.ArrayList<NodeIDType>	getReplicatedServersArray(java.lang.String name)
java.util.ArrayList<NodeIDType>	getReplicatedServersArray(java.lang.String name, int k)
static void	main(java.lang.String[] args)
void	refresh(NodeIDType[] servers, int numReplicas)
void	refresh(java.util.Set<NodeIDType> servers)
void	refresh(java.util.Set<NodeIDType> servers, int numReplicas)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsistentHashing

public ConsistentHashing(NodeIDType[] servers)

Parameters:

servers -

ConsistentHashing

public ConsistentHashing(NodeIDType[] servers,
                         int numReplicas)

Parameters:

servers -

numReplicas -

ConsistentHashing

public ConsistentHashing(java.util.Set<NodeIDType> servers)

Parameters:

servers -

ConsistentHashing

public ConsistentHashing(java.util.Set<NodeIDType> servers,
                         boolean replicateAll)

Parameters:

servers -

replicateAll -

Method Detail

refresh

public void refresh(NodeIDType[] servers,
                    int numReplicas)

Parameters:

servers -

numReplicas -

refresh

public void refresh(java.util.Set<NodeIDType> servers)

Parameters:

servers -

refresh

public void refresh(java.util.Set<NodeIDType> servers,
                    int numReplicas)

Parameters:

servers -

numReplicas -

getReplicatedServers

public java.util.Set<NodeIDType> getReplicatedServers(java.lang.String name)

Parameters:

name -

Returns:

Consecutive servers on the consistent hash ring to which this name hashes.

getReplicatedServersArray

public java.util.ArrayList<NodeIDType> getReplicatedServersArray(java.lang.String name)

Parameters:

name -

Returns:

Consecutive servers on the consistent hash ring to which this name hashes returned as an array.

getReplicatedServersArray

public java.util.ArrayList<NodeIDType> getReplicatedServersArray(java.lang.String name,
                                                                 int k)

Parameters:

name -

k -

Returns:

k consecutive servers on the consistent hash ring to which this name hashes returned as an array.

getNode

protected NodeIDType getNode(java.lang.String name)

main

public static void main(java.lang.String[] args)

Parameters:

args -