org.apache.ignite.internal.processors.affinity

Class GridAffinityProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.affinity.GridAffinityProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridAffinityProcessor
extends GridProcessorAdapter

Data affinity processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridAffinityProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
Object	affinityKey(String cacheName, Object key) Gets affinity key for cache key.
<K> org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.CacheAffinityProxy<K>	affinityProxy(String cacheName)
<K> Map<ClusterNode,Collection<K>>	mapKeysToNodes(String cacheName, Collection<? extends K> keys) Maps keys to nodes for given cache.
<K> ClusterNode	mapKeyToNode(String cacheName, K key) Maps single key to a node.
<K> ClusterNode	mapKeyToNode(String cacheName, K key, AffinityTopologyVersion topVer) Maps single key to a node.
<K> List<ClusterNode>	mapKeyToPrimaryAndBackups(String cacheName, K key) Map single key to primary and backup nodes.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).
void	start() Starts grid component.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, onKernalStart, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridAffinityProcessor

public GridAffinityProcessor(GridKernalContext ctx)

Parameters:

ctx - Context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

mapKeysToNodes

public <K> Map<ClusterNode,Collection<K>> mapKeysToNodes(@Nullable
                                                String cacheName,
                                                @Nullable
                                                Collection<? extends K> keys)
                                              throws IgniteCheckedException

Maps keys to nodes for given cache.

Parameters:

cacheName - Cache name.

keys - Keys to map.

Returns:

Map of nodes to keys.

Throws:

IgniteCheckedException - If failed.

mapKeyToNode

@Nullable
public <K> ClusterNode mapKeyToNode(@Nullable
                                    String cacheName,
                                    K key)
                         throws IgniteCheckedException

Maps single key to a node.

Parameters:

cacheName - Cache name.

key - Key to map.

Returns:

Picked node.

Throws:

IgniteCheckedException - If failed.

mapKeyToNode

@Nullable
public <K> ClusterNode mapKeyToNode(@Nullable
                                    String cacheName,
                                    K key,
                                    AffinityTopologyVersion topVer)
                         throws IgniteCheckedException

Maps single key to a node.

Parameters:

cacheName - Cache name.

key - Key to map.

Returns:

Picked node.

Throws:

IgniteCheckedException - If failed.

mapKeyToPrimaryAndBackups

public <K> List<ClusterNode> mapKeyToPrimaryAndBackups(@Nullable
                                              String cacheName,
                                              K key)
                                            throws IgniteCheckedException

Map single key to primary and backup nodes.

Parameters:

cacheName - Cache name.

key - Key to map.

Returns:

Affinity nodes, primary first.

Throws:

IgniteCheckedException - If failed.

affinityKey

@Nullable
public Object affinityKey(@Nullable
                          String cacheName,
                          @Nullable
                          Object key)
                   throws IgniteCheckedException

Gets affinity key for cache key.

Parameters:

cacheName - Cache name.

key - Cache key.

Returns:

Affinity key.

Throws:

IgniteCheckedException - In case of error.

affinityProxy

public <K> org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.CacheAffinityProxy<K> affinityProxy(String cacheName)

Parameters:

cacheName - Cache name.

Returns:

Cache affinity.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridProcessorAdapter