org.gridgain.grid.cache.affinity.rendezvous

Class GridCacheRendezvousAffinityFunction

java.lang.Object

org.gridgain.grid.cache.affinity.rendezvous.GridCacheRendezvousAffinityFunction

All Implemented Interfaces:

Externalizable, Serializable, GridCacheAffinityFunction

public class GridCacheRendezvousAffinityFunction
extends Object
implements GridCacheAffinityFunction, Externalizable

Affinity function for partitioned cache based on Highest Random Weight algorithm. This function supports the following configuration:

• partitions - Number of partitions to spread across nodes.
• excludeNeighbors - If set to true, will exclude same-host-neighbors from being backups of each other. Note that backupFilter is ignored if excludeNeighbors is set to true.
• backupFilter - Optional filter for back up nodes. If provided, then only nodes that pass this filter will be selected as backup nodes. If not provided, then primary and backup nodes will be selected out of all nodes available for this cache.

Cache affinity can be configured for individual caches via GridCacheConfiguration.getAffinity() method.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_PARTITION_COUNT Default number of partitions.

Constructor Summary

Constructors

Constructor and Description
GridCacheRendezvousAffinityFunction() Empty constructor with all defaults.
GridCacheRendezvousAffinityFunction(boolean exclNeighbors) Initializes affinity with flag to exclude same-host-neighbors from being backups of each other and specified number of backups.
GridCacheRendezvousAffinityFunction(boolean exclNeighbors, int parts) Initializes affinity with flag to exclude same-host-neighbors from being backups of each other, and specified number of backups and partitions.
GridCacheRendezvousAffinityFunction(int parts, GridBiPredicate<GridNode,GridNode> backupFilter) Initializes optional counts for replicas and backups.

Method Summary

Methods

Modifier and Type	Method and Description
List<GridNode>	assignPartition(int part, List<GridNode> nodes, int backups, Map<UUID,Collection<GridNode>> neighborhoodCache) Returns collection of nodes (primary first) for specified partition.
List<List<GridNode>>	assignPartitions(GridCacheAffinityFunctionContext affCtx) Gets affinity nodes for a partition.
GridBiPredicate<GridNode,GridNode>	getBackupFilter() Gets optional backup filter.
GridCacheAffinityNodeHashResolver	getHashIdResolver() Gets hash ID resolver for nodes.
int	getPartitions() Gets total number of key partitions.
boolean	isExcludeNeighbors() Checks flag to exclude same-host-neighbors from being backups of each other (default is false).
int	partition(Object key) Gets partition number for a given key starting from 0.
int	partitions() Gets total number of partitions available.
void	readExternal(ObjectInput in)
void	removeNode(UUID nodeId) Removes node from affinity.
void	reset() Resets cache affinity to its initial state.
void	setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter) Sets optional backup filter.
void	setExcludeNeighbors(boolean exclNeighbors) Sets flag to exclude same-host-neighbors from being backups of each other (default is false).
void	setHashIdResolver(GridCacheAffinityNodeHashResolver hashIdRslvr) Sets hash ID resolver for nodes.
void	setPartitions(int parts) Sets total number of partitions.
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_PARTITION_COUNT

public static final int DFLT_PARTITION_COUNT

Default number of partitions.

See Also:

Constant Field Values

Constructor Detail

GridCacheRendezvousAffinityFunction

public GridCacheRendezvousAffinityFunction()

Empty constructor with all defaults.

GridCacheRendezvousAffinityFunction

public GridCacheRendezvousAffinityFunction(boolean exclNeighbors)

Initializes affinity with flag to exclude same-host-neighbors from being backups of each other and specified number of backups.

Note that excludeNeighbors parameter is ignored if #getBackupFilter() is set.

Parameters:

exclNeighbors - True if nodes residing on the same host may not act as backups of each other.

GridCacheRendezvousAffinityFunction

public GridCacheRendezvousAffinityFunction(boolean exclNeighbors,
                                   int parts)

Initializes affinity with flag to exclude same-host-neighbors from being backups of each other, and specified number of backups and partitions.

Note that excludeNeighbors parameter is ignored if #getBackupFilter() is set.

Parameters:

exclNeighbors - True if nodes residing on the same host may not act as backups of each other.

parts - Total number of partitions.

GridCacheRendezvousAffinityFunction

public GridCacheRendezvousAffinityFunction(int parts,
                                   @Nullable
                                   GridBiPredicate<GridNode,GridNode> backupFilter)

Initializes optional counts for replicas and backups.

Note that excludeNeighbors parameter is ignored if backupFilter is set.

Parameters:

parts - Total number of partitions.

backupFilter - Optional back up filter for nodes. If provided, backups will be selected from all nodes that pass this filter. First argument for this filter is primary node, and second argument is node being tested.

Note that excludeNeighbors parameter is ignored if backupFilter is set.

Method Detail

getPartitions

public int getPartitions()

Gets total number of key partitions. To ensure that all partitions are equally distributed across all nodes, please make sure that this number is significantly larger than a number of nodes. Also, partition size should be relatively small. Try to avoid having partitions with more than quarter million keys.

Note that for fully replicated caches this method should always return 1.

Returns:

Total partition count.

setPartitions

public void setPartitions(int parts)

Sets total number of partitions.

Parameters:

parts - Total number of partitions.

getHashIdResolver

public GridCacheAffinityNodeHashResolver getHashIdResolver()

Gets hash ID resolver for nodes. This resolver is used to provide alternate hash ID, other than node ID.

Node IDs constantly change when nodes get restarted, which causes them to be placed on different locations in the hash ring, and hence causing repartitioning. Providing an alternate hash ID, which survives node restarts, puts node on the same location on the hash ring, hence minimizing required repartitioning.

Returns:

Hash ID resolver.

setHashIdResolver

public void setHashIdResolver(GridCacheAffinityNodeHashResolver hashIdRslvr)

Sets hash ID resolver for nodes. This resolver is used to provide alternate hash ID, other than node ID.

Node IDs constantly change when nodes get restarted, which causes them to be placed on different locations in the hash ring, and hence causing repartitioning. Providing an alternate hash ID, which survives node restarts, puts node on the same location on the hash ring, hence minimizing required repartitioning.

Parameters:

hashIdRslvr - Hash ID resolver.

getBackupFilter

@Nullable
public GridBiPredicate<GridNode,GridNode> getBackupFilter()

Gets optional backup filter. If not null, backups will be selected from all nodes that pass this filter. First node passed to this filter is primary node, and second node is a node being tested.

Note that excludeNeighbors parameter is ignored if backupFilter is set.

Returns:

Optional backup filter.

setBackupFilter

public void setBackupFilter(@Nullable
                   GridBiPredicate<GridNode,GridNode> backupFilter)

Sets optional backup filter. If provided, then backups will be selected from all nodes that pass this filter. First node being passed to this filter is primary node, and second node is a node being tested.

Note that excludeNeighbors parameter is ignored if backupFilter is set.

Parameters:

backupFilter - Optional backup filter.

isExcludeNeighbors

public boolean isExcludeNeighbors()

Checks flag to exclude same-host-neighbors from being backups of each other (default is false).

Note that excludeNeighbors parameter is ignored if #getBackupFilter() is set.

Returns:

True if nodes residing on the same host may not act as backups of each other.

setExcludeNeighbors

public void setExcludeNeighbors(boolean exclNeighbors)

Sets flag to exclude same-host-neighbors from being backups of each other (default is false).

Note that excludeNeighbors parameter is ignored if #getBackupFilter() is set.

Parameters:

exclNeighbors - True if nodes residing on the same host may not act as backups of each other.

assignPartition

public List<GridNode> assignPartition(int part,
                             List<GridNode> nodes,
                             int backups,
                             @Nullable
                             Map<UUID,Collection<GridNode>> neighborhoodCache)

Returns collection of nodes (primary first) for specified partition.

reset

public void reset()

Resets cache affinity to its initial state. This method will be called by the system any time the affinity has been sent to remote node where it has to be reinitialized. If your implementation of affinity function has no initialization logic, leave this method empty.

Specified by:

reset in interface GridCacheAffinityFunction

partitions

public int partitions()

Gets total number of partitions available. All caches should always provide correct partition count which should be the same on all participating nodes. Note that partitions should always be numbered from 0 inclusively to N exclusively without any gaps.

Specified by:

partitions in interface GridCacheAffinityFunction

Returns:

Total partition count.

partition

public int partition(Object key)

Gets partition number for a given key starting from 0. Partitioned caches should make sure that keys are about evenly distributed across all partitions from 0 to partition count for best performance.

Note that for fully replicated caches it is possible to segment key sets among different grid node groups. In that case each node group should return a unique partition number. However, unlike partitioned cache, mappings of keys to nodes in replicated caches are constant and a node cannot migrate from one partition to another.

Specified by:

partition in interface GridCacheAffinityFunction

Parameters:

key - Key to get partition for.

Returns:

Partition number for a given key.

assignPartitions

public List<List<GridNode>> assignPartitions(GridCacheAffinityFunctionContext affCtx)

Gets affinity nodes for a partition. In case of replicated cache, all returned nodes are updated in the same manner. In case of partitioned cache, the returned list should contain only the primary and back up nodes with primary node being always first.

Note that partitioned affinity must obey the following contract: given that node N is primary for some key K, if any other node(s) leave grid and no node joins grid, node N will remain primary for key K.

Specified by:

assignPartitions in interface GridCacheAffinityFunction

Parameters:

affCtx - Affinity function context. Will provide all required information to calculate new partition assignments.

Returns:

Unmodifiable list indexed by partition number. Each element of array is a collection in which first node is a primary node and other nodes are backup nodes.

removeNode

public void removeNode(UUID nodeId)

Removes node from affinity. This method is called when it is safe to remove left node from affinity mapping.

Specified by:

removeNode in interface GridCacheAffinityFunction

Parameters:

nodeId - ID of node to remove.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException